cron_runner

Documentation

Index

• type ITaskModel
• type Server
  • func New(logger *zap.Logger, cache cache.Cache) (Server, error)

Types

type ITaskModel

type ITaskModel interface {
	GetId() string
	GetName() string
	GetSpec() string
}

type Server

type Server interface {
	Start()

	TaskCountWait()

	// Stop 停止 cron 服务
	Stop()

	// AddTask 增加定时任务
	AddTask(task ITaskModel)

	// RemoveTask 删除定时任务
	RemoveTask(taskId string)

	// AddJob 增加定时任务执行的工作内容
	AddJob(task ITaskModel) cron.FuncJob
	// contains filtered or unexported methods
}

singleton

func New

func New(logger *zap.Logger, cache cache.Cache) (Server, error)