Versions in this module Expand all Collapse all v0 v0.2.11 Oct 19, 2026 Changes in this version + const ActivityIdle + const ActivityUnknown + const ActivityWorking + const AnswerAgent + const AnswerScout + const BlockerExternalPrefix + const BlockerHuman + const DeclaredByScout + const DefaultCheckinIntervalSec + const DefaultGoalExecMaxSec + const DefaultGoalExecMinSec + const DefaultScoutModel + const DefaultStallSec + const GoalDropped + const GoalExecAdaptive + const GoalExecFixed + const GoalExecOff + const GoalMet + const GoalOpen + const HealthAvailable + const HealthDeadlock + const HealthOK + const HealthSilent + const HealthStalled + const HealthUnblocked + const HealthUnresponsive + const MaxMissedCheckins + const OpGoal + const OpGoalExec + const OpStatus + const OpWatch + const PolicyAlways + const PolicyOff + const PolicySmart + const ScoutMinConfidence + const ScoutSystemPrompt + const WorkBlocked + const WorkDone + const WorkIdle + const WorkProgress + func BuildScoutPrompt(f *Fleet, m *Member, reason string, screen []string, posts []string, ...) string + func DurationText(d time.Duration) string + func MemberLabel(f *Fleet, paneID string) string + func RenderGoals(f *Fleet, now int64) string + func RenderStatus(f *Fleet, now int64) string + func ScoutEligible(c Checkin, w Watch) bool + func ValidWork(w string) bool + type Checkin struct + BoardID string + Fleet string + Member Member + Missed int + Reason string type Fleet + Goal *Goal + GoalExec *GoalExec + GoalStatus *GoalStatus + Watch *Watch + type Goal struct + DoneWhen string + DueAt int64 + MetAt int64 + Note string + SetAt int64 + SetBy string + State string + Text string + func (g *Goal) IsMet() bool + func (g *Goal) IsOpen() bool + type GoalExec struct + MaxSec int + MinSec int + Mode string + func (g *GoalExec) Resolved() GoalExec + func (g GoalExec) Validate() error + type GoalStatus struct + AssessedAt int64 + Bottleneck string + FinishAt int64 + Members map[string]string + NextAt int64 + Pct int + Sent int + State string + Summary string + Unknown int + Waiting int + Why []string + type GoalUpdate struct + DoneWhen string + DueSec int + Member string + Note string + SetBy string + State string + Text string + type HealthChange struct + Cycle []string + Fleet string + From string + Member Member + To string type Member + Goal *Goal + Status *MemberStatus + func ResolveMember(f *Fleet, ref string) (*Member, error) + type MemberStatus struct + ActiveAt int64 + Activity string + BlockedBy []string + BlockerFor []string + CheckinAt int64 + CheckinCmd string + CheckinMissed int + DeclaredBy string + EtaAt int64 + EtaSetAt int64 + GoalAskAt int64 + GoalAskCmd string + Health string + HealthSince int64 + JoinedAt int64 + Note string + ObservedAt int64 + Pct *int + ScoutAt int64 + ScoutHealth string + Task string + UpdatedAt int64 + Work string + WorkSince int64 type Registry + func (r *Registry) CheckinSent(fleetName, paneID, cmdID string) + func (r *Registry) Declare(fleetName, paneID string, u StatusUpdate, now int64) (StatusResult, error) + func (r *Registry) DueCheckins(now int64) []Checkin + func (r *Registry) Evaluate(now int64) []HealthChange + func (r *Registry) GoalAskSent(fleetName, paneID, cmdID string, now int64) + func (r *Registry) Observe(paneID, activity string, now int64) + func (r *Registry) ScoutAnswered(fleetName, paneID, health string, now int64) + func (r *Registry) SetGoal(fleetName string, gu GoalUpdate, now int64) (*Fleet, error) + func (r *Registry) SetGoalExec(name string, g GoalExec) (*Fleet, error) + func (r *Registry) SetGoalStatus(name string, gs GoalStatus) + func (r *Registry) SetStatus(fleetName, paneID string, u StatusUpdate, now int64) (string, *Member, string, error) + func (r *Registry) SetWatch(name string, w Watch) (*Fleet, error) + type ScoutAnswer struct + Answerable bool + BlockedBy []string + Confidence float64 + Note string + Reason string + Task string + Work string + func ParseScoutAnswer(text string) (ScoutAnswer, error) + type StatusResult struct + AnsweredCheckin string + AnsweredGoalAsk string + Fleet string + Member *Member + type StatusUpdate struct + BlockedBy []string + By string + EtaSec int + KeepTask bool + Note string + Pct *int + Task string + Work string + func ScoutUpdate(a ScoutAnswer, model string) (StatusUpdate, error) type Update + Goal GoalUpdate + GoalExec GoalExec + Status StatusUpdate + Watch Watch type UpdateReply + AnsweredCheckin string + AnsweredGoalAsk string + Member *Member + type Watch struct + Answer string + IntervalSec int + Policy string + ScoutModel string + StallSec int + func (w *Watch) Resolved() Watch + func (w Watch) IntervalText() string + func (w Watch) Validate() error v0.2.9 Aug 16, 2026 v0.2.7 Aug 16, 2026 v0.2.6 Aug 15, 2026 Changes in this version + const MaxUp + const OpForget + const OpMemberRemove + const OpMemberUpsert + const OpRegister + const OpState + const RetentionMaxBytes + const RetentionTTL + const StateDown + const StateRegistered + const StateUp + var ErrNoRegistry = errors.New("fleet: the registry did not answer") + func BucketConfig(session string) *nats.KeyValueConfig + func BucketName(session string) string + func ServeQueries(nc *nats.Conn, r *Registry, reconciledAt func() int64) (*nats.Subscription, error) + func ServeUpdates(nc *nats.Conn, r *Registry, onChange func(op string, f *Fleet, name string)) (*nats.Subscription, error) + func ValidateName(name string) error + type Fleet struct + BoardID string + Created int64 + Members []Member + Name string + RoadmapDir string + Source string + State string + Tab string + func Normalise(f Fleet) Fleet + type KV interface + Delete func(key string, opts ...nats.DeleteOpt) error + Get func(key string) (nats.KeyValueEntry, error) + Keys func(opts ...nats.WatchOpt) ([]string, error) + Put func(key string, value []byte) (uint64, error) + type LivePanesFunc func() (map[string]bool, error) + type Member struct + Label string + PaneID string + Parent string + Role string + SessionID string + Unit string + Worktree string + type Persistence struct + func NewPersistence(kv KV) *Persistence + func (p *Persistence) Delete(name string) error + func (p *Persistence) Restore(r *Registry) (int, error) + func (p *Persistence) Save(f *Fleet) error + type Query struct + Name string + type Registry struct + func New() *Registry + func (r *Registry) FleetOfPane(paneID string) string + func (r *Registry) Forget(name string) bool + func (r *Registry) Get(name string) *Fleet + func (r *Registry) Len() int + func (r *Registry) List() []Fleet + func (r *Registry) Reconcile(livePaneIDs map[string]bool) int + func (r *Registry) Register(f Fleet) (*Fleet, error) + func (r *Registry) RemoveMember(name, paneID string) bool + func (r *Registry) SetState(name, state string) error + func (r *Registry) UpsertMember(name string, m Member) error + type Reply struct + Err string + Fleets []Fleet + ReconciledAt int64 + func Ask(nc *nats.Conn, q Query, timeout time.Duration) (*Reply, error) + type Update struct + Fleet Fleet + Member Member + Name string + Op string + PaneID string + State string + type UpdateReply struct + Err string + Fleet *Fleet + OK bool + func Send(nc *nats.Conn, u Update, timeout time.Duration) (*UpdateReply, error)