scheduler

type Client interface {
	// ListSchedules returns all schedules.
	ListSchedules(ctx context.Context) ([]*Schedule, error)

	// GetSchedule returns a schedule by id or nil if not found.
	GetSchedule(ctx context.Context, id string) (*Schedule, error)

	// Schedule creates or updates a schedule (generic upsert via Has flags).
	Schedule(ctx context.Context, in *MutableSchedule) error

	// Run creates or updates a run (generic upsert via Has flags).
	Run(ctx context.Context, in *MutableRun) error

	// GetRuns lists runs for a schedule, optionally filtered by since id.
	GetRuns(ctx context.Context, scheduleID, since string) ([]*Run, error)

	// RunDue lists all schedules, checks if they are due to run,
	// and triggers runs while avoiding duplicates. Returns number of started runs.
	RunDue(ctx context.Context) (int, error)
}

type MutableRun = sch.MutableRun

type MutableSchedule = sch.MutableSchedule

type Run = sch.Run

type Schedule = sch.Schedule