hostpoller

Nov 3, 2026

Changes in this version

+ const CapabilityResetContext

+ const OpWorkerResetContext

+ var ErrClock = errors.New(...)

+ var ErrHandleClosed = errors.New("the process handle is closed; nothing was sent")

+ var ErrLeaseExpired = errors.New("the stop lease expired before the signal; nothing was sent")

+ var ErrUnsupportedPlatform = errors.New(...)

+ var ResetStepCodes = []string

+ func ResetStepCode(err error) string

type AgentRecord

+ Start string

+ type ContextReset struct

+ CheckpointNode string

+ Epoch int

+ ID string

+ Phase string

+ Reason string

+ SessionID string

+ StopGranted bool

+ StopLeaseMs int

+ TaskID string

+ WorkerID string

+ type GitTreeState struct

+ Ahead int

+ Dirty bool

+ InGit bool

+ Upstream string

+ func GitTree(ctx context.Context, dir string) (GitTreeState, error)

+ type LinuxProcessControl struct

+ func (LinuxProcessControl) Now() (time.Duration, error)

+ func (LinuxProcessControl) Observe(int) (ProcessHandle, error)

+ func (LinuxProcessControl) Observe(pid int) (ProcessHandle, error)

type Poller

+ func (p *Poller) EnableResets(rs ResetServer, deps ResetDeps)

+ type ProcessControl interface

+ Now func() (time.Duration, error)

+ Observe func(pid int) (ProcessHandle, error)

+ type ProcessHandle interface

+ Close func()

+ Identity func() ProcessIdentity

+ SignalWithin func(sig syscall.Signal, t0, lease time.Duration, now func() (time.Duration, error)) (late time.Duration, err error)

+ type ProcessIdentity struct

+ PID int

+ StartTime string

+ type ResetCheckpoint struct

+ Content string

+ Title string

+ type ResetDeps struct

+ Git func(ctx context.Context, dir string) (GitTreeState, error)

+ Idle func(ctx context.Context, workerRef string) error

+ Proc ProcessControl

+ type ResetRecord struct

+ Checkpoint string

+ Epoch int

+ LateStopMs int64

+ New *ProcessIdentity

+ Old ProcessIdentity

+ OperationID string

+ Relaunching bool

+ ResetID string

+ WorkerID string

+ type ResetServer interface

+ AuthorizeResetStop func(ctx context.Context, resetID string, epoch int, p ProcessIdentity) (ResetStep, error)

+ ClaimReset func(ctx context.Context, resetID string, epoch int, p ProcessIdentity) (ResetStep, error)

+ ReadReset func(ctx context.Context, resetID string) (ContextReset, error)

+ RegisterResetRecovery func(ctx context.Context, resetID string, epoch int, cp ResetCheckpoint, ...) (ResetStep, error)

+ ReportResetAgentStopped func(ctx context.Context, resetID string, epoch int, late time.Duration) (ResetStep, error)

+ ReportResetRelaunchFailed func(ctx context.Context, resetID string, epoch int, reason string) (ResetStep, error)

+ ReportResetRelaunched func(ctx context.Context, resetID string, epoch int, p ProcessIdentity) (ResetStep, error)

+ type ResetStep struct

+ Refused string

+ Replayed bool

+ Reset ContextReset

+ type ResetStepError struct

+ Code string

+ Err error

+ func (e *ResetStepError) Error() string

+ func (e *ResetStepError) Unwrap() error

type State

+ Resets map[string]ResetRecord

type WorkerConfig

+ Recover []string

Nov 1, 2026

Changes in this version

type Config

+ Capabilities []string

type Registration

+ Capabilities []string

Oct 31, 2026

Changes in this version

+ func ScrubbedEnv(parent []string, hostKey string) []string

Oct 30, 2026

Changes in this version

type DeliveryConfig

+ AckMixed bool

Oct 22, 2026

Changes in this version

+ func CanonicalFamily(s string) string

+ func SameFamily(a, b string) bool

Oct 19, 2026

Changes in this version

+ var ErrDeliveryScope = errors.New("the host key lacks attention:deliver: delivery is off for this run")

+ type BatchSource interface

+ Batches func(ctx context.Context) ([]delivery.Batch, error)

type Config

+ Delivery DeliveryConfig

+ func (c *Config) CheckWorktreeAliases(s *State) error

+ func (c *Config) DeliveryStateDir() string

+ func (c *Config) Recipient(s *State, ref, workerID string) delivery.Recipient

+ func (c *Config) RefFor(id, urn, name string) string

+ type Deliverer interface

+ Deliver func(ctx context.Context, b delivery.Batch, r delivery.Recipient) delivery.Outcome

+ type DeliveryConfig struct

+ Enabled bool

+ OrcaBin string

type Poller

+ DeliveryStep func(at time.Time, read string)

+ WakeStep func(delivery.WakeRead)

+ func (p *Poller) DeliveryEnabled() bool

