tasks

package

v0.0.7 Latest Latest Go to latest Published: Mar 17, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 8 Imported by: 0

Details

View Source

const CMD_TASK_PREFIX = "task:"

View Source

const MODE_OVERIDE = SchedulingMode(0x01) // replace task if already scheduled

View Source

const MODE_REPLACE = MODE_OVERIDE | MODE_RESET // replace task and reset task schedule

View Source

const MODE_RESET = SchedulingMode(0x02) // reset actual delay if already scheduled

This section is empty.

func TaskReconciler(count int) controller.ConfigurationModifier

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

func NewBaseTask(ttype, name string) BaseTask

func (this *BaseTask) Execute(logger logger.LogContext) reconcile.Status

func (this *BaseTask) Id() string

type SchedulingMode byte

type Task interface {
	Id() string
	Execute(logger logger.LogContext) reconcile.Status
}

type Tasks interface {
	ScheduleTask(Task, SchedulingMode)
}

func GetTaskClient(controller controller.Interface) Tasks