scheduler

type Dialect string

type RunFunc func(ctx context.Context, agentID, input, sessionID string) error

type RunRecord struct {
	ID         string    `json:"id"`
	ScheduleID string    `json:"schedule_id"`
	AgentID    string    `json:"agent_id"`
	SessionID  string    `json:"session_id"`
	Input      string    `json:"input"`
	Status     string    `json:"status"` // success, error
	Error      string    `json:"error,omitempty"`
	StartedAt  time.Time `json:"started_at"`
	FinishedAt time.Time `json:"finished_at"`
}

type Runner interface {
	Add(agentID, cronExpr, input string, newSession bool) (*Schedule, error)
	Remove(id string) error
	List() []*Schedule
	Get(id string) (*Schedule, error)
	History(scheduleID string) []RunRecord
	Start(ctx context.Context)
	Stop()
}

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

type Schedule struct {
	ID         string    `json:"id"`
	AgentID    string    `json:"agent_id"`
	CronExpr   string    `json:"cron_expr"`
	Input      string    `json:"input"`
	NewSession bool      `json:"new_session"` // true = new session per run, false = reuse
	SessionID  string    `json:"session_id,omitempty"`
	Enabled    bool      `json:"enabled"`
	CreatedAt  time.Time `json:"created_at"`
	LastRunAt  time.Time `json:"last_run_at,omitempty"`
	NextRunAt  time.Time `json:"next_run_at,omitempty"`
	RunCount   int64     `json:"run_count"`
}

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

type Store interface {
	// Migrate creates the scheduler schema (idempotent).
	Migrate(ctx context.Context) error
	// Add persists a new schedule.
	Add(ctx context.Context, sched *Schedule) error
	// Remove deletes a schedule by ID.
	Remove(ctx context.Context, id string) error
	// Get returns a schedule by ID.
	Get(ctx context.Context, id string) (*Schedule, error)
	// List returns all schedules.
	List(ctx context.Context) ([]*Schedule, error)
	// ClaimDue atomically advances the NextRunAt of every schedule that is due at
	// now and returns only those this caller claimed. Across replicas sharing the
	// store, a given due firing is claimed by exactly one caller. nextFn computes
	// the next fire time for a cron expression strictly after the given instant.
	ClaimDue(ctx context.Context, now time.Time, nextFn func(expr string, after time.Time) time.Time) ([]*Schedule, error)
	// SetSession persists the reused session ID for a schedule.
	SetSession(ctx context.Context, id, sessionID string) error
	// AddRunRecord appends a run record to a schedule's history.
	AddRunRecord(ctx context.Context, rec RunRecord) error
	// History returns run records for a schedule.
	History(ctx context.Context, scheduleID string) ([]RunRecord, error)
	// Close releases resources owned by the store.
	Close() error
}

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