cron_task

Documentation

Index

• Constants
• Variables
• func GetSysProcAttr() *syscall.SysProcAttr
• func KillProcess(proc *exec.Cmd) error
• type CronManager
  • func GetCronManager() *CronManager
  • func NewCronManager() *CronManager
  • func (m *CronManager) AddTask(task model.MCronTask) error
  • func (m *CronManager) DeleteTask(id string)
  • func (m *CronManager) KillTask(uuid string) error
  • func (m *CronManager) ListRunningTask() []model.MCronTask
• type ProcessManager
  • func NewProcessManager() *ProcessManager
  • func (pm *ProcessManager) KillProcess(id string) error
  • func (pm *ProcessManager) ListProcess() map[string]*exec.Cmd
  • func (pm *ProcessManager) RunProcess(file io.Writer, task model.MCronTask) error

Constants

const (
	CRON_RESULT_STATUS_RUNNING = "RUNNING"
	CRON_RESULT_STATUS_END     = "END"
)

CRON_RESULT_STATUS

const (
	CRON_TASK_TYPE_LINUX_SHELL = "LINUX_SHELL"
)

CRON_TASK_TYPE

const LINUX_SHELL = "/bin/bash"

CRON

const PERM_0777 = 0777

Variables

var CRON_TASK_DISABLE = false

var CRON_TASK_EANBLE = true

Functions

func GetSysProcAttr

func GetSysProcAttr() *syscall.SysProcAttr

func KillProcess

func KillProcess(proc *exec.Cmd) error

Types

type CronManager

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

func GetCronManager

func GetCronManager() *CronManager

func NewCronManager

func NewCronManager() *CronManager

func (*CronManager) AddTask

func (m *CronManager) AddTask(task model.MCronTask) error

func (*CronManager) DeleteTask

func (m *CronManager) DeleteTask(id string)

func (*CronManager) KillTask

func (m *CronManager) KillTask(uuid string) error

func (*CronManager) ListRunningTask

func (m *CronManager) ListRunningTask() []model.MCronTask

type ProcessManager

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

ProcessManager

func NewProcessManager

func NewProcessManager() *ProcessManager

func (*ProcessManager) KillProcess

func (pm *ProcessManager) KillProcess(id string) error

func (*ProcessManager) ListProcess

func (pm *ProcessManager) ListProcess() map[string]*exec.Cmd

func (*ProcessManager) RunProcess

func (pm *ProcessManager) RunProcess(file io.Writer, task model.MCronTask) error