cron_server

Documentation

Index

• type Server
  • func New(logger *zap.Logger, db db.Repo, cache cache.Repo) (Server, error)

Types

type Server

type Server interface {

	// Start 启动 cron 服务
	Start()

	// Stop 停止 cron 服务
	Stop()

	// AddTask 增加定时任务
	AddTask(task *cron_task_repo.CronTask)

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

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

func New

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