+ func (p *Poller) EnableDelivery(src BatchSource, d Deliverer)

+ func (p *Poller) EnableWakes(src WakeSource, d WakeDeliverer)

+ type WakeDeliverer interface

+ DeliverWake func(ctx context.Context, w delivery.Wake, r delivery.Recipient) delivery.Outcome

+ type WakePage struct

+ BudgetExhausted bool

+ Dormant int

+ Wakes []delivery.Wake

+ Withheld int

+ type WakeSource interface

+ Wakes func(ctx context.Context) (WakePage, error)

type WorkerConfig

+ TUI string

Oct 15, 2026

Changes in this version

+ const Failed

+ const HostKeyEnv

+ const LaunchGrantTTL

+ const OpWorkerDeliver

+ const OpWorkerEnd

+ const OpWorkerStart

+ const OpWorktreeCreate

+ const OpWorktreeRemove

+ const Succeeded

+ var ErrFinal = errors.New("the operation is already finished")

+ var ErrNotDone = errors.New("no session bound with this start's grant yet")

+ func ValidNameToken(s string) bool

+ type Agent interface

+ Done func() <-chan struct{}

+ ExitDetail func() string

+ PID func() int

+ type AgentRecord struct

+ PID int

+ Worktree string

+ type Config struct

+ App string

+ KeyFile string

+ Label string

+ PollIntervalSeconds int

+ Repos map[string]string

+ Server string

+ StateFile string

+ Workers map[string]WorkerConfig

+ WorktreesRoot string

+ func LoadConfig(path string) (*Config, error)

+ func (c *Config) ReadHostKey() (string, error)

+ func (c *Config) WorkerRefs() []string

+ func (c *Config) WorktreePath(token string) string

+ type Event struct

+ Detail string

+ Kind string

+ Operation string

+ Outcome string

+ Time time.Time

+ Type string

+ type ExecHost struct

+ PromptTimeout time.Duration

+ func (ExecHost) Alive(pid int) bool

+ func (ExecHost) CreateWorktree(ctx context.Context, repoPath, path, branch, base string) error

+ func (ExecHost) Inspect(ctx context.Context, path string) (WorktreeState, error)

+ func (ExecHost) Launch(_ context.Context, spec LaunchSpec) (Agent, error)

+ func (ExecHost) Occupied(_ context.Context, path string) (string, error)

+ func (ExecHost) RemoveWorktree(ctx context.Context, path string) error

+ func (h ExecHost) Prompt(ctx context.Context, argv []string, dir string, env []string) error

+ type Host interface

+ Alive func(pid int) bool

+ CreateWorktree func(ctx context.Context, repoPath, path, branch, base string) error

+ Inspect func(ctx context.Context, path string) (WorktreeState, error)

+ Launch func(ctx context.Context, spec LaunchSpec) (Agent, error)

+ Occupied func(ctx context.Context, path string) (string, error)

+ Prompt func(ctx context.Context, argv []string, dir string, env []string) error

+ RemoveWorktree func(ctx context.Context, path string) error

+ type LaunchSpec struct

+ Argv []string

+ Dir string

+ Env []string

+ type Operation struct

+ Args map[string]any

+ FailureReason string

+ ID string

+ LaunchGrant string

+ Result map[string]any

+ Status string

+ Type string

+ WorkerID string

+ type Poller struct

+ BindPoll time.Duration

+ Fatal func(error) bool

+ func New(cfg *Config, server Server, host Host, state *State, key string, ...) *Poller

+ func (p *Poller) ReportFailures() int

+ func (p *Poller) Run(ctx context.Context) error

+ func (p *Poller) Step(ctx context.Context) error

+ func (p *Poller) Wait()

+ type RegisteredHost struct

+ HostID string

+ Workers []RegisteredHostWorker

+ type RegisteredHostWorker struct

+ Name string

+ URN string

+ WorkerID string

+ type RegisteredWorker struct

+ Family string

+ Worker string

+ Worktrees []string

+ type Registration struct

+ Label string

+ PollIntervalSeconds int

+ Workers []RegisteredWorker

+ type Server interface

+ Collect func(ctx context.Context) ([]Operation, error)

+ Register func(ctx context.Context, r Registration) (RegisteredHost, error)

+ Report func(ctx context.Context, id, outcome, worktree, reason string) (Operation, error)

+ type State struct

+ Agents map[string]AgentRecord

+ Created map[string][]string

+ HostID string

+ Keep map[string]string

+ func LoadState(path string) (*State, error)

+ func (s *State) RegisteredHostID() string

+ func (s *State) Snapshot() (map[string][]string, map[string]string)

+ type WorkerConfig struct

+ End []string

+ EndWait string

+ Family string

+ Launch []string

+ Worktrees []string

+ type WorktreeState struct

+ Ahead int

+ Branch string

+ Dirty bool

+ Exists bool

+ IsWorktree bool

+ Upstream string