Documentation
¶
Overview ¶
Package workers coordinates local worker registrations and heartbeats.
Index ¶
- Constants
- func ClassifyStartupNoEvidence(evidence StartupEvidence) string
- func StartupRecoveryActions(classification string, evidence StartupEvidence) []string
- type Event
- type ReadySnapshot
- type StartupEvidence
- type StartupHealth
- type StartupNoEvidenceReport
- type Store
- func (s Store) AwaitReady(id string) (ReadySnapshot, error)
- func (s Store) Complete(id string, finishReason string, tokensOutput int64) (Worker, error)
- func (s Store) Create(cwd string, trustedRoots []string, autoRecover bool) (Worker, error)
- func (s Store) Get(id string) (Worker, error)
- func (s Store) List() ([]Worker, error)
- func (s Store) Observe(id string, screenText string) (Worker, error)
- func (s Store) ObserveStartupTimeout(id string, evidence StartupEvidence) (Worker, error)
- func (s Store) ResolveTrust(id string) (Worker, error)
- func (s Store) Restart(id string, taskID string) (Worker, error)
- func (s Store) Save(worker Worker) error
- func (s Store) SendPrompt(id string, prompt string, receipt *TaskReceipt, taskID string) (Worker, error)
- func (s Store) Terminate(id string) (Worker, error)
- type TaskReceipt
- type TerminalOutcome
- type Worker
Constants ¶
View Source
const ( StartupTrustRequired = "trust_required" StartupPromptMisdelivery = "prompt_misdelivery" StartupPromptAcceptanceTimeout = "prompt_acceptance_timeout" StartupTransportDead = "transport_dead" StartupWorkerCrashed = "worker_crashed" StartupUnknown = "unknown" )
Variables ¶
This section is empty.
Functions ¶
func ClassifyStartupNoEvidence ¶
func ClassifyStartupNoEvidence(evidence StartupEvidence) string
func StartupRecoveryActions ¶
func StartupRecoveryActions(classification string, evidence StartupEvidence) []string
Types ¶
type Event ¶
type Event = laneevents.Event
type ReadySnapshot ¶
type StartupEvidence ¶
type StartupEvidence struct {
LastLifecycleState string `json:"last_lifecycle_state"`
LastLifecycleAt time.Time `json:"last_lifecycle_at"`
PaneCommand string `json:"pane_command,omitempty"`
PaneObservedAt time.Time `json:"pane_observed_at"`
CommandStartedAt time.Time `json:"command_started_at"`
PromptSentAt *time.Time `json:"prompt_sent_at,omitempty"`
PromptAcceptanceState string `json:"prompt_acceptance_state"`
TrustPromptDetected bool `json:"trust_prompt_detected"`
TransportHealthy *bool `json:"transport_healthy,omitempty"`
TransportHealth string `json:"transport_health"`
Transport StartupHealth `json:"transport"`
MCPHealthy *bool `json:"mcp_healthy,omitempty"`
MCPHealth string `json:"mcp_health"`
MCP StartupHealth `json:"mcp"`
ElapsedSeconds int64 `json:"elapsed_seconds"`
}
type StartupHealth ¶
type StartupNoEvidenceReport ¶
type Store ¶
type Store struct {
ConfigHome string
}
func (Store) AwaitReady ¶
func (s Store) AwaitReady(id string) (ReadySnapshot, error)
func (Store) ObserveStartupTimeout ¶
func (s Store) ObserveStartupTimeout(id string, evidence StartupEvidence) (Worker, error)
func (Store) SendPrompt ¶
type TaskReceipt ¶
type TerminalOutcome ¶
type TerminalOutcome struct {
Fingerprint string `json:"fingerprint"`
LaneEvent string `json:"lane_event"`
Type string `json:"type"`
Status string `json:"status"`
FinishReason string `json:"finish_reason,omitempty"`
Sequence int64 `json:"sequence"`
DuplicateCount int `json:"duplicate_count"`
MaterialDifferenceCount int `json:"material_difference_count"`
UpdatedAt time.Time `json:"updated_at"`
}
type Worker ¶
type Worker struct {
ID string `json:"worker_id"`
CWD string `json:"cwd"`
TrustedRoots []string `json:"trusted_roots,omitempty"`
AutoRecoverPromptMisdelivery bool `json:"auto_recover_prompt_misdelivery"`
Status string `json:"status"`
ReadyForPrompt bool `json:"ready_for_prompt"`
TrustResolved bool `json:"trust_resolved"`
TaskID string `json:"task_id,omitempty"`
TaskStatus string `json:"task_status,omitempty"`
TaskReceipt *TaskReceipt `json:"task_receipt,omitempty"`
LastError string `json:"last_error,omitempty"`
StartupNoEvidence *StartupNoEvidenceReport `json:"startup_no_evidence,omitempty"`
Events []Event `json:"events,omitempty"`
Terminal *TerminalOutcome `json:"terminal,omitempty"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
Click to show internal directories.
Click to hide internal directories.