schedulerrecovery

type Attempt struct {
	ID        string
	StartedAt time.Time
	Stuck     []string
}

type AttemptStore interface {
	Begin(context.Context, Attempt) (bool, error)
	Finish(context.Context, Result) error
}

type CommandConfig struct {
	Checkpoint []string
	Restart    []string
	Progress   []string
	Timeout    time.Duration
}

type CommandExecutor struct {
	Config CommandConfig
}

type CommandObserver struct {
	Argv    []string
	Timeout time.Duration
}

type Controller struct {
	Policy    Policy
	Observer  Observer
	Heartbeat HeartbeatReader
	Attempts  AttemptStore
	Executor  Executor
	Events    EventSink
	Now       func() time.Time
}

type Decision struct {
	Recover bool
	Reason  string
	Stuck   []string
}

type Event struct {
	At        time.Time `json:"at"`
	State     string    `json:"state"`
	Reason    string    `json:"reason"`
	AttemptID string    `json:"attempt_id,omitempty"`
	Stuck     []string  `json:"stuck,omitempty"`
	Error     string    `json:"error,omitempty"`
}

type EventSink interface {
	Emit(context.Context, Event) error
}

type Executor interface {
	Checkpoint(context.Context, Attempt) (string, error)
	RestartDispatcher(context.Context, Attempt) error
	AwaitProgress(context.Context, Attempt) (progressed, remaining []string, err error)
}

type FileStore struct {
	Path     string
	LockPath string
}

type Heartbeat struct {
	At       time.Time `json:"at"`
	Progress string    `json:"progress"`
}

type HeartbeatReader interface {
	ReadHeartbeat(context.Context) (Heartbeat, error)
}

type MetricsFileSink struct{ Path string }

type MultiSink []EventSink

type Observation struct {
	ObservedAt      time.Time
	ActiveIntents   int
	PendingCreates  []PendingCreate
	ManagerUptime   time.Duration
	LastRecoveryAt  time.Time
	HeartbeatAt     time.Time
	RecoveryRunning bool
}

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

type PendingCreate struct {
	ID            string        `json:"id"`
	Age           time.Duration `json:"age_nanoseconds"`
	CreateAttempt int           `json:"create_attempt"`
}

type Policy struct {
	MinimumStuckAge time.Duration
	MinimumUptime   time.Duration
	Cooldown        time.Duration
	HeartbeatStale  time.Duration
}

type Result struct {
	AttemptID  string
	Suppressed bool
	Checkpoint string
	Progressed []string
	Remaining  []string
	Recovered  bool
	FinishedAt time.Time
	Error      string
}