scheduler

Documentation

Index

• func GetSchedulerGroups() (groups map[string]Group, err error)
• type Group
  • func (group Group) Schedule(ctx context.Context, runner func(context.Context), logger *util.Logger, ...)
  • func (group Group) ScheduleSecondary(ctx context.Context, runner func(context.Context), logger *util.Logger, ...)

Functions

func GetSchedulerGroups

func GetSchedulerGroups() (groups map[string]Group, err error)

Types

type Group

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

func (Group) Schedule

func (group Group) Schedule(ctx context.Context, runner func(context.Context), logger *util.Logger, logName string)

func (Group) ScheduleSecondary

func (group Group) ScheduleSecondary(ctx context.Context, runner func(context.Context), logger *util.Logger, logName string, primaryGroup Group)

ScheduleSecondary - Behaves almost like Schedule, but ignores the point in time where the primary group also has a run (to avoid overlapping statistics)