scheduler

type BatchWaker interface {
	WakeMany(ctx context.Context, targets []WakeTarget) []error
}

type CycleResult struct {
	PendingRuns      int
	ActiveRuns       int
	SessionsScanned  int
	RecoveredLeases  int
	WakeAttempts     int
	WakeSucceeded    int
	WakeFailed       int
	NoMatchRuns      int
	RecentlyNotified int
	UnclaimableRuns  int
	Paused           bool
	SelectedRunIDs   []string
	NoMatchRunIDs    []string
	RecoveredRunIDs  []string
}

type Option func(*Scheduler)

type PauseStore interface {
	GetSchedulerPause(ctx context.Context) (taskpkg.SchedulerPauseState, error)
}

type RebuildResult struct {
	PendingRuns     int
	ActiveRuns      int
	SessionsScanned int
	ClearedWakeKeys int
	RebuiltAt       time.Time
}

type RunSnapshot struct {
	Task taskpkg.Task
	Run  taskpkg.Run
}

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

type SessionSnapshot struct {
	ID           string
	AgentName    string
	WorkspaceID  string
	Channel      string
	Type         string
	State        string
	Prompting    bool
	Capabilities []string
	CreatedAt    time.Time
}

type SessionSource interface {
	Sessions(ctx context.Context) ([]SessionSnapshot, error)
}

type Stats struct {
	Cycles            int
	Rebuilds          int
	RecoveredLeases   int
	RecoveryErrors    int
	WakeAttempts      int
	WakeSucceeded     int
	WakeFailed        int
	NoMatchRuns       int
	RecentlyNotified  int
	UnclaimableRuns   int
	LastCycleAt       time.Time
	LastRebuildAt     time.Time
	LastRecoveryError string
	LastWakeError     string
}

type TaskSource interface {
	PendingRuns(ctx context.Context) ([]RunSnapshot, error)
	ActiveRuns(ctx context.Context) ([]taskpkg.Run, error)
	RecoverExpiredRunLeases(
		ctx context.Context,
		recovery taskpkg.ExpiredLeaseRecovery,
		actor taskpkg.ActorContext,
	) ([]taskpkg.ExpiredLeaseRecoveryResult, error)
}

type WakeTarget struct {
	Work    RunSnapshot
	Session SessionSnapshot
	Reason  string
}

type Waker interface {
	Wake(ctx context.Context, target *WakeTarget) error
}