daemon

Jul 16, 2026

Changes in this version

+ const DriverHeadless

+ const DriverPTY

+ const StopReasonConvert

+ const StopReasonDelete

+ const StopReasonWatchdog

+ const TodoStatusBlocked

+ const TodoStatusDone

+ const TodoStatusInProgress

+ const TodoStatusTodo

+ var ErrTodoNotFound = errors.New("todo not found")

+ func ListStateBackups(statePath string) []string

+ func StateBackupPath(statePath string, version int) string

type CIStatus

+ Passed int

+ Total int

+ type CreateOpts struct

+ AgentHooks bool

+ AgentName string

+ AllowConcurrent bool

+ AutoCleanup string

+ BaseBranch string

+ Codex config.CodexOptions

+ Cols uint16

+ EnvExtra []map[string]string

+ Headless bool

+ ID string

+ IdleTimeoutSecs int

+ InPlace bool

+ Includes []string

+ Mirror string

+ Model string

+ Name string

+ NoFetch bool

+ NoRepo bool

+ ParentID string

+ Prompt string

+ RepoPath string

+ Rows uint16

+ SkipModelValidation bool

+ Starred bool

+ TrackerIssue string

+ TriggerID string

+ TriggerReactor bool

+ Yolo bool

+ type JailedComment struct

+ Association string

+ Author string

+ Body string

+ Branch string

+ CommentID int64

+ ID string

+ IsBot bool

+ JailedAt string

+ Line int

+ PRNumber int

+ Path string

+ ReleasedAt string

+ RepoSlug string

+ Surface string

+ TargetName string

+ TargetSession string

+ func (j JailedComment) Released() bool

type MCPManager

+ func (m *MCPManager) List() []protocol.MCPServerStatus

+ func (m *MCPManager) LogFiles(name string, lines int) ([]protocol.MCPLogFile, error)

+ func (m *MCPManager) Restart(name string) (int, error)

type MsgStore

+ func (s *MsgStore) GetJailed(id string) (JailedComment, bool, error)

+ func (s *MsgStore) Jail(j JailedComment) (id string, created bool, err error)

+ func (s *MsgStore) ListJailed(includeReleased bool) ([]JailedComment, error)

+ func (s *MsgStore) MarkReleased(id string) (JailedComment, bool, error)

+ func (s *MsgStore) Unrelease(id string) (bool, error)

+ func (s *MsgStore) UnreleasedJailed() ([]JailedComment, error)

+ type PublishOpts struct

+ Body string

+ ReplyTo string

+ SenderID string

+ SenderName string

+ Stream string

+ ThreadID string

+ type ResourceSample struct

+ At time.Time

+ CPUPercent float64

+ FDsPartial bool

+ OpenFDs int

+ ProcessCount int

+ ProcessIDs []int

+ RSSMB int64

+ TopProcess string

type ScenarioState

+ Triggers []config.TriggerConfig

+ type SessionDriver interface

+ Attach func(w io.Writer)

+ BytesRead func() int64

+ Close func()

+ CreatedAt func() time.Time

+ Detach func()

+ DetachWriter func(w io.Writer)

+ Done func() <-chan struct{}

+ ExitCode func() int

+ ExitSignal func() syscall.Signal

+ Exited func() bool

+ Fd func() uintptr

+ ForceKill func() error

+ Interrupt func(count int, delay time.Duration) error

+ Kill func() error

+ LastOutputAt func() time.Time

+ NotifyUserInput func()

+ PeakRSSBytes func() int64

+ Pgid func() int

+ Poke func()

+ ProcessPID func() int

+ RecentlyAdopted func(grace time.Duration) bool

+ Resize func(rows, cols uint16) error

+ ScreenPreview func() string

+ ScreenSnapshot func() grpty.ScreenCapture

+ ScrollbackFile func() *grpty.Scrollback

+ WaitForUserIdle func(idleTimeout, maxWait time.Duration) bool

+ WasAdopted func() bool

+ WriteInput func(data []byte) error

+ WriteInputAndSubmit func(data []byte) error

type SessionManager

+ func (sm *SessionManager) ConvertToInteractive(id string, rows, cols uint16) (SessionState, error)

+ func (sm *SessionManager) EnsureHumanToken() error

+ func (sm *SessionManager) ForkWithAgent(name, sourceSessionID, targetAgent, targetModel string, rows, cols uint16) (SessionState, error)

