scheduler

Documentation

Index

• type ScheduledTask
  • func CreateRecurringTask(name string, function TaskFunc, interval time.Duration) *ScheduledTask
  • func CreateTask(name string, function TaskFunc, timeToExecution time.Duration) *ScheduledTask
  • func (task *ScheduledTask) Cancel()
  • func (task *ScheduledTask) String() string
• type TaskFunc

Types

type ScheduledTask

type ScheduledTask struct {
	Name      string        `json:"name"`
	Interval  time.Duration `json:"interval"`
	Recurring bool          `json:"recurring"`
	// contains filtered or unexported fields
}

func CreateRecurringTask

func CreateRecurringTask(name string, function TaskFunc, interval time.Duration) *ScheduledTask

func CreateTask

func CreateTask(name string, function TaskFunc, timeToExecution time.Duration) *ScheduledTask

WARNING: Tasks will run on every cluster node, so use this carefully.

func (*ScheduledTask) Cancel

func (task *ScheduledTask) Cancel()

func (*ScheduledTask) String

func (task *ScheduledTask) String() string

type TaskFunc

type TaskFunc func()