Versions in this module Expand all Collapse all v1 v1.0.0 Mar 23, 2021 Changes in this version + type ScheduledTask struct + Args []tasks.Arg + Headers map[string]interface{} + Id string + Spec string + TaskCode string + TaskQueue string + func NewScheduledTask(id, taskCode, spec, taskQueue string, args ...tasks.Arg) *ScheduledTask + func (task *ScheduledTask) Equal(other *ScheduledTask) bool + func (task *ScheduledTask) Signature() *tasks.Signature + type ServerRef struct + type XServer struct + func NewServer(server *machinery.Server) *XServer + func (server *XServer) RegisterScheduledTask(task *ScheduledTask) error + func (server *XServer) RegisterScheduledTasks(tasks []*ScheduledTask) error + func (server *XServer) ReloadScheduledTasks(tasks []*ScheduledTask) error + func (server *XServer) RemoveScheduledTask(id string)
Go to main page