+ func (sm *SessionManager) ReleaseJailed(id string) (JailedComment, error)

+ func (sm *SessionManager) ReleaseJailedByAuthor(login string) ([]JailedComment, error)

+ func (sm *SessionManager) RunFileWatchLoop(ctx context.Context)

+ func (sm *SessionManager) RunPRRefWatchLoop(ctx context.Context)

+ func (sm *SessionManager) RunResourceMonitorLoop(ctx context.Context)

+ func (sm *SessionManager) RunStartupWatchdogLoop(ctx context.Context)

+ func (sm *SessionManager) RunTodoSweepLoop(ctx context.Context)

+ func (sm *SessionManager) RunTokenLoop(ctx context.Context)

+ func (sm *SessionManager) RunTriggerLoop(ctx context.Context)

+ func (sm *SessionManager) SendPushNotification(n pushNotification) (bool, string)

+ func (sm *SessionManager) SubmitHeadlessApproval(ctx context.Context, req protocol.ApprovalRequestMsg) protocol.ApprovalDecisionMsg

+ func (sm *SessionManager) TodoAddOp(ac authContext, m protocol.TodoAddMsg) (protocol.TodoItemInfo, error)

+ func (sm *SessionManager) TodoAssignOp(ac authContext, m protocol.TodoAssignMsg) (protocol.TodoItemInfo, error)

+ func (sm *SessionManager) TodoClaimOp(ac authContext, m protocol.TodoClaimMsg) (protocol.TodoClaimResponse, error)

+ func (sm *SessionManager) TodoExportOp(ac authContext, m protocol.TodoExportMsg) (string, error)

+ func (sm *SessionManager) TodoListOp(ac authContext, m protocol.TodoListMsg) ([]protocol.TodoItemInfo, error)

+ func (sm *SessionManager) TodoRemoveOp(ac authContext, m protocol.TodoRemoveMsg) error

+ func (sm *SessionManager) TodoTransitionOp(ac authContext, m protocol.TodoTransitionMsg) (protocol.TodoItemInfo, error)

+ func (sm *SessionManager) TodoUpdateOp(ac authContext, m protocol.TodoUpdateMsg) (protocol.TodoItemInfo, error)

+ func (sm *SessionManager) TriggerList() []protocol.TriggerRecord

+ func (sm *SessionManager) TriggerPause(name string, pause bool) error

+ func (sm *SessionManager) TriggerRunNow(ctx context.Context, name string) error

+ func (sm *SessionManager) TriggerStatus(name string) (protocol.TriggerRecord, error)

type SessionState

+ AutoCleanup string

+ Codex *config.CodexOptions

+ ContextPressure bool

+ ContextPressureAt time.Time

+ DriverKind string

+ IdleTimeoutSecs int

+ LastMessage string

+ LegacyMirror bool

+ LegacyMirrorSourceID string

+ Mirror bool

+ MirrorSourceID string

+ SessionEndReason string

+ SessionEndReasonGen int64

+ StuckRestarts int

+ SubAgents map[string]string

+ Tokens *TokenStats

+ TrackerIssue string

+ TriggerID string

+ TriggerReactor bool

type State

+ PRWatchPromptedAuthors map[string]bool

+ TriggerRuntime map[string]*TriggerRuntimeState

+ type TodoAdd struct

+ Assignee string

+ CreatedBy string

+ Note string

+ ParentID string

+ Scope string

+ Tags []string

+ Title string

+ type TodoFilter struct

+ Owner string

+ Status string

+ Tag string

+ type TodoItem struct

+ Assignee string

+ CreatedAt string

+ CreatedBy string

+ ID string

+ Note string

+ Owner string

+ ParentID string

+ Position int64

+ Revision int64

+ Scope string

+ Status string

+ Tags []string

+ Title string

+ UpdatedAt string

+ type TodoStore struct

+ func NewTodoStore(dbPath string) (*TodoStore, error)

+ func (s *TodoStore) Add(in TodoAdd) (TodoItem, error)

+ func (s *TodoStore) Assign(id, assignee string) (TodoItem, error)

+ func (s *TodoStore) AssigneeProgress(scope string) (map[string][2]int, error)

+ func (s *TodoStore) Claim(id, owner string) (TodoItem, bool, error)

+ func (s *TodoStore) ClaimNext(scope, owner string) (TodoItem, bool, error)

+ func (s *TodoStore) Close() error

+ func (s *TodoStore) Counts(scope string) (done, total int, err error)

