Versions in this module Expand all Collapse all v0 v0.1.0 Jul 14, 2026 Changes in this version + func IsActiveStatus(status string) bool + func IsTerminalStatus(status string) bool + type EventProvenance struct + Channel string + Confidence string + Emitter string + Environment string + SourceKind string + func NormalizeEventProvenance(provenance EventProvenance) EventProvenance + type LaneBoard struct + Active []LaneBoardEntry + Blocked []LaneBoardEntry + Finished []LaneBoardEntry + GeneratedAt time.Time + type LaneBoardEntry struct + Command string + Freshness LaneFreshness + Heartbeat *LaneHeartbeat + Kind string + Lifecycle LifecycleResolution + Prompt string + Provenance EventProvenance + ScopeBinding ScopeBinding + SessionID string + Status string + TaskID string + TerminalOutcome *TerminalOutcome + type LaneFreshness string + const LaneFreshnessHealthy + const LaneFreshnessStalled + const LaneFreshnessTransportDead + const LaneFreshnessUnknown + type LaneHeartbeat struct + ObservedAt time.Time + Provenance EventProvenance + Status string + TransportAlive bool + type LifecycleResolution struct + Reason string + Status string + Terminal bool + TerminalStateUnknown bool + func ResolveLifecycle(status string, freshness LaneFreshness) LifecycleResolution + type PruneOptions struct + Keep int + OlderThan time.Duration + func DefaultPruneOptions() PruneOptions + type PruneResult struct + Kept int + Removed []string + RemovedCount int + type RestartPolicy struct + DelaySeconds int + Enabled bool + MaxAttempts int + Mode string + type RunOptions struct + AgentType string + Description string + Env []string + Kind string + Prompt string + RestartCount int + RestartPolicy *RestartPolicy + RestartedFrom string + ScopeBinding ScopeBinding + SessionID string + TaskPacket json.RawMessage + type ScopeBinding struct + Actionable bool + Owner string + WatcherAction string + WorkflowScope string + func NormalizeScopeBinding(binding ScopeBinding) ScopeBinding + type Store struct + Dir string + func NewStore(configHome string) Store + func (s Store) Get(id string) (Task, error) + func (s Store) LaneBoard(stalledAfter time.Duration) (LaneBoard, error) + func (s Store) LaneBoardAt(now time.Time, stalledAfter time.Duration) (LaneBoard, error) + func (s Store) List() ([]Task, error) + func (s Store) LogFrom(id string, offset int64) (int64, string, error) + func (s Store) LogRange(id string, offset int64, limitBytes int64) (int64, string, error) + func (s Store) Logs(id string, limitBytes int64) (string, error) + func (s Store) Prune(options PruneOptions) (PruneResult, error) + func (s Store) RecordTerminalEvent(id string, event TerminalEvent) (Task, error) + func (s Store) Restart(id string, cwd string) (Task, error) + func (s Store) Run(command string, cwd string) (Task, error) + func (s Store) RunWithOptions(command string, cwd string, options RunOptions) (Task, error) + func (s Store) Status(id string) (Task, error) + func (s Store) Stop(id string) (Task, error) + func (s Store) SuperviseOnce(now time.Time) (SuperviseResult, error) + func (s Store) Update(id string, message string) (Task, error) + func (s Store) UpdateHeartbeat(id string, heartbeat LaneHeartbeat) (Task, error) + func (s Store) Watch(ctx context.Context, id string, options WatchOptions, ...) error + type SuperviseResult struct + Restarted []Task + Skipped []SuperviseSkip + type SuperviseSkip struct + ID string + Reason string + type Task struct + AgentType string + Command string + CompletedAt *time.Time + Description string + Error string + ExitCode *int + Heartbeat *LaneHeartbeat + ID string + Kind string + LogPath string + Messages []TaskMessage + PID int + Prompt string + RestartCount int + RestartPolicy *RestartPolicy + RestartedBy string + RestartedFrom string + ScopeBinding ScopeBinding + SessionID string + StartedAt time.Time + Status string + TaskPacket json.RawMessage + TerminalEvents []TerminalEvent + TerminalOutcome *TerminalOutcome + Workspace string + func FilterByKind(tasks []Task, kind string) []Task + func FilterBySession(tasks []Task, sessionID string) []Task + type TaskMessage struct + CreatedAt time.Time + Message string + type TerminalEvent struct + Actionable bool + Duplicate bool + DuplicateOf string + Error string + ExitCode *int + Fingerprint string + MateriallyDifferent bool + ObservedAt time.Time + Provenance EventProvenance + Sequence int + Status string + type TerminalOutcome struct + Actionable bool + ConflictCount int + DuplicateCount int + Error string + EventCount int + ExitCode *int + Fingerprint string + MateriallyDifferent bool + ObservedAt time.Time + Status string + type WatchEvent struct + Data string + Error string + ID string + Offset int64 + Provenance EventProvenance + ScopeBinding ScopeBinding + Status string + Task *Task + Type string + type WatchOptions struct + Interval time.Duration + MaxEvents int + Offset int64
Go to main page