task

package

v0.0.0-...-e6d3209 Latest Latest Go to latest Published: Jul 24, 2021 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func AllExGroups() *map[string]LogExportGroup

func InitGlobalSyslogHander()

type K8sTaskHandler struct {
}

func (this *K8sTaskHandler) CheckClusterStatusTask()

*

type LogExportGroup struct {
	ExportName string
	TaskId     string
	LastTime   string
}

type SyslogManager struct {
	CurGroup    string
	ExportTypes *map[string]LogExportGroup
}

var GlobalSysLogManager *SyslogManager

func NewSyslogTaskManager(exportTypes *map[string]LogExportGroup) *SyslogManager

func (this *SyslogManager) ReGenSyncSyslogTask()

type SystemCheckHandler struct {
}

func (this *SystemCheckHandler) SystemCheck()

type TaskHandler struct {
	// contains filtered or unexported fields
}

var SysLogTaskHandler *TaskHandler

func NewTaskHandler() *TaskHandler

func (this *TaskHandler) AddByFunc(id string, spec string, f func()) error

AddByFunc add function as TaskHandler task

func (this *TaskHandler) AddByID(id string, spec string, cmd cron.Job) error

AddByID add one TaskHandler task id is unique spec is the TaskHandler expression

func (this *TaskHandler) DelByID(id string)

DelByID remove one TaskHandler task

func (this *TaskHandler) IsExists(jid string) bool

IsExists check the TaskHandler task whether existed with c id

func (this *TaskHandler) Start()

Start start the TaskHandler engine

func (this *TaskHandler) Stop()

Stop stop the TaskHandler engine

type TaskService struct {
	Task *models.Task
}

func (this *TaskService) RemoveTask() models.Result