+ func (s *TodoStore) Get(id string) (TodoItem, error)

+ func (s *TodoStore) List(scope string, f TodoFilter) ([]TodoItem, error)

+ func (s *TodoStore) ListAll(f TodoFilter) ([]TodoItem, error)

+ func (s *TodoStore) Remove(id string) error

+ func (s *TodoStore) ReopenOwnedBy(ownerID string) (int, error)

+ func (s *TodoStore) ReopenStale(lease time.Duration) (int, error)

+ func (s *TodoStore) SweepDone(maxAge time.Duration) (int, error)

+ func (s *TodoStore) Transition(id, newStatus, actor string, override bool) (TodoItem, error)

+ func (s *TodoStore) UpdateFields(id string, title, note *string, tags *[]string, position *int64) (TodoItem, error)

+ type TokenStats struct

+ CacheCreation int64

+ CacheRead int64

+ CountedAt time.Time

+ Degraded bool

+ Input int64

+ Output int64

+ Total int64

+ Unclassified int64

+ type TriggerRun struct

+ Cause string

+ Result string

+ ScheduledAt time.Time

+ SourceSessionID string

+ type TriggerRuntimeState struct

+ ActivatedAt *time.Time

+ Fingerprint string

+ History []TriggerRun

+ LastError string

+ LastScheduledFireAt *time.Time

+ Name string

+ NextScheduledFireAt *time.Time

+ Paused bool

+ RunCount int

Jul 10, 2026

Changes in this version

+ const GCOrphanScratch

+ const GCOrphanWorktree

+ type GCOrphan struct

+ HasDirtyFiles bool

+ ID string

+ IsGitWorktree bool

+ Path string

+ Reason string

+ Removed bool

+ Skipped bool

+ Type string

type SessionManager

+ func (sm *SessionManager) FindOrphans(now time.Time) []GCOrphan

+ func (sm *SessionManager) Restore(id string) (SessionState, error)

+ func (sm *SessionManager) RestoreWithChildren(rootID string) ([]SessionState, error)

+ func (sm *SessionManager) RunGC(force bool, now time.Time) []GCOrphan

+ func (sm *SessionManager) RunPurgeLoop(ctx context.Context)

+ func (sm *SessionManager) SoftDelete(id string) (SessionState, error)

+ func (sm *SessionManager) SoftDeleteWithChildren(rootID string, excludeRoot bool) ([]string, error)

type SessionState

+ DeletedAt *time.Time

+ ExpiresAt *time.Time

+ func (s *SessionState) IsSoftDeleted() bool

+ type StateVersionError struct

+ BinaryVersion int

+ FileVersion int

+ func (e *StateVersionError) Error() string

Jul 9, 2026

Changes in this version

type Message

+ System bool

Jul 8, 2026

Changes in this version

+ type ConnOrigin struct

+ Identity *TailnetIdentity

+ Remote bool

+ type PairedDevice struct

+ CreatedAt time.Time

+ ID string

+ Label string

+ LastSeenAt time.Time

+ PubKey string

+ ReadOnly bool

+ TailnetNode string

+ TailnetUser string

+ TokenHash string

+ type RemoteListener interface

+ Close func() error

+ Listen func() (net.Listener, error)

+ WhoIs func(ctx context.Context, remoteAddr string) (*TailnetIdentity, error)

type SessionManager

+ func (sm *SessionManager) AddApprovalSubscriber(conn net.Conn, sendControl func(string, any))

+ func (sm *SessionManager) AddPendingPairing(label, pubKey string, id TailnetIdentity, now time.Time) (string, chan pairApproval, error)

+ func (sm *SessionManager) ApprovePairing(requestID string, readOnly bool, now time.Time) (deviceID, clientToken string, err error)

+ func (sm *SessionManager) DeviceForToken(token string) *PairedDevice

+ func (sm *SessionManager) ListPairings() ([]pendingPairing, []PairedDevice)

+ func (sm *SessionManager) RegisterDeviceConn(deviceID string, conn net.Conn)

+ func (sm *SessionManager) RemoveApprovalSubscriber(conn net.Conn)

+ func (sm *SessionManager) RevokeDevice(deviceID string) (int, error)

+ func (sm *SessionManager) UnregisterDeviceConn(deviceID string, conn net.Conn)

type State

+ PairedDevices map[string]*PairedDevice

+ PairingHMACKey string

