hostpoller

package

Go to main page

Versions in this module

v0

v0.28.0

Oct 22, 2026

v0.27.0

Oct 22, 2026

Changes in this version

+ func CanonicalFamily(s string) string

+ func SameFamily(a, b string) bool

v0.26.1

Oct 21, 2026

v0.26.0

Oct 20, 2026

v0.25.0

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

v0.24.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL