scheduler

Documentation

Index

• Constants
• type Schedule
  • func (schedule Schedule) Schedule(ctx context.Context, runner func(context.Context), logger *util.Logger, ...)
  • func (schedule Schedule) ScheduleSecondary(ctx context.Context, primarySchedule Schedule, runner func(context.Context), ...)
• type Scheduler
  • func GetScheduler() (scheduler Scheduler, err error)

Constants

const FullSnapshotMinutes = 10

const FullSnapshotsPerHour = 6

Types

type Schedule

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

func (Schedule) Schedule

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

func (Schedule) ScheduleSecondary

func (schedule Schedule) ScheduleSecondary(ctx context.Context, primarySchedule Schedule, runner func(context.Context), logger *util.Logger, logName string)

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

type Scheduler

type Scheduler struct {
	TenSecond Schedule
	OneMinute Schedule
	TenMinute Schedule
}

func GetScheduler

func GetScheduler() (scheduler Scheduler, err error)