schedule

type Config struct {
	PollInterval     time.Duration
	OperationTimeout time.Duration
	Observer         Observer
}

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

type Event struct {
	Name        string
	Outcome     Outcome
	ScheduledAt time.Time
	JobID       job.ID
	At          time.Time
}

type Factory[P any] struct {
	// contains filtered or unexported fields
}

type MaterializeFunc func(context.Context, job.Executor, Occurrence) (job.DispatchResult, error)

type Observer interface {
	Observe(context.Context, Event)
}

type ObserverFunc func(context.Context, Event)

type Occurrence struct {
	Schedule    string
	ScheduledAt time.Time
	TimeZone    string
	// contains filtered or unexported fields
}

type Option func(*definitionSettings) error

type Outcome string

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

type Result struct {
	Name        string
	Outcome     Outcome
	ScheduledAt time.Time
	JobID       job.ID
}

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

type Status struct {
	Name             string
	Expression       string
	TimeZone         string
	JobName          string
	Queue            string
	MisfireGrace     time.Duration
	Fingerprint      string
	NextRunAt        time.Time
	LastEvaluatedAt  *time.Time
	LastCursorAt     *time.Time
	LastOccurrenceAt *time.Time
	LastJobID        job.ID
	LastOutcome      Outcome
	CreatedAt        *time.Time
	UpdatedAt        *time.Time
}

type Store interface {
	Materialize(context.Context, Definition, MaterializeFunc) (Result, error)
	List(context.Context, []Definition) ([]Status, error)
}