+ func (s *State) EnsurePairingHMACKey() (string, error)

+ type TailnetIdentity struct

+ Node string

+ Tags []string

+ User string

Jul 7, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) InterruptSession(sessionID string) error

type SessionState

+ Yolo bool

Jun 26, 2026

Changes in this version

type PRStatus

+ Mergeable string

Jun 25, 2026

Changes in this version

+ type CIStatus struct

+ FailingChecks []string

+ State string

type MsgStore

+ func (s *MsgStore) Conversation(self string, limit int) ([]Message, error)

+ type PRStatus struct

+ HeadRefOid string

+ Number int

+ ReviewDecision string

+ State string

+ URL string

type SessionManager

+ func (sm *SessionManager) RunPRWatchLoop(ctx context.Context)

type SessionState

+ CI CIStatus

+ PullRequest PRStatus

Jun 25, 2026

Changes in this version

+ type MigrationInfo struct

+ Agent string

+ AgentSessionID string

+ At time.Time

+ Model string

+ RenderedPath string

type SessionManager

+ func (sm *SessionManager) Migrate(id, targetAgent, targetModel string, rows, cols uint16) (SessionState, error)

type SessionState

+ MigratedFrom *MigrationInfo

Jun 18, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) RestartWithChildren(rootID string, excludeRoot bool, rows, cols uint16) ([]string, error)

Jun 17, 2026

Changes in this version

+ func ValidateScenarioName(name string) error

+ type ScenarioSession struct

+ Agent string

+ Model string

+ Name string

+ Repo string

+ Role string

+ Shared bool

+ Task string

+ TaskDone bool

+ type ScenarioState struct

+ CreatedAt time.Time

+ Goal string

+ ID string

+ Name string

+ OrchestratorID string

+ SessionIDs []string

+ Sessions []ScenarioSession

+ SourceFileHash string

type SessionManager

+ func (sm *SessionManager) AddToScenario(name string, input protocol.ScenarioSessionInput, rows, cols uint16) (*SessionState, error)

+ func (sm *SessionManager) DeleteScenario(name string) ([]string, error)

+ func (sm *SessionManager) HasAttachedClient(sessionID string) bool

+ func (sm *SessionManager) ListScenarios() []protocol.ScenarioRecord

+ func (sm *SessionManager) ResumeScenario(name string, rows, cols uint16) ([]string, error)

+ func (sm *SessionManager) ScenarioStatus(name string) (*protocol.ScenarioRecord, error)

+ func (sm *SessionManager) ScenarioTaskDone(scenarioName, sessionID string) error

+ func (sm *SessionManager) SessionForToken(token string) string

+ func (sm *SessionManager) StartScenario(msg protocol.ScenarioStartMsg, rows, cols uint16) (*ScenarioState, error)

+ func (sm *SessionManager) StopScenario(name string) ([]string, error)

+ func (sm *SessionManager) Update(id string, name *string, parentID *string) error

type SessionState

+ ScenarioGoal string

+ ScenarioID string

+ ScenarioName string

+ ScenarioRole string

+ Token string

type State

+ Scenarios map[string]*ScenarioState

Jun 12, 2026

Changes in this version

type SessionState

+ ExitSignal string

Jun 4, 2026

Changes in this version

type SessionState

+ PIDStartTime int64

Jun 4, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) Config() *config.Config

May 29, 2026

Changes in this version

+ const OrchestratorSessionName

+ const StopReasonCrash

+ const StopReasonIdle

+ const StopReasonShutdown

+ const StopReasonUser

+ const SystemKindOrchestrator

+ func IsSystemSession(s *SessionState) bool

type SessionManager

+ func (sm *SessionManager) RunGitPullLoop(ctx context.Context)

type SessionState

+ BackoffLevel int

+ FreshStart bool

+ LastStartedAt time.Time

+ StopReason string

+ SystemKind string

May 21, 2026

Changes in this version

+ type DocStore struct

+ func NewDocStore(dbPath string) (*DocStore, error)

+ func (s *DocStore) Close() error

+ func (s *DocStore) Delete(repo, key string) error

+ func (s *DocStore) Get(repo, key string) (*Document, error)

+ func (s *DocStore) List(repo, prefix string) ([]Document, error)

+ func (s *DocStore) Put(repo, key, body, contentType, authorID, authorName string) error

+ type Document struct

+ AuthorID string

+ AuthorName string

+ Body string

+ ContentType string

