task

Documentation

Index

• func AllExGroups() *map[string]LogExportGroup
• func InitGlobalSyslogHander()
• type K8sTaskHandler
  • func (this *K8sTaskHandler) CheckClusterStatusTask()
• type LogExportGroup
• type SyslogManager
  • func NewSyslogTaskManager(exportTypes *map[string]LogExportGroup) *SyslogManager
  • func (this *SyslogManager) ReGenSyncSyslogTask()
• type SystemCheckHandler
  • func (this *SystemCheckHandler) SystemCheck()
• type TaskHandler
  • func NewTaskHandler() *TaskHandler
  • func (this *TaskHandler) AddByFunc(id string, spec string, f func()) error
  • func (this *TaskHandler) AddByID(id string, spec string, cmd cron.Job) error
  • func (this *TaskHandler) DelByID(id string)
  • func (this *TaskHandler) IsExists(jid string) bool
  • func (this *TaskHandler) Start()
  • func (this *TaskHandler) Stop()
• type TaskService
  • func (this *TaskService) RemoveTask() models.Result

Functions

func AllExGroups

func AllExGroups() *map[string]LogExportGroup

func InitGlobalSyslogHander

func InitGlobalSyslogHander()

Types

type K8sTaskHandler

type K8sTaskHandler struct {
}

func (*K8sTaskHandler) CheckClusterStatusTask

func (this *K8sTaskHandler) CheckClusterStatusTask()

*

• 安全检查任务

type LogExportGroup

type LogExportGroup struct {
	ExportName string
	TaskId     string
	LastTime   string
}

type SyslogManager

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

var GlobalSysLogManager *SyslogManager

func NewSyslogTaskManager

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

func (*SyslogManager) ReGenSyncSyslogTask

func (this *SyslogManager) ReGenSyncSyslogTask()

type SystemCheckHandler

type SystemCheckHandler struct {
}

func (*SystemCheckHandler) SystemCheck

func (this *SystemCheckHandler) SystemCheck()

type TaskHandler

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

var SysLogTaskHandler *TaskHandler

func NewTaskHandler

func NewTaskHandler() *TaskHandler

func (*TaskHandler) AddByFunc

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

AddByFunc add function as TaskHandler task

func (*TaskHandler) AddByID

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 (*TaskHandler) DelByID

func (this *TaskHandler) DelByID(id string)

DelByID remove one TaskHandler task

func (*TaskHandler) IsExists

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

IsExists check the TaskHandler task whether existed with c id

func (*TaskHandler) Start

func (this *TaskHandler) Start()

Start start the TaskHandler engine

func (*TaskHandler) Stop

func (this *TaskHandler) Stop()

Stop stop the TaskHandler engine

type TaskService

type TaskService struct {
	Task *models.Task
}

func (*TaskService) RemoveTask

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