scheduler

Documentation

Index

• Constants
• func NewManager(lc logger.LoggingClient, config *config.ConfigurationStruct) interfaces.SchedulerManager
• type Executor
  • func (executor *Executor) Initialize(interval models.Interval, lc logger.LoggingClient) errors.EdgeX
  • func (executor *Executor) IsComplete() bool
  • func (executor *Executor) UpdateNextTime()

Constants

const (
	SchedulerTimeFormat = "20060102T150405"
)

Functions

func NewManager

func NewManager(lc logger.LoggingClient, config *config.ConfigurationStruct) interfaces.SchedulerManager

NewManager creates a new scheduler manager for running the interval job

Types

type Executor

type Executor struct {
	Interval           models.Interval
	IntervalActionsMap map[string]models.IntervalAction
	StartTime          time.Time
	EndTime            time.Time
	NextTime           time.Time
	Frequency          time.Duration
	MarkedDeleted      bool
}

func (*Executor) Initialize

func (executor *Executor) Initialize(interval models.Interval, lc logger.LoggingClient) errors.EdgeX

Initialize initialize the Executor with interval. This function should be invoked after adding or updating the interval.

func (*Executor) IsComplete

func (executor *Executor) IsComplete() bool

IsComplete checks whether the Executor is complete

func (*Executor) UpdateNextTime

func (executor *Executor) UpdateNextTime()

UpdateNextTime increase the NextTime by frequency if the Executor not complete