+ CreatedAt string

+ Key string

+ Repo string

+ UpdatedAt string

type SessionManager

+ func (sm *SessionManager) SetDocStore(ds *DocStore)

May 21, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) ClearSummary(sessionID string) error

+ func (sm *SessionManager) SetSummary(sessionID, text string, ttlSeconds int) error

type SessionState

+ LastOutputAt *time.Time

+ SummarySetAt *time.Time

+ SummaryTTL int

+ SummaryText string

May 20, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) Star(id string) error

+ func (sm *SessionManager) Unstar(id string) error

type SessionState

+ Starred bool

May 17, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) StopWithChildren(rootID string, excludeRoot bool) ([]string, error)

type SessionState

+ StatusChangedAt time.Time

type SessionStatus

+ const StatusCreating

+ const StatusDeleting

May 16, 2026

Changes in this version

+ func ValidateSessionName(name string) error

May 13, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) Diagnostics() protocol.DiagnosticsMsg

May 12, 2026

Changes in this version

+ type CreationConfig struct

+ Agent config.Agent

+ SandboxConfig config.SandboxConfig

type SessionState

+ CreationCfg *CreationConfig

May 11, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) Restart(id string, rows, cols uint16) (SessionState, error)

May 8, 2026

Changes in this version

type SessionState

+ Model string

May 7, 2026

Changes in this version

+ type MCPManager struct

+ func NewMCPManager(cfg *config.Config, logDir string, log *slog.Logger) *MCPManager

+ func (m *MCPManager) Connect(serverName, proxyID string) (*MCPProcess, error)

+ func (m *MCPManager) Disconnect(proxyID string)

+ func (m *MCPManager) HasServer(name string) bool

+ func (m *MCPManager) Reload(cfg *config.Config)

+ func (m *MCPManager) Shutdown()

+ type MCPProcess struct

type SessionManager

+ func (sm *SessionManager) SetMCPManager(mm *MCPManager)

May 4, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) DeleteWithChildren(id string) ([]string, error)

type SessionState

+ ParentID string

May 4, 2026

Changes in this version

+ type IncludedRepoState struct

+ BaseBranch string

+ Branch string

+ RepoName string

+ RepoPath string

+ WorktreePath string

type SessionState

+ Includes []IncludedRepoState

+ SharedWorktreeSourceID string

May 1, 2026

Changes in this version

type SessionState

+ InPlace bool

type UpgradeManifest

+ Profile string

Apr 29, 2026

Changes in this version

+ func IsGraithDaemon(pid int) bool

type MsgStore

+ func (s *MsgStore) AckMessages(stream, subscriber string, seqs []int64) error

type SessionManager

+ func (sm *SessionManager) IsAttachedClient(sessionID string, conn net.Conn) bool

type SessionState

+ SandboxConfig *config.SandboxConfig

Apr 27, 2026

Changes in this version

type SessionState

+ AgentHooks bool

Apr 27, 2026

Changes in this version

type SessionState

+ ApprovalsEnabled bool

Apr 26, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) PendingApprovals() []protocol.ApprovalInfo

+ func (sm *SessionManager) RespondToApproval(requestID, decision, reason string) error

+ func (sm *SessionManager) SubmitApproval(ctx context.Context, req protocol.ApprovalRequestMsg) protocol.ApprovalDecisionMsg

type SessionState

+ SharedWorktree bool

Apr 23, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) HandleHookReport(sr protocol.StatusReportMsg)

type SessionState

+ HookContextPercent *float64

+ HookCostUSD *float64

+ HookModel string

+ HookToolName string

+ Sandboxed bool

Apr 22, 2026

Changes in this version

type SessionManager

+ func (sm *SessionManager) Fork(name, sourceSessionID string, rows, cols uint16) (SessionState, error)

Apr 19, 2026

Changes in this version

type MsgStore

+ func (s *MsgStore) Cleanup(maxAge time.Duration, maxPerStream int) (int64, error)

+ func (s *MsgStore) TotalUnread(subscriber string) int

type SessionManager

+ func (sm *SessionManager) ReloadConfig() error

+ func (sm *SessionManager) RunMessageCleanupLoop(ctx context.Context)

Apr 15, 2026

Changes in this version

+ const CurrentStateVersion

+ var ErrDaemonRunning = errors.New("daemon already running")

+ func AcquirePIDFile(path string) error

+ func ExecUpgrade(manifestPath, configFile string) error

