cron

type Cron interface {
	// Start the cron scheduler
	Start() (<-chan *Execution, error)
	// Stop the cron scheduler
	Stop()
	// Schedule an event to be executed on its schedule. This should
	// be called when adding events outside of Reload operations.
	// This method is idempotent and can be used to update existing schedules
	// of events as well as add new events.
	Schedule(event Event)
	// Unschedule an event from the scheduler.
	Unschedule(event string)
}

type Event interface {
	Schedule
	// GetID is a unique identifier for this event that can be
	// used to update or remove it from the scheduler.
	GetID() string
}

type Execution struct {
	// Event id that was executed
	Event Event
	// Time the event was executed
	Time int64
}

type LoadEvents func(qb.LimitOffset) ([]Event, int, error)

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

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

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

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

type Result string

type Schedule interface {
	// GetMinute of execution, [0,59]
	GetMinute() int32
	// GetDayOfWeek of execution [1,7]
	GetDayOfWeek() int32
	// GetDayOfMonth of execution [1,31]
	GetDayOfMonth() int32
	// GetMonth of execution, [1,12]
	GetMonth() int32
	// GetHour of execution [0,23]
	GetHour() int32
}

type Scheduler interface {
	// GetNextExecution determines the next execution time based on the provided schedule and returns.
	// All times are UTC.
	GetNextExecution(schedule Schedule) time.Time
}