+ func HandleConnection(ctx context.Context, conn net.Conn, sm *SessionManager, log *slog.Logger)

+ func Listen(sockPath string) (net.Listener, error)

+ func ReleasePIDFile(path string)

+ func Run(cfg *config.Config, paths config.Paths, configFile, adoptFrom string) error

+ func SaveState(path string, state *State) error

+ func StopDaemon(pidFile string) error

+ func WriteManifest(dir string, m *UpgradeManifest) (string, error)

+ type Message struct

+ Body string

+ CreatedAt string

+ ID string

+ ReplyTo string

+ SenderID string

+ SenderName string

+ Seq int64

+ Stream string

+ ThreadID string

+ type MsgStore struct

+ func NewMsgStore(dbPath string) (*MsgStore, error)

+ func (s *MsgStore) Ack(stream, subscriber string, upToSeq int64) error

+ func (s *MsgStore) AckLatest(stream, subscriber string) error

+ func (s *MsgStore) Close() error

+ func (s *MsgStore) ListStreams(subscriber string) ([]StreamInfo, error)

+ func (s *MsgStore) MessageToJSON(m Message) []byte

+ func (s *MsgStore) Publish(stream, senderID, senderName, body, threadID, replyTo string) (Message, error)

+ func (s *MsgStore) Read(stream, subscriber string, onlyUnread bool, threadID string) ([]Message, error)

+ func (s *MsgStore) Subscribe(stream string) (chan Message, func())

+ type Server struct

+ func NewServer(l net.Listener, handler func(ctx context.Context, conn net.Conn), ...) *Server

+ func (s *Server) Serve(ctx context.Context) error

+ func (s *Server) Shutdown()

+ type SessionManager struct

+ func NewSessionManager(cfg *config.Config, paths config.Paths, log *slog.Logger) *SessionManager

+ func (sm *SessionManager) AdoptSessions(manifest *UpgradeManifest) error

+ func (sm *SessionManager) ClearAttachedClient(sessionID string, conn net.Conn)

+ func (sm *SessionManager) Create(name, agentName, repoPath, baseBranch, prompt string, noRepo bool, ...) (SessionState, error)

+ func (sm *SessionManager) Delete(id string) error

+ func (sm *SessionManager) FindByName(name string) (SessionState, bool)

+ func (sm *SessionManager) Get(id string) (SessionState, bool)

+ func (sm *SessionManager) GetPTY(id string) (*grpty.Session, bool)

+ func (sm *SessionManager) KickAttachedClient(sessionID string)

+ func (sm *SessionManager) List() []SessionState

+ func (sm *SessionManager) LoadState() error

+ func (sm *SessionManager) PrepareUpgrade(listenerFd uintptr, configFile string) (*UpgradeManifest, error)

+ func (sm *SessionManager) Rename(id, newName string) error

+ func (sm *SessionManager) Resume(id string, rows, cols uint16) (SessionState, error)

+ func (sm *SessionManager) RunDetectionLoop(ctx context.Context)

+ func (sm *SessionManager) SetAttachedClient(sessionID string, conn net.Conn, kick func())

+ func (sm *SessionManager) SetMsgStore(ms *MsgStore)

+ func (sm *SessionManager) Stop(id string) error

+ func (sm *SessionManager) StopAll(ctx context.Context)

+ type SessionState struct

+ Agent string

+ AgentSessionID string

+ AgentStatus string

+ AttachedClient string

+ BaseBranch string

+ Branch string

+ CreatedAt time.Time

+ ExitCode *int

+ GitDirty bool

+ GitUnpushed int

+ ID string

+ IdleSince *time.Time

+ LastAttachedAt *time.Time

+ Name string

+ PID int

+ RepoName string

+ RepoPath string

+ Status SessionStatus

+ WorktreePath string

+ type SessionStatus string

+ const StatusErrored

+ const StatusRunning

+ const StatusStopped

+ type State struct

+ Sessions map[string]*SessionState

+ Version int

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

+ func NewState() *State

+ func (s *State) Reconcile()

+ type StreamInfo struct

+ LatestAt string

+ Name string

+ Total int64

+ Unread int64

+ type UpgradeManifest struct

+ ConfigFile string

+ ListenerFd int

+ Sessions []UpgradeSession

+ func ReadManifest(path string) (*UpgradeManifest, error)

+ type UpgradeSession struct

+ Fd int

+ ID string

+ PID int