session

package

Go to main page

Versions in this module

v1

v1.46.0

Aug 20, 2026

Changes in this version

+ func StopSessionDriver(inst *Instance)

+ type ActivityNoteData struct

+ AuthorSessionTitle string

+ AuthorSessionUUID string

+ CreatedAt time.Time

+ ID string

+ Message string

type BacklogChangeKind

+ const ChangeActivityNoteAdded

type BacklogItemChange

+ ActivityNote *ActivityNoteData

type BacklogItemData

+ ActivityNotes []ActivityNoteData

type EntRepository

+ func NewTestEntRepository(t testing.TB) *EntRepository

+ func (r *EntRepository) AppendActivityNote(ctx context.Context, ...) error

+ func (r *EntRepository) ListActivityNotesForItem(ctx context.Context, itemID string) ([]ActivityNoteData, error)

type Instance

+ func (i *Instance) PreviewContext(ctx context.Context) (string, error)

type Storage

+ func (s *Storage) AppendActivityNote(ctx context.Context, ...) error

+ func (s *Storage) ListActivityNotesForItem(ctx context.Context, itemID string) ([]ActivityNoteData, error)

type TmuxProcessManager

+ func (tm *TmuxProcessManager) CapturePaneContentContext(ctx context.Context) (string, error)

v1.45.1

Aug 19, 2026

Changes in this version

+ var EntSchemaCreateMu sync.Mutex

v1.45.0

Aug 17, 2026

Changes in this version

type Instance

+ func (i *Instance) SetCommitStatus(state github.CommitStatusState, statusContext, description string) error

v1.44.1

Aug 17, 2026

v1.44.0

Aug 16, 2026

Changes in this version

+ func JoinHibernation(i *Instance)

+ func JoinSessionDriver(inst *Instance)

type ApprovalRuleData

+ MinSessionIdleMinutes int32

type EntRepository

+ func (r *EntRepository) UnarchiveBacklogItem(ctx context.Context, id string) (*BacklogItemData, error)

type EntWorkflowRepository

+ func (r *EntWorkflowRepository) UpdateConditional(ctx context.Context, id uuid.UUID, w WorkflowUpdateInput, ...) (*ent.Workflow, error)

type Instance

+ func (i *Instance) CapturePaneContentPriority() (string, error)

+ func (i *Instance) RefreshTmuxClientPriority() error

type Repository

+ UnarchiveBacklogItem func(ctx context.Context, id string) (*BacklogItemData, error)

type Storage

+ func (s *Storage) ListInstanceDataWithWorktree() ([]InstanceData, error)

+ func (s *Storage) UnarchiveBacklogItem(ctx context.Context, id string) (*BacklogItemData, error)

type TmuxManager

+ CapturePaneContentPriority func() (string, error)

+ RefreshClientPriority func() error

type TmuxProcessManager

+ func (tm *TmuxProcessManager) CapturePaneContentPriority() (string, error)

+ func (tm *TmuxProcessManager) RefreshClientPriority() error

type WorkflowCreateInput

+ Enabled *bool

type WorkflowRepository

+ UpdateConditional func(ctx context.Context, id uuid.UUID, w WorkflowUpdateInput, ...) (*ent.Workflow, error)

type WorkflowUpdateInput

+ Enabled *bool

v1.43.1

Aug 14, 2026

v1.43.0

Aug 14, 2026

Changes in this version

+ var ErrDependencyCycle = errors.New("backlog item dependency would create a cycle")

+ var ErrDuplicateDelivery = errors.New("duplicate delivery")

+ var ErrUnresolvedBlockers = domain.ErrUnresolvedBlockers

+ func BuildHeadlessChatRetriagePrompt(item *BacklogItemData, artifactAbsPath string, prior HeadlessTriageResult, ...) string

type BacklogItemChange

+ ClaimantHostID string

type BacklogItemData

+ ChainFired bool

+ ChainedAt *time.Time

+ NextWorkflowID *uuid.UUID

+ TriggeredByChainDepth int

+ type BacklogItemDependencyEdge struct

+ BlockedID string

+ BlockerID string

type BacklogItemFilter

+ ChainFired *bool

+ NextWorkflowIDSet *bool

type BacklogItemUpdate

+ ChainFired *bool

+ ChainedAt *time.Time

+ ClearChainedAt bool

+ ClearNextWorkflowID bool

+ NextWorkflowID *uuid.UUID

+ TriggeredByChainDepth *int

type BacklogLifecycleListener

+ func (l *BacklogLifecycleListener) SetChainReconciler(r *TriggerChainReconciler)

+ type CallbackDispatcher interface

+ Dispatch func(eventType string, payload any)

+ type ChainFirer struct

+ func NewChainFirer(repo *EntRepository, workflows WorkflowRepository, ...) *ChainFirer

+ func (c *ChainFirer) Dispatch(item *BacklogItemData)

+ func (c *ChainFirer) Fire(ctx context.Context, item *BacklogItemData) (fired bool, err error)

type EntRepository

+ func (r *EntRepository) AddBacklogItemDependency(ctx context.Context, edge BacklogItemDependencyEdge) error

+ func (r *EntRepository) ClaimChainFire(ctx context.Context, id string, expectedUpdatedAt time.Time) (claimed bool, err error)

+ func (r *EntRepository) RevertChainFireClaim(ctx context.Context, id string) error

+ func (r *EntRepository) SetCallbackDispatcher(d CallbackDispatcher)

+ func (r *EntRepository) SetChainFirer(f *ChainFirer)

+ func (r *EntRepository) UnresolvedBlockerIDs(ctx context.Context, itemID string) ([]string, error)

+ func (r *EntRepository) UnresolvedBlockerItemIDs(ctx context.Context, itemIDs []string) (map[string]bool, error)

+ type EntTriggerFireEventRepository struct

+ func NewEntTriggerFireEventRepository(client *ent.Client) *EntTriggerFireEventRepository

+ func (r *EntTriggerFireEventRepository) Create(ctx context.Context, input TriggerFireEventInput) error

+ func (r *EntTriggerFireEventRepository) ListByWorkflow(ctx context.Context, workflowID uuid.UUID, limit int) ([]*ent.TriggerFireEvent, error)

+ func (r *EntTriggerFireEventRepository) UpdateOutcome(ctx context.Context, workflowID uuid.UUID, ...) error

type EntWorkflowRepository

+ func (r *EntWorkflowRepository) GetByWebhookSlug(ctx context.Context, slug string) (*ent.Workflow, error)

+ func (r *EntWorkflowRepository) ListByTriggerType(ctx context.Context, triggerType string) ([]*ent.Workflow, error)

type InstanceStatusInfo

+ SubagentCount int

type ItemSessionData

+ ClaimantHostID string

type ItemSessionSummary

+ ClaimantHostID string

type Repository

+ AddBacklogItemDependency func(ctx context.Context, edge BacklogItemDependencyEdge) error

+ UnresolvedBlockerIDs func(ctx context.Context, itemID string) ([]string, error)

+ UnresolvedBlockerItemIDs func(ctx context.Context, itemIDs []string) (map[string]bool, error)

type Storage

+ func (s *Storage) AddBacklogItemDependency(ctx context.Context, edge BacklogItemDependencyEdge) error

+ func (s *Storage) SetCallbackDispatcher(d CallbackDispatcher)

+ func (s *Storage) UnresolvedBlockerIDs(ctx context.Context, itemID string) ([]string, error)

+ func (s *Storage) UnresolvedBlockerItemIDs(ctx context.Context, itemIDs []string) (map[string]bool, error)

+ func (s *Storage) WireChainFirer(workflows WorkflowRepository, fireEvents TriggerFireEventRepository, ...) *ChainFirer

+ type TriggerChainReconciler struct

+ func NewTriggerChainReconciler(firer *ChainFirer) *TriggerChainReconciler

+ func (r *TriggerChainReconciler) ReconcileChains(ctx context.Context, er *EntRepository)

+ type TriggerFireEventInput struct

+ DeliveryID string

+ ErrorMessage string

+ Outcome string

+ SessionID string

+ WorkflowID *uuid.UUID

+ type TriggerFireEventRepository interface

+ Create func(ctx context.Context, input TriggerFireEventInput) error

+ ListByWorkflow func(ctx context.Context, workflowID uuid.UUID, limit int) ([]*ent.TriggerFireEvent, error)

+ UpdateOutcome func(ctx context.Context, workflowID uuid.UUID, ...) error

+ type TriggerFirer interface

+ FireTriggerChained func(ctx context.Context, wf *ent.Workflow, priorItemSummary string, ...) (sessionID string, err error)

type WorkflowCreateInput

+ EventFilter string

+ GitHubBranch string

+ GitHubRepo string

+ LabelFilter string

+ PromptTemplate string

+ TriggerType string

+ WebhookSecretEncrypted string

+ WebhookSlug string

type WorkflowRepository

+ GetByWebhookSlug func(ctx context.Context, slug string) (*ent.Workflow, error)

+ ListByTriggerType func(ctx context.Context, triggerType string) ([]*ent.Workflow, error)

type WorkflowUpdateInput

+ EventFilter *string

+ GitHubBranch *string

+ GitHubRepo *string

+ LabelFilter *string

+ LastFiredAt *time.Time

+ PromptTemplate *string

+ TriggerType *string

+ WebhookSecretEncrypted *string

+ WebhookSlug *string

v1.42.0

Aug 13, 2026

Changes in this version

+ const BacklogBranchPrefix

+ const DefaultHeadlessFailureCaptureMaxBytes

+ const MaxSteerMessageLength

+ const TestOnlyReworkMinAttempts

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

+ var ErrCorrelationDrifted = errors.New("import commit: correlation result changed since preview -- please re-preview")

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

+ var ErrInstanceConstructionFailed = errors.New("failed to create instance")

+ var ErrInstanceRegistrationFailed = errors.New("failed to register instance")

+ var ErrInstanceSaveFailed = errors.New("failed to save instance")

+ var ErrNoHistoryAdapter = errors.New("no history adapter resolves for this program")

+ var ErrPRReassignmentNotAllowed = errors.New("PR reassignment not allowed")

+ var ErrPathAlreadyManaged = errors.New("import commit: path is already managed by an existing session")

+ var ErrPathNotExist = errors.New("path does not exist")

+ var ErrResumePathNotExist = errors.New("cannot resume: project directory no longer exists")

+ var ErrTmuxSessionNotFound = errors.New("commit import: candidate's tmux session no longer exists")

+ var ErrVerdictClearRequiredForReady = domain.ErrVerdictClearRequiredForReady

+ func AutoApproveSupported(program string) bool

+ func CancelPendingKill(params CancelPendingKillParams) (resumed bool, err error)

+ func CheckPathNotAlreadyManaged(candidatePath string, registry InstanceStore) error

+ func GetWorktreeDirtyPaths(worktreePath string) ([]string, error)

+ func IsFlakyVerdictFlipFlop(recent []ReviewVerdictSummary) bool

+ func IsTestOnlyReworkCycle(fileListsByAttempt [][]string) bool

+ func ReconcileSuspendedProcesses(_ context.Context, suspended *SuspendedProcessStore, storage InstanceStore) error

+ func RepairCorruptedGitRepo(repoPath string) error

+ func ResumeOriginalProcess(_ int32) error — windows/amd64

+ func ResumeOriginalProcess(pid int32) error — darwin/amd64, js/wasm, linux/amd64

+ func SuspendOriginalProcess(_ int32) error — windows/amd64

+ func SuspendOriginalProcess(pid int32) error — darwin/amd64, js/wasm, linux/amd64

+ func WriteHeadlessFailureCapture(dir, sessionUUID, raw string, maxBytes int64) (absPath string, err error)

+ type AliveChecker interface

+ IsAlive func(pid int32, expectedCreateTimeMs int64) bool

type ApprovalMetadata

+ RiskLevel string

type BacklogItemData

+ PlanRejectedAt *time.Time

+ PlanRejectionReason string

type BacklogItemUpdate

+ ClearPlanRejectedAt bool

+ PlanRejectedAt *time.Time

+ PlanRejectionReason *string

+ type CancelPendingKillParams struct

+ InstanceID string

+ OriginalPID int32

+ Storage InstanceStore

+ Suspended *SuspendedProcessStore

type CanonicalTurn

+ func ReadCanonicalTurnsFromFile(path string) ([]CanonicalTurn, error)

+ type CommitImportParams struct

+ AliveChecker AliveChecker

+ Candidate ExternalSessionCandidate

+ Detector *HistoryFileDetector

+ DisambiguationChoice string

+ ExpectedCorrelation CorrelationResult

+ Linker *HistoryLinker

+ OriginalCreateTimeMs int64

+ OriginalPID int32

+ Registry *Registry

+ Storage InstanceStore

+ Suspended *SuspendedProcessStore

+ TmuxQuerier TmuxSocketQuerier

+ TmuxServerSocket string

+ type CommitImportResult struct

+ FreshCreateTimeMs int64

+ Instance *Instance

+ func CommitImportExternalSession(ctx context.Context, params CommitImportParams) (CommitImportResult, error)

+ type CorrelationConfidence int

+ const ConfidenceNone

+ const ConfidencePIDExact

+ const ConfidencePathHeuristic

+ type CorrelationKind int

+ const CorrelationAmbiguous

+ const CorrelationNotFound

+ const CorrelationResolved

+ func (k CorrelationKind) String() string

+ type CorrelationResult struct

+ Candidates []HistoryFileInfo

+ Confidence CorrelationConfidence

+ Kind CorrelationKind

+ UUID string

+ func CorrelateCandidate(detector *HistoryFileDetector, candidate ExternalSessionCandidate) (CorrelationResult, error)

+ type CreateInstanceOptions = InstanceOptions

+ type CreateManagedInstanceParams struct

+ CreateIfMissing bool

+ Options CreateInstanceOptions

+ Registry *Registry

+ ResumeID string

+ Storage InstanceStore

type EntRepository

+ func (r *EntRepository) GetRepoPathAndLatestCompletedWorkSessionCommits(ctx context.Context, itemID string) (repoPath, baseSHA, headSHA string, err error)

+ func (r *EntRepository) UpdateItemSessionFailureCapture(ctx context.Context, id string, path string) error

+ func (r *EntRepository) UpdateSessionMetadata(ctx context.Context, currentTitle string, ...) error

+ type ExternalSessionCandidate struct

+ PID int32

+ Path string

+ Program string

+ SocketPath string

+ SourceKind ImportSourceKind

+ TmuxSession string

+ func NewCandidateFromDiscovered(ds *mux.DiscoveredSession) ExternalSessionCandidate

type GitHubRef

+ func (r *GitHubRef) PRURL() string

type HistoryFileDetector

+ func (d *HistoryFileDetector) DetectAllByPath(projectPath string) ([]HistoryFileInfo, error)

+ func (d *HistoryFileDetector) ResolveFilePath(projectPath, conversationUUID string) (string, error)

type HistoryFileInfo

+ ModTime time.Time

+ type ImportSourceKind int

+ const MuxDiscovered

+ const PlainTmux

+ func (k ImportSourceKind) String() string

+ type InhibitionEngine struct

+ func NewInhibitionEngine() *InhibitionEngine

+ func (ie *InhibitionEngine) SanitizeString(s string) string

+ func (ie *InhibitionEngine) SanitizeTurn(turn CanonicalTurn) CanonicalTurn

+ func (ie *InhibitionEngine) SanitizeTurns(turns []CanonicalTurn) []CanonicalTurn

type Instance

+ AutoApprove bool

+ ExtraArgs []string

+ func CreateManagedInstance(ctx context.Context, params CreateManagedInstanceParams) (*Instance, error)

+ func (i *Instance) SetAutoApprove(v bool, persist func() error) error

type InstanceData

+ AutoApprove bool

type InstanceOptions

+ AutoApprove bool

+ ExtraArgs []string

type InstanceSnapshot

+ AutoApprove bool

type InstanceStore

+ UpdateInstanceMetadata func(currentTitle string, newTitle, category, note, workingDir *string) error

type ItemSessionSummary

+ FailureCapturePath string

+ func MostRecentCompletedWorkSession(sessions []ItemSessionSummary) *ItemSessionSummary

+ type KillOutcome struct

+ Err error

+ Status KillOutcomeStatus

+ func KillExternalOriginalProcess(checker AliveChecker, pid int32, createTimeMs int64, tmuxSession string) KillOutcome

+ type KillOutcomeStatus int

+ const KillOutcomeAlreadyGone

+ const KillOutcomeFailed

+ const KillOutcomeKilled

+ const KillOutcomeUnspecified

+ type PRReassignmentGuard struct

+ CurrentPRMerged bool

+ NewPRAuthorVerified bool

+ OverrideReason string

type PRStatusPoller

+ func (p *PRStatusPoller) ETagCache() *github.ETagCache

type Repository

+ UpdateSessionMetadata func(ctx context.Context, currentTitle string, ...) error

type ReviewVerdictSummary

+ DiffHash string

type Storage

+ func (s *Storage) ComputeCurrentDiffHash(ctx context.Context, itemID string) string

+ func (s *Storage) UpdateInstanceMetadata(currentTitle string, newTitle, category, note, workingDir *string) error

+ func (s *Storage) UpdateItemSessionFailureCapture(ctx context.Context, id string, path string) error

+ type SuspendedProcessRecord struct

+ Candidate ExternalSessionCandidate

+ CreateTimeMs int64

+ InstanceID string

+ PID int32

+ type SuspendedProcessStore struct

+ func NewSuspendedProcessStore() (*SuspendedProcessStore, error)

+ func (s *SuspendedProcessStore) Add(record SuspendedProcessRecord) error

+ func (s *SuspendedProcessStore) Get(instanceID string) (SuspendedProcessRecord, bool, error)

+ func (s *SuspendedProcessStore) List() ([]SuspendedProcessRecord, error)

+ func (s *SuspendedProcessStore) Remove(instanceID string) error

type TmuxSocketQuerier

+ func NewRealTmuxSocketQuerier() TmuxSocketQuerier

v1.41.0

Aug 10, 2026

Changes in this version

+ const BacklogCategoryBugfix

+ const BacklogCategoryChore

+ const BacklogCategoryFeature

+ const BacklogCategoryRefactor

+ const BacklogStatusQueued

+ const DefaultSDDPipelineModeSlug

+ const EnterKeySequence

+ const MaxNoteLength

+ const TriggeredByAgent

+ const TriggeredByGitHubSync

+ var ErrPauseNotPermitted = errors.New("session does not permit pause")

+ var ErrResumeNotPermitted = errors.New("session does not permit resume")

+ func ApplyTmuxLiveness(peers []WorkspacePeer, liveUUIDs map[string]struct{})

+ func BuildSubmittableInput(input string, pressEnter bool) string

+ func BuildWorkspacePeersBlock(peers []WorkspacePeer) string

+ func ContainsModifiedField(fields []string, name string) bool

+ func EnsureDefaultSDDPipelineMode(ctx context.Context, repo PipelineModeRepository) error

+ func GuardedTransitionAllowed(engine WorkflowEngine, item BacklogItemTransitionInput, to BacklogStatus) bool

+ func IsGitHubURLWithHosts(input string, enterpriseHosts []string) bool

+ func IsTmuxBackedSessionRole(role string) bool

+ func IsValidBacklogCategory(s string) bool

+ func LiveTmuxSessionUUIDs(ctx context.Context) map[string]struct

+ func MergeUserModifiedFields(raw string, newFields ...string) (string, error)

+ func ParseUserModifiedFields(raw string) []string

+ func RenderSessionSummaryMarkdown(sessionTitle string, narrative string, fallbackUsed bool, diff DiffSnapshot, ...) string

+ func WireSessionSummaryListener(generator summaryGenerator, inst *Instance)

+ func WorkspaceKey(githubOwner, githubRepo, mainRepoPath, path string) string

+ func WorkspacePeersBlockForPath(ctx context.Context, storage *Storage, repoPath string) string

type ApprovalMetadata

+ EscalationCategory string

+ EscalationReason string

type ApprovalRuleData

+ RequireCIPassing bool

+ type BacklogCategory = domain.BacklogCategory

+ type BacklogChangeKind string

+ const ChangeItemArchived

+ const ChangeItemRemoved

+ const ChangeItemUpdated

+ const ChangeSessionAttached

+ const ChangeStatusTransition

+ const ChangeTriageProgressUpdated

+ const ChangeVerdictRecorded

+ type BacklogItemChange struct

+ ArchivedAt *time.Time

+ Kind BacklogChangeKind

+ NewStatus string

+ OldStatus string

+ RemovedReason string

+ SessionID string

+ UpdatedFields []string

+ Verdict *ReviewVerdictData

type BacklogItemData

+ Category string

+ ExternalURL string

+ GitHubSyncedIssueUpdatedAt *time.Time

+ Labels []string

+ PrFeedbackAddressedAt *time.Time

+ QueuedAt *time.Time

+ QueuedAutonomous bool

+ UserModifiedFields string

type BacklogItemSummary

+ ExternalURL string

+ Labels []string

type BacklogItemUpdate

+ Category *string

+ ClearGitHubSyncedIssueUpdatedAt bool

+ ClearPrFeedbackAddressedAt bool

+ ExternalURL *string

+ GitHubSyncedIssueUpdatedAt *time.Time

+ Labels *[]string

+ PrFeedbackAddressedAt *time.Time

+ QueuedAt *time.Time

+ QueuedAutonomous *bool

+ UserModifiedFields *string

type BacklogLifecycleListener

+ func (l *BacklogLifecycleListener) SetDequeuer(d QueueDequeuer)

+ func (l *BacklogLifecycleListener) SetOrphanedPRFinder(f func(ctx context.Context, repoPath, branch string) (*github.PRInfo, error))

+ func (l *BacklogLifecycleListener) SetPRByNumberFinder(...)

+ func (l *BacklogLifecycleListener) SetReworkBlockStaleResolver(r ReworkBlockStaleResolver)

+ func (l *BacklogLifecycleListener) SetTriageRespawner(r TriageRespawner)

+ type CostSnapshot struct

+ DataUnavailable bool

+ EstimatedCostUSD float64

+ TotalTokens int64

+ func BuildCostSnapshot(sessionUUID string, tokenStore tokens.TokenStoreReader) CostSnapshot

+ type DecisionRecord struct

+ ApprovalDecision string

+ NotificationType int32

+ type DecisionsSnapshot struct

+ AutoApproved int

+ Denied int

+ ManuallyApproved int

+ ReviewQueueResolved int

+ StillOpen int

+ func BuildDecisionsSnapshot(ctx context.Context, sessionID string, notifLister NotificationDecisionLister, ...) (DecisionsSnapshot, error)

+ func (d DecisionsSnapshot) Percent(n int) float64

+ func (d DecisionsSnapshot) Total() int

+ type DiffSnapshot struct

+ Added int

+ FilesChanged int

+ Removed int

+ func BuildDiffSnapshot(stats *git.DiffStats) DiffSnapshot

+ func (d DiffSnapshot) IsEmpty() bool

type EntRepository

+ func (r *EntRepository) GetBacklogItemsByExternalIDs(ctx context.Context, sourceID string, externalIDs []string) (map[string]*ent.BacklogItem, error)

+ func (r *EntRepository) RecordSourceSyncFailure(ctx context.Context, sourceID string, message string) error

+ func (r *EntRepository) SetItemChangePublisher(p ItemChangePublisher)

+ func (r *EntRepository) SetItemSessionBaseCommit(ctx context.Context, id, sha string) error

+ func (r *EntRepository) TransitionBacklogItemStatusWithPRFields(ctx context.Context, id string, toStatus BacklogStatus, prURL string, ...) (*BacklogItemData, error)

+ func (r *EntRepository) UpdateItemSessionEndedWithReason(ctx context.Context, id string, endedAt time.Time, reason string) error

type ExternalItem

+ IssueUpdatedAt time.Time

+ State string

type GitHubIssuesPlugin

+ func (g *GitHubIssuesPlugin) CloseIssue(ctx context.Context, config PluginConfig, externalID string, ...) (time.Time, error)

+ func (g *GitHubIssuesPlugin) FetchAll(ctx context.Context, config PluginConfig, cursor string) (items []ExternalItem, newCursor string, possiblyIncomplete bool, err error)

+ func (g *GitHubIssuesPlugin) PostIssueComment(ctx context.Context, config PluginConfig, externalID string, body string) error

type GitHubRef

+ Host string

+ func ParseGitHubURLWithHosts(input string, enterpriseHosts []string) (*GitHubRef, error)

+ func ResolveGitHubInputCtx(ctx context.Context, input string) (localPath string, ref *GitHubRef, err error)

+ func ResolveGitHubInputCtxWithHosts(ctx context.Context, input string, enterpriseHosts []string) (localPath string, ref *GitHubRef, err error)

type HeadlessTriageResult

+ ItemCategory string

+ Priority int

type Instance

+ ExitReason string

+ Note string

+ func (i *Instance) ArchiveWithStop(t time.Time) error

+ func (i *Instance) GetProgram() string

+ func (i *Instance) GetShellTmuxSessionName(shellID string) (string, bool)

+ func (i *Instance) MarkCrashed(exitReason string) error

+ func (i *Instance) MarkExitedNormally() error

+ func (i *Instance) PaneExitInfo() (dead bool, code int, signal string)

+ func (i *Instance) ResumeFromCrash(ctx context.Context) error

+ func (i *Instance) SetArchivedAtIfNilAndStop(t time.Time) bool

+ func (i *Instance) SetExitReason(reason string)

+ func (i *Instance) SetNote(note string)

+ func (i *Instance) WorkspaceKey() string

type InstanceContext

+ GetProgram func() string

type InstanceData

+ ExitReason string

+ Note string

+ func (d InstanceData) WorkspaceKey() string

type InstanceOptions

+ Note string

type InstanceSnapshot

+ ExitReason string

+ Note string

+ type ItemChangePublisher interface

+ PublishItemChanged func(item *BacklogItemData, change BacklogItemChange)

type ItemSessionSummary

+ BaseCommitSha string

+ EndReason string

type ItemSourceData

+ BackwardSyncEnabled bool

+ ForwardSyncCloseLabel string

+ ForwardSyncEnabled bool

type ItemSourceUpdate

+ BackwardSyncEnabled *bool

+ ForwardSyncCloseLabel *string

+ ForwardSyncEnabled *bool

type LifecycleEvent

+ const EventStopped

+ type NotificationDecisionLister interface

+ ListDecisionRecords func(ctx context.Context, sessionID string) ([]DecisionRecord, error)

type OpenStuckStateData

+ PlanArtifactsPath string

type PRStatusPoller

+ func (p *PRStatusPoller) PollInterval() time.Duration

+ type PaginatedFetcher interface

+ FetchAll func(ctx context.Context, config PluginConfig, cursor string) (items []ExternalItem, newCursor string, possiblyIncomplete bool, err error)

+ type QueueDequeuer interface

+ DequeueNextQueuedItems func(ctx context.Context) error

type RepoPathManager

+ func (m *RepoPathManager) ResolveGitHubInputCtx(ctx context.Context, input string) (localPath string, ref *GitHubRef, err error)

+ func (m *RepoPathManager) ResolveGitHubInputCtxWithHosts(ctx context.Context, input string, enterpriseHosts []string) (localPath string, ref *GitHubRef, err error)

+ type ReviewQueueLookup interface

+ ReviewQueueResolvedCount func(ctx context.Context, sessionID string) (resolved, stillOpen int, err error)

+ type ReworkBlockStaleResolver interface

+ ResolveReworkBlockedStaleIfRecovered func(ctx context.Context, itemID string) error

type SessionArchiver

+ KillTmuxPaneOnly func(ctx context.Context, sessionUUID string) error

+ type SessionSummaryGenerator struct

+ func NewSessionSummaryGenerator(entClient *ent.Client, pool headless.PoolClient, ...) *SessionSummaryGenerator

+ func (g *SessionSummaryGenerator) FindRowBySessionID(ctx context.Context, sessionID string) (*ent.SessionSummary, error)

+ func (g *SessionSummaryGenerator) GenerateAndPersist(ctx context.Context, sessionUUID, sessionTitle string, createdAt time.Time, ...)

+ func (g *SessionSummaryGenerator) ReconcileStaleness(ctx context.Context, row *ent.SessionSummary) *ent.SessionSummary

+ func (g *SessionSummaryGenerator) SetNotificationLister(l NotificationDecisionLister)

+ func (g *SessionSummaryGenerator) SetTokenStore(t tokens.TokenStoreReader)

+ type SessionSummaryStatus string

+ const SessionSummaryStatusError

+ const SessionSummaryStatusGenerating

+ const SessionSummaryStatusPending

+ const SessionSummaryStatusReady

+ func (s SessionSummaryStatus) IsValid() bool

type Status

+ const Crashed

type Storage

+ func (s *Storage) GetItemSourceByID(ctx context.Context, id string) (*ItemSourceData, error)

+ func (s *Storage) ListWorkspacePeers(ctx context.Context, workspaceKey string, excludeSessionUUID string) ([]WorkspacePeer, error)

+ func (s *Storage) RecordSourceSyncFailure(ctx context.Context, sourceID, message string) error

+ func (s *Storage) RemediationBlocked(ctx context.Context, itemID string, reason domain.StuckReason) (blocked bool, err error)

+ func (s *Storage) SetBacklogItemPRAndTransition(ctx context.Context, itemID, prURL string, prNumber int, summary string) error

+ func (s *Storage) SetItemChangePublisher(p ItemChangePublisher)

+ func (s *Storage) SetItemSessionBaseCommit(ctx context.Context, id, sha string) error

+ func (s *Storage) SetSessionGoalWorkspaceKey(ctx context.Context, sessionUUID, workspaceKey string) error

+ func (s *Storage) UpdateItemSessionEndedWithReason(ctx context.Context, id string, endedAt time.Time, reason string) error

type SyncLoop

+ func (sl *SyncLoop) DecryptConfigToken(raw string) (string, error)

+ func (sl *SyncLoop) PreviewBackwardSyncImpact(ctx context.Context, source *ent.ItemSource) (itemCount int, sampleTitles []string, possiblyIncomplete bool, err error)

+ func (sl *SyncLoop) PreviewBackwardSyncImpactByID(ctx context.Context, sourceID string) (itemCount int, sampleTitles []string, possiblyIncomplete bool, err error)

+ type TimelineSnapshot struct

+ StartedAt time.Time

+ StoppedAt time.Time

+ func BuildTimelineSnapshot(createdAt time.Time, stoppedAt time.Time) TimelineSnapshot

+ func (t TimelineSnapshot) Duration() time.Duration

+ type TriageRespawner interface

+ AutoRespawnTriage func(ctx context.Context, itemID string) error

+ IsTriageLive func(itemID string) bool

+ type WorkspacePeer struct

+ Branch string

+ Goal *SessionGoalData

+ InstanceLive bool

+ Path string

+ SessionUUID string

+ StaleGoal bool

+ Status Status

+ Title string

+ func (p WorkspacePeer) Lifecycle() string

v1.39.0

Jul 21, 2026

Changes in this version

+ const MaxSameSessionReviewAttempts

+ var ErrCodeNotOnMain = domain.ErrCodeNotOnMain

+ var ErrNoOpenStuckState = errors.New("no open stuck state for this item/reason")

+ var ErrRemediationParked = errors.New("remediation attempts exhausted for this item/reason; reset before retrying")

+ var MaxRemediationAttempts = int32(len(remediationBackoffSchedule))

+ func CaptureShipSnapshot(ctx context.Context, storage *Storage, item *BacklogItemData, ...) error

+ func IsRepeatedFailure(recent []ReviewVerdictSummary) bool

+ func IsRepeatedNoVerdictFailure(hadVerdict []bool) bool

type BacklogItemData

+ AutoCreatePR bool

+ ProgressNotes []ProgressNoteData

+ ReworkCapOverride *int

+ ShippedApprovedCount int

+ ShippedChangesReqCount int

+ ShippedCheckConclusion string

+ ShippedFileStats string

+ ShippedSnapshotAt *time.Time

+ ShippedSnapshotCaptureFailed bool

type BacklogItemFilter

+ ExcludeArchived bool

+ ExcludeDone bool

type BacklogItemUpdate

+ AutoCreatePR *bool

+ ReworkCapOverride *int

+ ShippedApprovedCount *int

+ ShippedChangesReqCount *int

+ ShippedCheckConclusion *string

+ ShippedFileStats *string

+ ShippedSnapshotAt *time.Time

+ ShippedSnapshotCaptureFailed *bool

type BacklogLifecycleListener

+ func (l *BacklogLifecycleListener) RecordPRCreatedOutOfBand(ctx context.Context, workSessionUUID, prURL string, prNumber int)

+ func (l *BacklogLifecycleListener) SetBranchReconciler(f func(worktreePath, branchName string) (*git.MergeMainResult, error))

+ func (l *BacklogLifecycleListener) SetOneShotShipRunner(r OneShotShipRunner)

+ func (l *BacklogLifecycleListener) SetReviewRespawner(r ReviewRespawner)

+ func (l *BacklogLifecycleListener) SetSessionArchiver(a SessionArchiver)

+ func (l *BacklogLifecycleListener) SetStaleWorkRemediator(r StaleWorkRemediator)

type CachingPipelineEngine

+ func (e *CachingPipelineEngine) InteractiveReviewPromptFor(item *BacklogItemData, acSnapshot []AcCriterion, diff string, ...) string

type EntRepository

+ func (r *EntRepository) BulkResetStuckRemediation(ctx context.Context, reason *domain.StuckReason, onlyParked bool) (int, error)

+ func (r *EntRepository) FindDoneItemsOlderThan(ctx context.Context, cutoff time.Time) ([]BacklogItemData, error)

+ func (r *EntRepository) FindDriftedPRItems(ctx context.Context) ([]*ent.BacklogItem, error)

+ func (r *EntRepository) FindReviewItemsWithUnprocessedVerdict(ctx context.Context) ([]*ent.BacklogItem, error)

+ func (r *EntRepository) GetRecentReviewVerdictSummaries(ctx context.Context, itemID string, limit int) ([]ReviewVerdictSummary, error)

+ func (r *EntRepository) RecordRemediationAttempt(ctx context.Context, itemID string, reason domain.StuckReason, attempts int32, ...) (bool, error)

+ func (r *EntRepository) RecordRemediationRestartGrace(ctx context.Context, itemID string, reason domain.StuckReason, ...) (bool, error)

+ func (r *EntRepository) ResetStuckRemediation(ctx context.Context, itemID string, reason domain.StuckReason) (bool, error)

+ type OneShotShipRunner interface

+ RunOneShotForSession func(ctx context.Context, sessionID, prompt string, timeoutSeconds int32) (string, error)

type OpenStuckStateData

+ GraceBootTime *time.Time

+ NextRemediationAt *time.Time

+ RemediationAttempts int32

type PipelineEngine

+ InteractiveReviewPromptFor func(item *BacklogItemData, acSnapshot []AcCriterion, diff string, ...) string

type ProgressNoteData

+ ID string

+ type ReviewRespawner interface

+ AutoRespawnReview func(ctx context.Context, itemID string) error

+ type SessionArchiver interface

+ ArchiveSessionByUUID func(ctx context.Context, sessionUUID string) error

+ type StaleWorkRemediator interface

+ RemediateStaleWorkSession func(ctx context.Context, itemID string) error

type Storage

+ func (s *Storage) BulkResetStuckRemediation(ctx context.Context, reason *domain.StuckReason, onlyParked bool) (int, error)

+ func (s *Storage) FindDoneItemsOlderThan(ctx context.Context, cutoff time.Time) ([]BacklogItemData, error)

+ func (s *Storage) GetRecentReviewVerdictSummaries(ctx context.Context, itemID string, limit int) ([]ReviewVerdictSummary, error)

+ func (s *Storage) RecordManualRemediationAttempt(ctx context.Context, itemID string, reason domain.StuckReason) (justParked bool, err error)

+ func (s *Storage) RecordRemediationAttempt(ctx context.Context, itemID string, reason domain.StuckReason, attempts int32, ...) (bool, error)

+ func (s *Storage) RecordRemediationRestartGrace(ctx context.Context, itemID string, reason domain.StuckReason, ...) (bool, error)

+ func (s *Storage) RemediationDue(ctx context.Context, itemID string, reason domain.StuckReason) (due bool, justParked bool, err error)

+ func (s *Storage) ResetStuckRemediation(ctx context.Context, itemID string, reason domain.StuckReason) (bool, error)

v1.38.0

Jul 17, 2026

Changes in this version

+ const DefaultReviewTranscriptMaxBytes

+ func BuildReviewCallOptions(diff, codebaseWorkDir string) (systemPrompt string, opts headless.CallOptions, callTimeout time.Duration, ...)

+ func ComputeContentHash(fields ...string) string

+ func DegradeIfUnverified(path string, overall ReviewOutcome, verdicts []CriterionVerdict, ...) (ReviewOutcome, []CriterionVerdict, string, string)

+ func ParseHeadlessToolReads(text string) []string

+ func RecoverBaseCommitSHA(ctx context.Context, repoPath, headRef string) (string, error)

+ func ResolvedModeLabel(mode string) string

+ func ValidatePipelineModeContent(fields PipelineModeContentFields) error

+ func WriteReviewTranscriptFile(sm *scrollback.ScrollbackManager, sessionUUID, codebaseWorkDir string, ...) (relPath string, cleanup func(), err error)

type AcCriterion

+ func MergeLiveCriterionNotes(snapshot, live []AcCriterion) []AcCriterion

type BacklogItemData

+ AutoSpawnSession bool

+ PipelineMode string

type BacklogItemUpdate

+ AutoSpawnSession *bool

+ PipelineMode *string

type BacklogLifecycleListener

+ func (l *BacklogLifecycleListener) BackfillStuckStates(ctx context.Context)

+ func (l *BacklogLifecycleListener) PipelineEngine() PipelineEngine

+ func (l *BacklogLifecycleListener) SetSessionCreator(s ReviewGateSpawner)

+ func (l *BacklogLifecycleListener) SetSessionLivenessChecker(f func(sessionUUID string) bool)

+ type CachingPipelineEngine struct

+ func NewPipelineEngine(repo PipelineModeRepository) (*CachingPipelineEngine, error)

+ func (e *CachingPipelineEngine) ContentHashFor(mode PipelineMode) (string, bool)

+ func (e *CachingPipelineEngine) InitialPromptFor(item *BacklogItemData, priorSessions []ItemSessionSummary) string

+ func (e *CachingPipelineEngine) InvalidateCache(ctx context.Context) error

+ func (e *CachingPipelineEngine) ReviewPromptFor(item *BacklogItemData, acSnapshot []AcCriterion, diff string, ...) string

+ func (e *CachingPipelineEngine) SlashCommandSet(item *BacklogItemData) (map[string]string, error)

+ func (e *CachingPipelineEngine) TriagePromptFor(item *BacklogItemData, artifactAbsPath string) string

+ type EntPipelineModeRepository struct

+ func NewEntPipelineModeRepository(client *ent.Client) *EntPipelineModeRepository

+ func (r *EntPipelineModeRepository) Create(ctx context.Context, m PipelineModeCreateInput) (*ent.PipelineMode, error)

+ func (r *EntPipelineModeRepository) Delete(ctx context.Context, id uuid.UUID) error

+ func (r *EntPipelineModeRepository) GetByID(ctx context.Context, id uuid.UUID) (*ent.PipelineMode, error)

+ func (r *EntPipelineModeRepository) GetBySlug(ctx context.Context, slug string) (*ent.PipelineMode, error)

+ func (r *EntPipelineModeRepository) ListAll(ctx context.Context) ([]*ent.PipelineMode, error)

+ func (r *EntPipelineModeRepository) ListEnabled(ctx context.Context) ([]*ent.PipelineMode, error)

+ func (r *EntPipelineModeRepository) Update(ctx context.Context, id uuid.UUID, m PipelineModeUpdateInput) (*ent.PipelineMode, error)

type EntRepository

+ func (r *EntRepository) AppendProgressNote(ctx context.Context, itemID string, criterionIndex int, note, status string) error

+ func (r *EntRepository) CountReviewCyclesSince(ctx context.Context, itemID string, since time.Time) (int, error)

+ func (r *EntRepository) FindOpenStuckStates(ctx context.Context) ([]OpenStuckStateData, error)

+ func (r *EntRepository) FindStuckReviewItems(ctx context.Context) ([]*ent.BacklogItem, error)

+ func (r *EntRepository) FindZombieReviewItems(ctx context.Context) ([]*ent.BacklogItem, error)

+ func (r *EntRepository) GetMostRecentStatusEventAt(ctx context.Context, itemID string, toStatus BacklogStatus) (time.Time, bool, error)

+ func (r *EntRepository) ListProgressNotesForItem(ctx context.Context, itemID string) ([]ProgressNoteData, error)

+ func (r *EntRepository) MarkStuck(ctx context.Context, itemID string, reason domain.StuckReason, ...) (applied bool, err error)

+ func (r *EntRepository) MarkStuckNotified(ctx context.Context, itemID string, reason domain.StuckReason) (bool, error)

+ func (r *EntRepository) ResolveStuck(ctx context.Context, itemID string, reason domain.StuckReason) (bool, error)

+ func (r *EntRepository) SnoozeStuckState(ctx context.Context, itemID string, reason domain.StuckReason, until time.Time) (bool, error)

type HeadlessPoolClient

+ CallBlocking func(ctx context.Context, key headless.FeatureKey, systemPrompt string, ...) (string, float64, error)

type ItemSessionData

+ PipelineModeSnapshot string

+ PipelineModeSnapshotHash string

type ItemSessionSummary

+ PipelineModeSnapshot string

+ PipelineModeSnapshotHash string

+ func RecordDegradedReviewVerdict(storage *Storage, itemID string, acSnapshot AcCriteriaJSON, ...) (ItemSessionSummary, error)

+ type OpenStuckStateData struct

+ Context string

+ FirstDetectedAt time.Time

+ ID string

+ ItemID string

+ ItemStatus BacklogStatus

+ ItemTitle string

+ LastCheckedAt time.Time

+ NotifiedAt *time.Time

+ PrNumber int

+ PrURL string

+ Reason domain.StuckReason

+ type PipelineEngine interface

+ ContentHashFor func(mode PipelineMode) (hash string, ok bool)

+ InitialPromptFor func(item *BacklogItemData, priorSessions []ItemSessionSummary) string

+ ReviewPromptFor func(item *BacklogItemData, acSnapshot []AcCriterion, diff string, ...) string

+ SlashCommandSet func(item *BacklogItemData) (map[string]string, error)

+ TriagePromptFor func(item *BacklogItemData, artifactAbsPath string) string

+ type PipelineMode string

+ const PipelineModeDefault

+ type PipelineModeContentFields struct

+ DoneCommandTemplate string

+ FailCommandTemplate string

+ HelpCommandTemplate string

+ InitialPromptTemplate string

+ ReviewCommandTemplate string

+ ReviewPromptTemplate string

+ ShipCommandTemplate string

+ Slug string

+ StatusCommandTemplate string

+ TriagePromptTemplate string

+ ValidateSlug bool

+ type PipelineModeCreateInput struct

+ Description string

+ DoneCommandTemplate string

+ Enabled bool

+ FailCommandTemplate string

+ HelpCommandTemplate string

+ InitialPromptTemplate string

+ Name string

+ ReviewCommandTemplate string

+ ReviewPromptTemplate string

+ ShipCommandTemplate string

+ Slug string

+ StatusCommandTemplate string

+ TriagePromptTemplate string

+ type PipelineModeRepository interface

+ Create func(ctx context.Context, m PipelineModeCreateInput) (*ent.PipelineMode, error)

+ Delete func(ctx context.Context, id uuid.UUID) error

+ GetByID func(ctx context.Context, id uuid.UUID) (*ent.PipelineMode, error)

+ GetBySlug func(ctx context.Context, slug string) (*ent.PipelineMode, error)

+ ListAll func(ctx context.Context) ([]*ent.PipelineMode, error)

+ ListEnabled func(ctx context.Context) ([]*ent.PipelineMode, error)

+ Update func(ctx context.Context, id uuid.UUID, m PipelineModeUpdateInput) (*ent.PipelineMode, error)

+ type PipelineModeUpdateInput struct

+ Description *string

+ DoneCommandTemplate *string

+ Enabled *bool

+ FailCommandTemplate *string

+ HelpCommandTemplate *string

+ InitialPromptTemplate *string

+ Name *string

+ ReviewCommandTemplate *string

+ ReviewPromptTemplate *string

+ ShipCommandTemplate *string

+ StatusCommandTemplate *string

+ TriagePromptTemplate *string

+ type ProgressNoteData struct

+ CreatedAt time.Time

+ CriterionIndex int

+ Note string

+ Status string

+ type ReviewContextExtras struct

+ ItemDescription string

+ PriorSessions []ItemSessionSummary

+ ProgressNotes []ProgressNoteData

+ StatusEvents []BacklogStatusEventData

+ TranscriptRelPath string

type Storage

+ func (s *Storage) AppendProgressNote(ctx context.Context, itemID string, criterionIndex int, note, status string) error

+ func (s *Storage) FindOpenStuckStates(ctx context.Context) ([]OpenStuckStateData, error)

+ func (s *Storage) ListProgressNotesForItem(ctx context.Context, itemID string) ([]ProgressNoteData, error)

+ func (s *Storage) MarkStuck(ctx context.Context, itemID string, reason domain.StuckReason, ...) (bool, error)

+ func (s *Storage) MarkStuckNotified(ctx context.Context, itemID string, reason domain.StuckReason) (bool, error)

+ func (s *Storage) ResolveStuck(ctx context.Context, itemID string, reason domain.StuckReason) (bool, error)

+ func (s *Storage) SnoozeStuckState(ctx context.Context, itemID string, reason domain.StuckReason, until time.Time) (bool, error)

v1.37.0

Jul 14, 2026

Changes in this version

+ const AcCriteriaJSONEmpty

+ const AcStatusDone

+ const AcStatusFail

+ const AcStatusInProgress

+ const AcStatusPending

+ const BacklogStatusPRPending

+ const CategoryBacklog

+ const PermissionModeAcceptEdits

+ const PermissionModeAuto

+ const PermissionModeBypassPermissions

+ const PermissionModeManual

+ const ReviewOutcomeFail

+ const ReviewOutcomePartial

+ const ReviewOutcomePass

+ const ReviewOutcomeUnverifiable

+ const TagAutonomous

+ const TagBacklogRevision

+ const TagBacklogWork

+ var ErrPRRequired = domain.ErrPRRequired

+ func BuildHeadlessRetriagePrompt(item *BacklogItemData, artifactAbsPath string, prior HeadlessTriageResult, ...) string

+ func CreateBacklogWorktree(repoPath, branchSuffix string) (string, error)

+ func GetGitDiffRef(ctx context.Context, dir string, baseSHA string, headRef string) (diff string, truncated bool, err error)

+ func GetGitHeadSHA(repoPath string) (string, error)

+ func IsWorktreeDirty(ctx context.Context, worktreePath string) (bool, error)

+ func SanitizeDiff(diff string) string

+ type AcCriteriaJSON = domain.AcCriteriaJSON

+ func MergeAcCriteria(existing []AcCriterion, incoming []AcCriterion) (AcCriteriaJSON, error)

+ type AcStatus = domain.AcStatus

+ type AutoReopenSpawner interface

+ AutoReopenAfterFailedReview func(ctx context.Context, itemID string) error

type BacklogItemData

+ PrNumber int

+ PrURL string

type BacklogItemPrecondition

+ Note string

+ type BacklogItemSummary struct

+ AcceptanceCriteria AcCriteriaJSON

+ ArchivedAt *time.Time

+ CreatedAt time.Time

+ ExternalID string

+ ID string

+ ItemSessions []ItemSessionSummary

+ Notes string

+ PrNumber int

+ PrURL string

+ Priority int

+ RepoPath string

+ Status BacklogStatus

+ Title string

+ UpdatedAt time.Time

type BacklogItemUpdate

+ PrNumber *int

+ PrURL *string

type BacklogLifecycleListener

+ func (l *BacklogLifecycleListener) ReconcilePRPending(ctx context.Context, er *EntRepository)

+ func (l *BacklogLifecycleListener) SetAutoReopener(r AutoReopenSpawner)

+ func (l *BacklogLifecycleListener) SetNotifier(n Notifier)

+ func (l *BacklogLifecycleListener) SetPRCreatorFactory(...)

+ func (l *BacklogLifecycleListener) SetPRFixSpawner(s PRFixSpawner)

+ func (l *BacklogLifecycleListener) SetPRPendingCheckerFactory(f func(repoPath string) prPendingChecker)

+ func (l *BacklogLifecycleListener) TriggerReviewForSession(workSessionUUID string)

+ type BacklogStatusEventData struct

+ CreatedAt time.Time

+ FromStatus string

+ ID string

+ Note *string

+ ToStatus string

+ TriggeredBy string

type CircularBuffer

+ func (cb *CircularBuffer) GetRecentHash(n int) (uint64, bool)

+ func (cb *CircularBuffer) GetRecentInto(dst []byte, n int) int

type ClaudeController

+ func (cc *ClaudeController) GetQueuedCommandsCount() int

+ func (cc *ClaudeController) GetStatusAndIdleInfo() (detection.DetectedStatus, string, detection.IdleStateInfo)

type EntRepository

+ func (r *EntRepository) BackfillMissingPRNumbers(ctx context.Context) (int, error)

+ func (r *EntRepository) FindPRPendingItems(ctx context.Context) ([]*ent.BacklogItem, error)

+ func (r *EntRepository) FindReviewItemsWithoutGate(ctx context.Context) ([]*ent.BacklogItem, error)

+ func (r *EntRepository) GetAllItemSessionsWithBacklogInfo(ctx context.Context) ([]ItemSessionBacklogEntry, error)

+ func (r *EntRepository) GetBaseCommitSHAsForSessions(ctx context.Context, sessionUUIDs []string) (map[string]string, error)

+ func (r *EntRepository) GetClaudeConversationUUIDBySessionUUID(ctx context.Context, sessionUUID string) (string, error)

+ func (r *EntRepository) GetWorktreeDataBySessionUUID(ctx context.Context, sessionUUID string) (GitWorktreeData, error)

+ func (r *EntRepository) ListBacklogItemSummaries(ctx context.Context, filter BacklogItemFilter) ([]BacklogItemSummary, error)

+ func (r *EntRepository) UpdateItemSessionVerificationNotes(ctx context.Context, id string, verificationNotes string) error

type GitWorktreeManager

+ func (gm *GitWorktreeManager) GetDirBaseSHA() string

+ func (gm *GitWorktreeManager) SetDirBaseSHA(sha string)

type HeadlessTriageResult

+ AcceptanceCriteria []AcCriterion

+ Feedback string

+ Iteration int

+ Title string

type Instance

+ func (i *Instance) PaneProcessDead() bool

+ func (i *Instance) SetDirBaseSHA(sha string)

+ func (i *Instance) SwitchProgram(ctx context.Context, rawProgram string, persist func() error) (changed bool, resolvedProgram string, err error)

type InstanceData

+ TmuxServerSocket string

+ type ItemSessionBacklogEntry struct

+ ItemID string

+ ItemStatus string

+ ItemTitle string

+ SessionRole string

+ SessionUUID string

type ItemSessionData

+ EstimatedCostUsd float64

+ VerificationNotes string

+ type ItemSessionSummary struct

+ AcSnapshot AcCriteriaJSON

+ BacklogItemID string

+ CommitCountSinceSpawn int

+ CreatedAt time.Time

+ EndedAt *time.Time

+ EstimatedCostUsd float64

+ ID string

+ LastCommitAt *time.Time

+ LastCommitMessage string

+ LastCommitSha string

+ LastFileTouchAt *time.Time

+ LastProgressAt *time.Time

+ OverallOutcome string

+ ReviewVerdict *ReviewVerdictSummary

+ Role string

+ SessionUUID string

+ StartedAt *time.Time

+ TriageResult string

+ TriageResultSummary string

+ VerificationNotes string

+ type Notifier interface

+ Notify func(itemID, title, message string, notificationType, priority int32)

+ type PRFixSpawner interface

+ AutoReopenForPRFix func(ctx context.Context, itemID string, fixContext string) error

type PTYAccess

+ func (p *PTYAccess) GetRecentHash(n int) (uint64, bool)

+ func (p *PTYAccess) GetRecentOutputInto(dst []byte, n int) int

type Repository

+ GetAllItemSessionsWithBacklogInfo func(ctx context.Context) ([]ItemSessionBacklogEntry, error)

+ ListBacklogItemSummaries func(ctx context.Context, filter BacklogItemFilter) ([]BacklogItemSummary, error)

+ type ReviewGateRunner struct

+ func NewReviewGateRunner(storage *Storage, getPool func() *headless.Pool, ...) *ReviewGateRunner

+ func (r *ReviewGateRunner) Run(ctx context.Context, item *BacklogItemData, is ItemSessionSummary, ...)

+ type ReviewOutcome = domain.ReviewOutcome

+ type ReviewVerdictSummary struct

+ CreatedAt time.Time

+ DiffTokenCount int

+ DiffTruncated bool

+ ID string

+ OverallOutcome string

+ OverrideAt *time.Time

+ OverrideBy string

+ OverrideReason string

+ PerCriterion string

+ Summary string

+ type SourceSyncEventData struct

+ CursorAfter string

+ ErrorMessage string

+ FinishedAt *time.Time

+ ID string

+ ItemsCreated int

+ ItemsErrored int

+ ItemsSkipped int

+ ItemsUpdated int

+ StartedAt time.Time

type Storage

+ func (s *Storage) GetAllItemSessionsWithBacklogInfo(ctx context.Context) ([]ItemSessionBacklogEntry, error)

+ func (s *Storage) GetBaseCommitSHAsForSessions(ctx context.Context, uuids []string) (map[string]string, error)

+ func (s *Storage) GetClaudeConversationUUIDBySessionUUID(ctx context.Context, sessionUUID string) (string, error)

+ func (s *Storage) GetWorktreeDataBySessionUUID(ctx context.Context, sessionUUID string) (GitWorktreeData, error)

+ func (s *Storage) ListBacklogItemSummaries(ctx context.Context, filter BacklogItemFilter) ([]BacklogItemSummary, error)

+ func (s *Storage) UpdateItemSessionGitActivity(ctx context.Context, id string, sha, msg string, commitAt time.Time, ...) error

+ func (s *Storage) UpdateItemSessionVerificationNotes(ctx context.Context, id string, verificationNotes string) error

type TmuxManager

+ PaneExitStatus func() (code int, signal string, dead bool)

type TmuxProcessManager

+ func (tm *TmuxProcessManager) PaneExitStatus() (code int, signal string, dead bool)

+ type TmuxSocketQuerier interface

+ IsServerDown func(serverSocket string) bool

+ ListSessions func(serverSocket string) (map[string]bool, error)

type WorktreePRPollerConfig

+ NoPRBackoff time.Duration

v1.35.0

Jul 6, 2026

Changes in this version

+ const DefaultBacklogPriority

+ const GoalStatusBlocked

+ const GoalStatusDone

+ const GoalStatusIdle

+ const GoalStatusWorking

+ const PauseReasonAutoInactivity

+ const PauseReasonAutoLimit

+ const PauseReasonAutoResource

+ const PauseReasonManual

+ const ReviewVerdictFail

+ const ReviewVerdictPartial

+ const ReviewVerdictPass

+ const ReviewVerdictUnverifiable

+ const SessionRoleReview

+ const SessionRoleTriage

+ const SessionRoleWork

+ const SessionTypeNewProject

+ const SessionTypeOneOff

+ const TaskStatusBlocked

+ const TaskStatusDone

+ const TaskStatusInProgress

+ const TaskStatusPending

+ const TriggeredBySystem

+ const TriggeredByUser

+ var ErrACRequired = errors.New("acceptance criteria required before marking ready")

+ var ErrConflict = errors.New("conflict")

+ var ErrInstanceDataNotFound = errors.New("instance data not found")

+ var ErrNotFound = errors.New("not found")

+ var ErrPlanArtifactsRequired = errors.New("plan artifacts path is required when planning is not skipped")

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

+ var ErrPreconditionFailed = errors.New("precondition failed: concurrent modification detected")

+ var ErrSessionAlreadyRegistered = errors.New("session: already registered")

+ var ErrSessionNotFound = errors.New("session: not found in storage")

+ var ErrShellStopped = errors.New("shell is stopped")

+ var ErrSubscriberFull = errors.New("PTYSubscriber: internal buffer exceeded capacity limit") — darwin/amd64, js/wasm, linux/amd64

+ var ErrVerdictRequired = errors.New("PASS verdict or manual override required before marking done")

+ func AggregateOutcome(verdicts []CriterionVerdict) string

+ func BuildHeadlessReviewPrompt(item *ent.BacklogItem, acSnapshot []AcCriterion, diff string, ...) string

+ func BuildHeadlessTriagePrompt(item *BacklogItemData, artifactAbsPath string) string

+ func BuildReviewPrompt(item *ent.BacklogItem, acSnapshot []AcCriterion, diff string, ...) string

+ func BuildSessionInitialPrompt(item *ent.BacklogItem, priorSessions []*ent.ItemSession) string

+ func BuildTokenBudgetedPrompt(item *ent.BacklogItem, priorSessions []*ent.ItemSession) string

+ func CanTransitionBacklog(from, to BacklogStatus) bool

+ func CleanupBacklogContextFile(worktreePath string) error

+ func CleanupSlashCommands(worktreePath string) error

+ func DecryptToken(key []byte, ciphertext string) (string, error)

+ func EncodeTasks(tasks []TaskNode) (string, error)

+ func EncryptToken(key []byte, plaintext string) (string, error)

+ func EnsureDirectorySessionPath(path string) error

+ func ExtractPRURL(sessionOutput string) string

+ func FindConversationFilePath(sessionID string) (string, error)

+ func FindInstanceByHistoryPath(instances []*Instance, filePath string) (string, bool)

+ func GetGitDiff(ctx context.Context, worktreePath string, baseSHA string) (diff string, truncated bool, err error)

+ func InstanceInfoSlice(instances []*Instance) []artifacts.InstanceInfo

+ func IsValidTaskStatus(s string) bool

+ func PortSessionHistory(ctx context.Context, oldProgram, newProgram string, i *Instance) error

+ func ReconcileOrphanedTmuxSessions(instances []*Instance)

+ func RegisterBackendProvider(backend ProcessManagerBackend)

+ func ResolveSessionPath(path string) (string, error)

+ func RunPreGateSecurityCheck(diff string) error

+ func SanitizeForAgentContext(s string, maxLen int) string

+ func SerializeAcCriteria(criteria []AcCriterion) (string, error)

+ func StartSessionDriver(inst *Instance, allowedPath string)

+ func TransitionGuard(item BacklogItemTransitionInput, to BacklogStatus) error

+ func ValidateTaskDepth(tasks []TaskNode, depth int) error

+ func ValidateWorkflowSlug(slug string) error

+ func WriteBacklogContextFile(item *ent.BacklogItem, priorSessions []*ent.ItemSession, worktreePath string) error

+ func WriteSlashCommands(item *ent.BacklogItem, worktreePath string) error

+ type AcCriterion struct

+ Index int

+ Status string

+ Text string

+ func ParseAcCriteria(raw string) ([]AcCriterion, error)

+ type AgyAdapter struct

+ func NewAgyAdapter() *AgyAdapter

+ func (a *AgyAdapter) CanHandle(program string) bool

+ func (a *AgyAdapter) Export(ctx context.Context, turns []CanonicalTurn, inst *Instance) error

+ func (a *AgyAdapter) Import(ctx context.Context, inst *Instance) ([]CanonicalTurn, error)

+ func (a *AgyAdapter) Name() string

type ApprovalRuleData

+ BlockedSubcommands []string

+ ForbiddenFlags []string

+ Programs []string

+ PythonModes []string

+ RequiredFlagPrefixes []string

+ RequiredFlags []string

+ SafePythonImportsOnly bool

+ Subcommands []string

+ type AutonomousDriver struct

+ func NewAutonomousDriver(inst *Instance, pool HeadlessPoolClient, goal string, maxTurns int, ...) *AutonomousDriver

+ func (d *AutonomousDriver) RegisterCompletionCallback(cb CompletionCallback)

+ func (d *AutonomousDriver) RegisterTurnCallback(cb TurnCallback)

+ func (d *AutonomousDriver) Start(ctx context.Context) error

+ func (d *AutonomousDriver) Stop()

+ type AutonomousDriverOutcome struct

+ Done bool

+ PRUrl string

+ Reason string

+ Stuck bool

+ Turns int

+ type AutonomousModeState struct

+ AutonomousMaxTurns int32

+ AutonomousMode bool

+ AutonomousOutcome string

+ AutonomousTurn int32

+ type BacklogController struct

+ func NewBacklogController(listener *BacklogLifecycleListener, storage *Storage, registry *PluginRegistry, ...) *BacklogController

+ func (c *BacklogController) Disable() error

+ func (c *BacklogController) Enable(_ context.Context) error

+ func (c *BacklogController) IsEnabled() bool

+ type BacklogItemData struct

+ AcceptanceCriteria string

+ ArchivedAt *time.Time

+ CreatedAt time.Time

+ Description string

+ ExternalID string

+ ID string

+ ItemSessions []*ent.ItemSession

+ Notes string

+ PlanApproved bool

+ PlanApprovedAt *time.Time

+ PlanArtifactsPath string

+ Priority int

+ RepoPath string

+ SkipPlanning bool

+ SkipReviewGate bool

+ SourceID string

+ Status string

+ StatusEvents []*ent.BacklogStatusEvent

+ Title string

+ UpdatedAt time.Time

+ type BacklogItemFilter struct

+ ExcludeTerminal bool

+ Limit int

+ Offset int

+ Priorities []int

+ SortBy string

+ Statuses []string

+ type BacklogItemPrecondition struct

+ ExpectedStatus string

+ ExpectedUpdatedAt *time.Time

+ type BacklogItemTransitionInput struct

+ AcCriteriaJSON string

+ OverallOutcome string

+ OverrideReason string

+ PlanApproved bool

+ PlanArtifactsPath string

+ SkipPlanning bool

+ Status BacklogStatus

+ type BacklogItemUpdate struct

+ AcceptanceCriteria *string

+ Description *string

+ Notes *string

+ PlanApproved *bool

+ PlanApprovedAt *time.Time

+ PlanArtifactsPath *string

+ Priority *int

+ RepoPath *string

+ SkipPlanning *bool

+ SkipReviewGate *bool

+ Title *string

+ type BacklogLifecycleListener struct

+ func NewBacklogLifecycleListener(storage *Storage) *BacklogLifecycleListener

+ func NewBacklogLifecycleListenerWithPool(storage *Storage, pool *headless.Pool) *BacklogLifecycleListener

+ func NewBacklogLifecycleListenerWithSpawner(storage *Storage, spawner ReviewGateSpawner) *BacklogLifecycleListener

+ func (l *BacklogLifecycleListener) ReconcileStuck(ctx context.Context)

+ func (l *BacklogLifecycleListener) SetEnabled(v bool)

+ func (l *BacklogLifecycleListener) SetHeadlessPool(p *headless.Pool)

+ func (l *BacklogLifecycleListener) Shutdown()

+ func (l *BacklogLifecycleListener) WireToInstance(inst *Instance)

+ type BacklogStatus string

+ const BacklogStatusArchived

+ const BacklogStatusDone

+ const BacklogStatusIdea

+ const BacklogStatusInProgress

+ const BacklogStatusReady

+ const BacklogStatusRefining

+ const BacklogStatusReview

+ type CDPStreamManager = cdp.CDPStreamManager

+ type CanonicalBlock struct

+ Kind CanonicalBlockKind

+ Text string

+ ToolArgs json.RawMessage

+ ToolID string

+ ToolName string

+ ToolResultContent string

+ ToolResultID string

+ ToolResultIsError bool

+ func NewTextBlock(text string) CanonicalBlock

+ func NewThinkingBlock(text string) CanonicalBlock

+ func NewToolResultBlock(id, name, content string, isError bool) CanonicalBlock

+ func NewToolUseBlock(id, name string, args json.RawMessage) CanonicalBlock

+ func (b CanonicalBlock) Validate() error

+ type CanonicalBlockKind string

+ const BlockKindImage

+ const BlockKindText

+ const BlockKindThinking

+ const BlockKindToolResult

+ const BlockKindToolUse

+ type CanonicalRole string

+ const RoleAssistant

+ const RoleUser

+ type CanonicalTurn struct

+ Blocks []CanonicalBlock

+ Model string

+ Role CanonicalRole

+ Timestamp time.Time

+ TurnIndex int

+ func (t CanonicalTurn) Validate() error

type Checkpoint

+ CanonicalPath string

+ CanonicalTurnIndex int

type CircularBuffer

+ func (cb *CircularBuffer) TotalBytesWritten() int64

+ type ClaudeAdapter struct

+ func NewClaudeAdapter() *ClaudeAdapter

+ func (a *ClaudeAdapter) CanHandle(program string) bool

+ func (a *ClaudeAdapter) Export(ctx context.Context, turns []CanonicalTurn, inst *Instance) error

+ func (a *ClaudeAdapter) Import(ctx context.Context, inst *Instance) ([]CanonicalTurn, error)

+ func (a *ClaudeAdapter) Name() string

type ClaudeController

+ func (cc *ClaudeController) AddStatusChangeListener(fn StatusChangeListener)

+ func (cc *ClaudeController) GetEscapeParser() *analytics.EscapeCodeParser

+ func (cc *ClaudeController) GetRateLimitHandler() *ratelimit.PTYConsumer

+ func (cc *ClaudeController) GetRateLimitResetTime() time.Time

+ func (cc *ClaudeController) GetStatusDetector() detection.TerminalDetector

+ func (cc *ClaudeController) GetTotalBytesWritten() int64

+ func (cc *ClaudeController) SetStatusChangeListener(fn StatusChangeListener)

type ClaudeSessionData

+ func (c *ClaudeSessionData) UnmarshalJSON(data []byte) error

+ type CompletionCallback func(instanceName string, outcome AutonomousDriverOutcome)

+ type ContentProvider interface

+ EvictInstance func(title string)

+ GetContent func(inst *Instance, statusInfo InstanceStatusInfo, ...) string

+ func NewPollerContentProvider() ContentProvider

+ type ConversationID string

+ func ParseConversationID(s string) (ConversationID, error)

+ type CriterionVerdict struct

+ CriterionIndex int

+ Evidence string

+ Outcome string

+ func ParseHeadlessVerdictResult(text string) (overall string, verdicts []CriterionVerdict, summary string)

+ type DefaultStatusDeterminer struct

+ func NewDefaultStatusDeterminer(config ReviewQueuePollerConfig) *DefaultStatusDeterminer

+ func (d *DefaultStatusDeterminer) Determine(inst *Instance, content string, statusInfo InstanceStatusInfo, ...) DetectionResult

+ type DefaultWorkflowEngine struct

+ func NewDefaultWorkflowEngine() *DefaultWorkflowEngine

+ func (e *DefaultWorkflowEngine) AllowedTransitions(from BacklogStatus) []BacklogStatus

+ func (e *DefaultWorkflowEngine) CanTransition(from, to BacklogStatus) bool

+ func (e *DefaultWorkflowEngine) ValidateGates(item BacklogItemTransitionInput, to BacklogStatus) error

+ type DetectionAction int

+ const DetectionActionAdd

+ const DetectionActionRemove

+ const DetectionActionSkip

+ type DetectionResult struct

+ Action DetectionAction

+ ClaudeStatus detection.DetectedStatus

+ CleanWorktree bool

+ Context string

+ Priority Priority

+ Reason AttentionReason

+ func (r DetectionResult) IsHighPriority() bool

+ type DriverOption func(*AutonomousDriver)

+ func WithStartupTimeout(d time.Duration) DriverOption

type EntRepository

+ func NewEntRepositoryFromClient(client *ent.Client) *EntRepository

+ func (r *EntRepository) ArchiveBacklogItem(ctx context.Context, id string) (*BacklogItemData, error)

+ func (r *EntRepository) CreateBacklogItem(ctx context.Context, data BacklogItemData) (*BacklogItemData, error)

+ func (r *EntRepository) CreateItemSession(ctx context.Context, data ItemSessionData) (*ent.ItemSession, error)

+ func (r *EntRepository) CreateItemSessionWithVerdict(ctx context.Context, isData ItemSessionData, verdict ReviewVerdictData) (*ent.ItemSession, *ent.ReviewVerdict, error)

+ func (r *EntRepository) CreateItemSource(ctx context.Context, data ItemSourceData) (*ItemSourceData, error)

+ func (r *EntRepository) CreateShell(ctx context.Context, sessionTitle string, data ShellData) (*ent.Shell, error)

+ func (r *EntRepository) CreateSourceSyncEvent(ctx context.Context, sourceID string, cursorAfter string, ...) error

+ func (r *EntRepository) DeleteBacklogItem(ctx context.Context, id string) error

+ func (r *EntRepository) DeleteItemSource(ctx context.Context, id string) error

+ func (r *EntRepository) DeleteShell(ctx context.Context, shellID string) error

+ func (r *EntRepository) FinishSourceSync(ctx context.Context, sourceID string, cursorAfter string, ...) error

+ func (r *EntRepository) GetAllSessionArtifacts(ctx context.Context) (map[string]string, error)

+ func (r *EntRepository) GetBacklogItem(ctx context.Context, id string) (*BacklogItemData, error)

+ func (r *EntRepository) GetBacklogItemByExternalID(ctx context.Context, sourceID, externalID string) (*ent.BacklogItem, error)

+ func (r *EntRepository) GetEntClient() *ent.Client

+ func (r *EntRepository) GetItemSession(ctx context.Context, id string) (*ent.ItemSession, error)

+ func (r *EntRepository) GetItemSessionBySessionAndItem(ctx context.Context, sessionUUID string, itemID string) (*ent.ItemSession, error)

+ func (r *EntRepository) GetItemSessionBySessionUUID(ctx context.Context, sessionUUID string) (*ent.ItemSession, error)

+ func (r *EntRepository) GetItemSourceByID(ctx context.Context, id string) (*ent.ItemSource, error)

+ func (r *EntRepository) GetMostRecentReviewVerdictForItem(ctx context.Context, itemID string) (string, error)

+ func (r *EntRepository) GetSessionArtifacts(ctx context.Context, title string) (string, error)

+ func (r *EntRepository) GetSubcommandBreakdown(ctx context.Context, program string, since time.Time) ([]SubcommandDecisionCount, error)

+ func (r *EntRepository) GetSubcommandTrend(ctx context.Context, program, subcommand string, since time.Time) ([]AnalyticsData, error)

+ func (r *EntRepository) ListAnalyticsByProgramSince(ctx context.Context, program string, since time.Time, limit int) ([]AnalyticsData, error)

+ func (r *EntRepository) ListAnalyticsSince(ctx context.Context, since time.Time, limit int) ([]AnalyticsData, error)

+ func (r *EntRepository) ListBacklogItems(ctx context.Context, filter BacklogItemFilter) ([]BacklogItemData, error)

+ func (r *EntRepository) ListItemSessions(ctx context.Context, itemID string) ([]*ent.ItemSession, error)

+ func (r *EntRepository) ListItemSources(ctx context.Context) ([]ItemSourceData, error)

+ func (r *EntRepository) ListRecentCommandsByProgram(ctx context.Context, program, subcommand string, since time.Time, n int) ([]string, error)

+ func (r *EntRepository) ListShells(ctx context.Context, sessionTitle string) ([]*ent.Shell, error)

+ func (r *EntRepository) ListSourceSyncEvents(ctx context.Context, sourceID string) (events []*ent.SourceSyncEvent, truncated bool, err error)

+ func (r *EntRepository) ReconcileStuckItems(ctx context.Context) (int, error)

+ func (r *EntRepository) SaveReviewVerdict(ctx context.Context, itemSessionID string, verdict ReviewVerdictData) (*ent.ReviewVerdict, error)

+ func (r *EntRepository) TransitionBacklogItemStatus(ctx context.Context, id string, toStatus BacklogStatus, ...) (*BacklogItemData, error)

+ func (r *EntRepository) UpdateAcCriterionStatus(ctx context.Context, itemID string, criterionIndex int, status string, ...) error

+ func (r *EntRepository) UpdateBacklogItem(ctx context.Context, id string, update BacklogItemUpdate, ...) (*BacklogItemData, error)

+ func (r *EntRepository) UpdateGitHubPRNumber(ctx context.Context, title string, prNumber int) error

+ func (r *EntRepository) UpdateItemSessionEnded(ctx context.Context, id string, endedAt time.Time) error

+ func (r *EntRepository) UpdateItemSessionFileTouch(ctx context.Context, id string, touchAt time.Time) error

+ func (r *EntRepository) UpdateItemSessionGitActivity(ctx context.Context, id string, sha, msg string, commitAt time.Time, ...) error

+ func (r *EntRepository) UpdateItemSessionSessionUUID(ctx context.Context, id string, sessionUUID string) error

+ func (r *EntRepository) UpdateItemSessionStarted(ctx context.Context, id string, startedAt time.Time) error

+ func (r *EntRepository) UpdateItemSessionTriageResult(ctx context.Context, id string, triageResult string) error

+ func (r *EntRepository) UpdateItemSource(ctx context.Context, id string, update ItemSourceUpdate) (*ItemSourceData, error)

+ func (r *EntRepository) UpdateLastAcknowledged(ctx context.Context, title string, t time.Time) error

+ func (r *EntRepository) UpdateLastAddedToQueue(ctx context.Context, title string, t time.Time) error

+ func (r *EntRepository) UpdateLastViewed(ctx context.Context, title string, t time.Time) error

+ func (r *EntRepository) UpdateReviewQueueState(ctx context.Context, title string, ...) error

+ func (r *EntRepository) UpdateSessionArtifacts(ctx context.Context, title string, blob string) error

+ func (r *EntRepository) UpdateShellStatus(ctx context.Context, shellID, status string, exitCode *int) error

+ type EntWorkflowRepository struct

+ func NewEntWorkflowRepository(client *ent.Client) *EntWorkflowRepository

+ func (r *EntWorkflowRepository) Create(ctx context.Context, w WorkflowCreateInput) (*ent.Workflow, error)

+ func (r *EntWorkflowRepository) Delete(ctx context.Context, id uuid.UUID) error

+ func (r *EntWorkflowRepository) GetByID(ctx context.Context, id uuid.UUID) (*ent.Workflow, error)

+ func (r *EntWorkflowRepository) GetBySlug(ctx context.Context, slug string) (*ent.Workflow, error)

+ func (r *EntWorkflowRepository) ListAll(ctx context.Context) ([]*ent.Workflow, error)

+ func (r *EntWorkflowRepository) ListEnabled(ctx context.Context) ([]*ent.Workflow, error)

+ func (r *EntWorkflowRepository) Update(ctx context.Context, id uuid.UUID, w WorkflowUpdateInput) (*ent.Workflow, error)

+ type ExternalItem struct

+ Description string

+ ExternalID string

+ Labels []string

+ Priority int

+ Title string

+ URL string

+ type ForceReleaseFunc func()

+ type GitHubIntegration struct

+ ClonedRepoPath string

+ GitHubApprovedCount int

+ GitHubChangesReqCount int

+ GitHubCheckConclusion string

+ GitHubIsFork bool

+ GitHubOwner string

+ GitHubPRIsDraft bool

+ GitHubPRNumber int

+ GitHubPRPriority string

+ GitHubPRState string

+ GitHubPRStatusTerminal bool

+ GitHubPRURL string

+ GitHubRepo string

+ GitHubSourceRef string

+ IsWorktree bool

+ LastPRStatusCheck time.Time

+ MainRepoPath string

+ type GitHubIssuesPlugin struct

+ func NewGitHubIssuesPlugin() *GitHubIssuesPlugin

+ func (g *GitHubIssuesPlugin) Fetch(ctx context.Context, config PluginConfig, cursor string) ([]ExternalItem, string, error)

+ func (g *GitHubIssuesPlugin) MapToBacklogItem(item ExternalItem, sourceID string) BacklogItemData

+ func (g *GitHubIssuesPlugin) PluginID() string

+ type GitHubPRsPlugin struct

+ func NewGitHubPRsPlugin() *GitHubPRsPlugin

+ func (g *GitHubPRsPlugin) Fetch(ctx context.Context, config PluginConfig, cursor string) ([]ExternalItem, string, error)

+ func (g *GitHubPRsPlugin) MapToBacklogItem(item ExternalItem, sourceID string) BacklogItemData

+ func (g *GitHubPRsPlugin) PluginID() string

type GitManager

+ InvalidateDirtyCache func()

+ PrimeDirtyCacheJitter func()

type GitWorktreeManager

+ func (gm *GitWorktreeManager) InvalidateDirtyCache()

+ func (gm *GitWorktreeManager) PrimeDirtyCacheJitter()

+ type HeadlessPoolClient interface

+ CallBlockingWithOptions func(ctx context.Context, key headless.FeatureKey, systemPrompt string, ...) (string, error)

+ type HeadlessTriageResult struct

+ Suggestions []TriageSuggestion

+ Summary string

+ Tasks []TriageTask

+ func ParseHeadlessTriageResult(raw string) (HeadlessTriageResult, error)

+ type HibernationSweeper struct

+ func NewHibernationSweeper(storage *Storage, cfg *appconfig.Config, reader memory.Reader) *HibernationSweeper

+ func (s *HibernationSweeper) GetCachedRSSMB(sessionUUID string) int64

+ func (s *HibernationSweeper) SetLiveProvider(p LiveInstancesProvider)

+ func (s *HibernationSweeper) Start(ctx context.Context)

+ func (s *HibernationSweeper) SystemMemoryPct() (float64, error)

+ type HistoryAdapter interface

+ CanHandle func(program string) bool

+ Export func(ctx context.Context, turns []CanonicalTurn, inst *Instance) error

+ Import func(ctx context.Context, inst *Instance) ([]CanonicalTurn, error)

+ Name func() string

type HistoryFileWatcher

+ func (w *HistoryFileWatcher) Stopped() <-chan struct{}

type HistoryLinker

+ func (hl *HistoryLinker) RegisterFileCallback(cb func(filePath string))

type Instance

+ AllowedTools string

+ AppendSystemPrompt string

+ ArchivedAt *time.Time

+ Artifacts *artifacts.SessionArtifactsBlob

+ AutonomousMaxTurns int32

+ AutonomousOutcome string

+ AutonomousTurn int32

+ CLIFlags string

+ CreateIfMissing bool

+ CreationProgress string

+ EnvVars map[string]string

+ Hidden bool

+ InitialPrompt string

+ PauseReason string

+ PermissionMode string

+ RateLimitAutoResume *bool

+ WorkflowID string

+ func (i *Instance) AddShellInMemory(sh *Shell)

+ func (i *Instance) CDPDisplayEnv() []string

+ func (i *Instance) CDPManager() CDPStreamManager

+ func (i *Instance) ClearConversationState()

+ func (i *Instance) CurrentBranch() string

+ func (i *Instance) DeleteShell(ctx context.Context, shellID string) error

+ func (i *Instance) FireLifecycleEventForTest(event LifecycleEvent, reason string)

+ func (i *Instance) ForceStatus(s Status)

+ func (i *Instance) GetClaudeConversationUUID() string

+ func (i *Instance) GetDetectedContext() string

+ func (i *Instance) GetDetectedStatus() detection.DetectedStatus

+ func (i *Instance) GetEscapeParser() *analytics.EscapeCodeParser

+ func (i *Instance) GetLifecycleStatus() Status

+ func (i *Instance) GetRateLimitResetTime() time.Time

+ func (i *Instance) GetSessionGoal() *SessionGoalData

+ func (i *Instance) GetShellExitCh(shellID string) (<-chan struct{}, bool)

+ func (i *Instance) GetShellPTYReader(shellID string) (*os.File, error)

+ func (i *Instance) GetTotalBytesWritten() int64

+ func (i *Instance) HasGitHubPR() bool

+ func (i *Instance) Hibernate(ctx context.Context) error

+ func (i *Instance) Hibernated() bool

+ func (i *Instance) IsActive() bool

+ func (i *Instance) IsCreating() bool

+ func (i *Instance) IsHibernated() bool

+ func (i *Instance) IsPaused() bool

+ func (i *Instance) IsStopped() bool

+ func (i *Instance) ListShellsInMemory() []*Shell

+ func (i *Instance) ReconcileShells(ctx context.Context)

+ func (i *Instance) RegisterStatusChangeCallback(fn func(detection.DetectedStatus, string))

+ func (i *Instance) RestartShell(ctx context.Context, shellID string) error

+ func (i *Instance) ResumeFromHibernation(ctx context.Context) error

+ func (i *Instance) RunWithResume(ctx context.Context, message string) (string, error)

+ func (i *Instance) SendInputViaControlMode(ctx context.Context, data []byte) error

+ func (i *Instance) SetArchivedAt(t *time.Time)

+ func (i *Instance) SetArchivedAtIfNil(t time.Time) bool

+ func (i *Instance) SetArtifacts(blob *artifacts.SessionArtifactsBlob)

+ func (i *Instance) SetAutoYes(v bool)

+ func (i *Instance) SetAutonomousComplete(done bool)

+ func (i *Instance) SetAutonomousMode(mode bool, outcome string)

+ func (i *Instance) SetAutonomousTurn(turn, maxTurns int32)

+ func (i *Instance) SetCategory(category string)

+ func (i *Instance) SetClaudeConversationUUID(uuid string)

+ func (i *Instance) SetClaudeSessionIDSavedCallback(fn func())

+ func (i *Instance) SetCreationProgress(msg string)

+ func (i *Instance) SetGitHubPR(prURL string, prNumber int)

+ func (i *Instance) SetGitHubPRNumber(n int)

+ func (i *Instance) SetHibernateReason(reason string)

+ func (i *Instance) SetLastAddedToQueue(t time.Time)

+ func (i *Instance) SetLastPRStatusCheck(t time.Time)

+ func (i *Instance) SetMCPServerURL(url string)

+ func (i *Instance) SetPauseReason(reason string)

+ func (i *Instance) SetProgram(program string)

+ func (i *Instance) SetRateLimitCallbacks(onDetected func(sessionID string, resetTime time.Time), ...)

+ func (i *Instance) SetSessionGoalCached(g *SessionGoalData)

+ func (i *Instance) SetShellRepository(repo ShellRepository)

+ func (i *Instance) SetStatusChangeCallback(fn func(detection.DetectedStatus, string))

+ func (i *Instance) SetTitleDirect(title string)

+ func (i *Instance) SetWorkingDir(dir string)

+ func (i *Instance) Snapshot() *InstanceSnapshot

+ func (i *Instance) SpawnShell(ctx context.Context, req SpawnShellRequest) (*Shell, error)

+ func (i *Instance) StopShell(ctx context.Context, shellID string) error

+ func (i *Instance) VNCDisplayEnv() string

+ func (i *Instance) VNCManager() VNCProcessManager

+ type InstanceAcquirer interface

+ Acquire func(sessionID string) (*LiveInstance, ReleaseFunc, error)

type InstanceContext

+ GetStableID func() string

type InstanceData

+ ArchivedAt *time.Time

+ Hidden bool

+ InitialPrompt string

+ PauseReason string

+ WorkflowID string

+ func (d InstanceData) GetStableID() string

+ func (d InstanceData) MatchesID(id string) bool

type InstanceOptions

+ AllowedTools string

+ AppendSystemPrompt string

+ AutonomousMode bool

+ CLIFlags string

+ CreateIfMissing bool

+ EnvVars map[string]string

+ Hidden bool

+ InitialPrompt string

+ PermissionMode string

+ WorkflowID string

+ type InstanceReader interface

+ GetDiffStats func() *git.DiffStats

+ GetLifecycleStatus func() Status

+ GetStableID func() string

+ GetStatus func() int

+ GetTimeSinceLastMeaningfulOutput func() time.Duration

+ GetTitle func() string

+ GetWorkingDirectory func() string

+ IsActive func() bool

+ IsHibernated func() bool

+ IsPaused func() bool

+ IsStopped func() bool

+ type InstanceSnapshot struct

+ ActiveCheckpoint string

+ AllowedTools string

+ AppendSystemPrompt string

+ ArchivedAt *time.Time

+ Artifacts *artifacts.SessionArtifactsBlob

+ AutoYes bool

+ Autonomous AutonomousModeState

+ Branch string

+ CLIFlags string

+ Category string

+ Checkpoints CheckpointList

+ CreatedAt time.Time

+ EnvVars map[string]string

+ ExternalMetadata *ExternalInstanceMetadata

+ ForkedFromID string

+ GitHub GitHubIntegration

+ Height int

+ Hidden bool

+ HistoryFilePath string

+ ID string

+ InitialPrompt string

+ InstanceType InstanceType

+ IsExpanded bool

+ IsManaged bool

+ MCPServerURL string

+ OneShot bool

+ Path string

+ PauseReason string

+ PermissionMode string

+ Permissions InstancePermissions

+ Program string

+ ProjectID string

+ Prompt string

+ RateLimitAutoResume *bool

+ SessionType SessionType

+ Status Status

+ Tags []string

+ Title string

+ TmuxPrefix string

+ TmuxServerSocket string

+ UUID string

+ UpdatedAt time.Time

+ Width int

+ WorkflowID string

+ WorkingDir string

+ type ItemSessionData struct

+ AcSnapshot string

+ ItemID string

+ SessionRole string

+ SessionUUID string

+ TriageResult string

+ type ItemSourceData struct

+ Config string

+ CreatedAt time.Time

+ DisplayName string

+ Enabled bool

+ ID string

+ LastSyncedAt *time.Time

+ PluginID string

+ TokenConfigured bool

+ UpdatedAt time.Time

+ type ItemSourcePlugin interface

+ Fetch func(ctx context.Context, config PluginConfig, cursor string) ([]ExternalItem, string, error)

+ MapToBacklogItem func(item ExternalItem, sourceID string) BacklogItemData

+ PluginID func() string

+ type ItemSourceUpdate struct

+ Config *string

+ DisplayName *string

+ Enabled *bool

+ type LiveInstance struct

+ func NewLiveInstance(inst *Instance) *LiveInstance

+ func (l *LiveInstance) Stop()

+ type LiveInstancesProvider interface

+ GetInstances func() []*Instance

+ type Locked struct

+ func (l *Locked[T]) Read(fn func(T))

+ func (l *Locked[T]) Write(fn func(*T))

+ type MemoryCacheReader interface

+ GetCachedRSSMB func(sessionUUID string) int64

+ SystemMemoryPct func() (float64, error)

+ type NativeProcessManager struct

+ func NewNativeProcessManager(_ ProcessManagerOptions) *NativeProcessManager

+ func NewNativeProcessManager(opts ProcessManagerOptions) *NativeProcessManager

+ func (n *NativeProcessManager) Attach() (chan struct{}, error)

+ func (n *NativeProcessManager) CapturePaneContent() (string, error)

+ func (n *NativeProcessManager) CapturePaneContentRaw() (string, error)

+ func (n *NativeProcessManager) CapturePaneContentWithOptions(_, _ string) (string, error)

+ func (n *NativeProcessManager) CaptureViewport(_ int) (string, error)

+ func (n *NativeProcessManager) Close() error

+ func (n *NativeProcessManager) DetachSafely() error

+ func (n *NativeProcessManager) FilterBanners(content string) (string, int)

+ func (n *NativeProcessManager) GetCurrentWorkingDirectory() (string, error)

+ func (n *NativeProcessManager) GetCursorPosition() (x, y int, err error)

+ func (n *NativeProcessManager) GetPTY() (*os.File, error)

+ func (n *NativeProcessManager) GetPaneDimensions() (width, height int, err error)

+ func (n *NativeProcessManager) GetPanePID() (int32, error)

+ func (n *NativeProcessManager) GetSessionIdentifier() string

+ func (n *NativeProcessManager) HasMeaningfulContent(_ string) bool

+ func (n *NativeProcessManager) HasSession() bool

+ func (n *NativeProcessManager) HasUpdated() (bool, bool, string)

+ func (n *NativeProcessManager) HasUpdated() (updated bool, hasPrompt bool, content string)

+ func (n *NativeProcessManager) IsAlive() bool

+ func (n *NativeProcessManager) RefreshClient() error

+ func (n *NativeProcessManager) ResetExitOnce()

+ func (n *NativeProcessManager) RestoreWithWorkDir(_ string) error

+ func (n *NativeProcessManager) SendInputViaControlMode(_ context.Context, _ []byte) error

+ func (n *NativeProcessManager) SendInputViaControlMode(_ context.Context, data []byte) error

+ func (n *NativeProcessManager) SendKeys(_ string) (int, error)

+ func (n *NativeProcessManager) SendKeys(keys string) (int, error)

+ func (n *NativeProcessManager) SendPromptWithEnter(_ string) error

+ func (n *NativeProcessManager) SendPromptWithEnter(prompt string) error

+ func (n *NativeProcessManager) SetDetachedSize(_, _ int, _ string) error

+ func (n *NativeProcessManager) SetDetachedSize(width, height int, _ string) error

+ func (n *NativeProcessManager) SetOnExitCallback(_ func(string))

+ func (n *NativeProcessManager) SetOnExitCallback(fn func(string))

+ func (n *NativeProcessManager) SetWindowSize(_, _ int) error

+ func (n *NativeProcessManager) SetWindowSize(cols, rows int) error

+ func (n *NativeProcessManager) Start(_ string) error

+ func (n *NativeProcessManager) Start(dir string) error

+ func (n *NativeProcessManager) StartControlMode() error

+ func (n *NativeProcessManager) StopControlMode() error

+ func (n *NativeProcessManager) SubscribeToControlModeUpdates() (string, chan []byte)

+ func (n *NativeProcessManager) TapEnter() error

+ func (n *NativeProcessManager) UnsubscribeFromControlModeUpdates(_ string)

+ func (n *NativeProcessManager) UnsubscribeFromControlModeUpdates(id string)

type PRStatusPoller

+ func (p *PRStatusPoller) GetInstances() []*Instance

type PRStatusPollerConfig

+ NoPRBackoff time.Duration

type PTYAccess

+ func (p *PTYAccess) GetFile() (*os.File, bool)

+ type PTYSubscriber interface — darwin/amd64, js/wasm, linux/amd64

+ Chan func() <-chan []byte

+ Close func()

+ Push func(data []byte) error

+ type PluginConfig struct

+ Raw string

+ type PluginRegistry struct

+ func NewDefaultRegistry() *PluginRegistry

+ func NewPluginRegistry() *PluginRegistry

+ func (r *PluginRegistry) Get(id string) (ItemSourcePlugin, bool)

+ func (r *PluginRegistry) Register(p ItemSourcePlugin)

+ type ProcessManager interface

+ Attach func() (chan struct{}, error)

+ CapturePaneContent func() (string, error)

+ CapturePaneContentRaw func() (string, error)

+ CapturePaneContentWithOptions func(startLine, endLine string) (string, error)

+ CaptureViewport func(lines int) (string, error)

+ Close func() error

+ DetachSafely func() error

+ FilterBanners func(content string) (string, int)

+ GetCurrentWorkingDirectory func() (string, error)

+ GetCursorPosition func() (x, y int, err error)

+ GetPTY func() (*os.File, error)

+ GetPaneDimensions func() (width, height int, err error)

+ GetPanePID func() (int32, error)

+ GetSessionIdentifier func() string

+ HasMeaningfulContent func(content string) bool

+ HasSession func() bool

+ HasUpdated func() (updated bool, hasPrompt bool, content string)

+ IsAlive func() bool

+ RefreshClient func() error

+ ResetExitOnce func()

+ RestoreWithWorkDir func(workDir string) error

+ SendInputViaControlMode func(ctx context.Context, data []byte) error

+ SendKeys func(keys string) (int, error)

+ SendPromptWithEnter func(prompt string) error

+ SetDetachedSize func(width, height int, instanceTitle string) error

+ SetOnExitCallback func(fn func(string))

+ SetWindowSize func(cols, rows int) error

+ Start func(dir string) error

+ StartControlMode func() error

+ StopControlMode func() error

+ SubscribeToControlModeUpdates func() (string, chan []byte)

+ TapEnter func() error

+ UnsubscribeFromControlModeUpdates func(id string)

+ func NewProcessManager(_ context.Context, defaultBackend ProcessManagerBackend, ...) ProcessManager

+ type ProcessManagerBackend string

+ const BackendNative

+ const BackendTmux

+ type ProcessManagerOptions struct

+ Args []string

+ Prefix string

+ Program string

+ ServerSocket string

+ SessionName string

+ type Registry struct

+ func NewRegistry(storage *Storage, onConstruct func(*LiveInstance)) *Registry

+ func (r *Registry) Acquire(sessionID string) (*LiveInstance, ReleaseFunc, error)

+ func (r *Registry) AcquireAll() ([]*LiveInstance, ReleaseFunc, error)

+ func (r *Registry) Count() int

+ func (r *Registry) ForceRelease(sessionID string)

+ func (r *Registry) List() []*LiveInstance

+ func (r *Registry) Register(instance *LiveInstance) (ReleaseFunc, error)

+ func (r *Registry) Shutdown()

+ func (r *Registry) Storage() *Storage

+ func (r *Registry) WithInstance(ctx context.Context, sessionID string, fn func(*LiveInstance) error) error

+ type RegistryInspector interface

+ Count func() int

+ List func() []*LiveInstance

+ type ReleaseFunc func()

type Repository

+ ArchiveBacklogItem func(ctx context.Context, id string) (*BacklogItemData, error)

+ CreateBacklogItem func(ctx context.Context, data BacklogItemData) (*BacklogItemData, error)

+ CreateItemSource func(ctx context.Context, data ItemSourceData) (*ItemSourceData, error)

+ DeleteBacklogItem func(ctx context.Context, id string) error

+ DeleteItemSource func(ctx context.Context, id string) error

+ GetBacklogItem func(ctx context.Context, id string) (*BacklogItemData, error)

+ GetSubcommandBreakdown func(ctx context.Context, program string, since time.Time) ([]SubcommandDecisionCount, error)

+ GetSubcommandTrend func(ctx context.Context, program, subcommand string, since time.Time) ([]AnalyticsData, error)

+ ListAnalyticsByProgramSince func(ctx context.Context, program string, since time.Time, limit int) ([]AnalyticsData, error)

+ ListAnalyticsSince func(ctx context.Context, since time.Time, limit int) ([]AnalyticsData, error)

+ ListBacklogItems func(ctx context.Context, filter BacklogItemFilter) ([]BacklogItemData, error)

+ ListItemSources func(ctx context.Context) ([]ItemSourceData, error)

+ ListRecentCommandsByProgram func(ctx context.Context, program, subcommand string, since time.Time, n int) ([]string, error)

+ TransitionBacklogItemStatus func(ctx context.Context, id string, toStatus BacklogStatus, ...) (*BacklogItemData, error)

+ UpdateBacklogItem func(ctx context.Context, id string, update BacklogItemUpdate, ...) (*BacklogItemData, error)

+ UpdateItemSource func(ctx context.Context, id string, update ItemSourceUpdate) (*ItemSourceData, error)

+ UpdateLastAcknowledged func(ctx context.Context, title string, t time.Time) error

+ UpdateLastAddedToQueue func(ctx context.Context, title string, t time.Time) error

+ UpdateLastViewed func(ctx context.Context, title string, t time.Time) error

+ UpdateReviewQueueState func(ctx context.Context, title string, ...) error

type ResponseStream

+ func (rs *ResponseStream) GetEscapeParser() *analytics.EscapeCodeParser

+ func (rs *ResponseStream) GetTotalBytesWritten() int64

+ func (rs *ResponseStream) SetStableSessionID(id string)

+ type ReviewGateSpawner interface

+ SpawnReviewSession func(ctx context.Context, item *ent.BacklogItem, itemSessionID string, ...) (*Instance, error)

+ type ReviewQueueWriter interface

+ Add func(item *ReviewItem) bool

type ReviewState

+ func (rs *ReviewState) SyncAtomicTimestamps()

+ type ReviewVerdictData struct

+ DiffHash string

+ DiffTokenCount int

+ DiffTruncated bool

+ ItemSessionID string

+ OverallOutcome string

+ OverrideAt *time.Time

+ OverrideBy string

+ OverrideReason string

+ PerCriterion string

+ PromptHash string

+ Summary string

+ type SessionGoalData struct

+ Goal string

+ SessionUUID string

+ SetBy string

+ Status string

+ Tasks []TaskNode

+ UUID string

+ UpdatedAt time.Time

+ func (g *SessionGoalData) TasksDone() int

+ func (g *SessionGoalData) TasksTotal() int

+ type Shell struct

+ Command string

+ ExitCode int

+ ID string

+ Name string

+ OrderIndex int

+ StartedAt time.Time

+ Status ShellStatus

+ TmuxSessionName string

+ WorkingDir string

+ type ShellData struct

+ Command string

+ ID string

+ Name string

+ OrderIndex int

+ TmuxSessionName string

+ WorkingDir string

+ type ShellHandle interface

+ Close func() error

+ GetPTY func() (*os.File, error)

+ Resize func(cols, rows int) error

+ type ShellRegistry struct

+ func (r *ShellRegistry) Add(sh *Shell, handle *tmux.ShellTmuxHandle)

+ func (r *ShellRegistry) AddStopped(sh *Shell)

+ func (r *ShellRegistry) Get(shellID string) (*Shell, bool)

+ func (r *ShellRegistry) GetBoth(shellID string) (*Shell, *tmux.ShellTmuxHandle, bool)

+ func (r *ShellRegistry) GetHandle(shellID string) (*tmux.ShellTmuxHandle, bool)

+ func (r *ShellRegistry) Len() int

+ func (r *ShellRegistry) List() []*Shell

+ func (r *ShellRegistry) Remove(shellID string)

+ func (r *ShellRegistry) SetHandle(shellID string, handle *tmux.ShellTmuxHandle)

+ func (r *ShellRegistry) UpdateForRestart(shellID string, newHandle *tmux.ShellTmuxHandle, newSessionName string, ...)

+ func (r *ShellRegistry) UpdateStatus(shellID string, status ShellStatus, exitCode *int) bool

+ type ShellRepository interface

+ CreateShell func(ctx context.Context, sessionTitle string, data ShellData) (*ent.Shell, error)

+ DeleteShell func(ctx context.Context, shellID string) error

+ ListShells func(ctx context.Context, sessionTitle string) ([]*ent.Shell, error)

+ UpdateShellStatus func(ctx context.Context, shellID, status string, exitCode *int) error

+ type ShellStatus string

+ const ShellStatusError

+ const ShellStatusRunning

+ const ShellStatusStopped

+ type SpawnShellRequest struct

+ Command string

+ Name string

+ WorkingDir string

+ type StartupScanner struct

+ func NewStartupScanner(statusManager StatusProvider, contentProvider ContentProvider) *StartupScanner

+ func (ss *StartupScanner) Scan(instances []*Instance, queue ReviewQueueWriter) int

type Status

+ const Active

+ const Hibernated

+ const Restoring

+ type StatusChangeListener func(newStatus detection.DetectedStatus, sessionName string)

+ type StatusDeterminer interface

+ Determine func(inst *Instance, content string, statusInfo InstanceStatusInfo, ...) DetectionResult

+ type StatusProvider interface

+ GetController func(instanceTitle string) (*ClaudeController, bool)

+ GetStatus func(inst *Instance) InstanceStatusInfo

type Storage

+ func (s *Storage) ArchiveBacklogItem(ctx context.Context, id string) (*BacklogItemData, error)

+ func (s *Storage) CreateBacklogItem(ctx context.Context, data BacklogItemData) (*BacklogItemData, error)

+ func (s *Storage) CreateItemSession(ctx context.Context, data ItemSessionData) (*ent.ItemSession, error)

+ func (s *Storage) CreateItemSessionWithVerdict(ctx context.Context, isData ItemSessionData, verdict ReviewVerdictData) (*ent.ItemSession, *ent.ReviewVerdict, error)

+ func (s *Storage) CreateItemSource(ctx context.Context, data ItemSourceData) (*ItemSourceData, error)

+ func (s *Storage) CreateSourceSyncEvent(ctx context.Context, sourceID, cursorAfter string, ...) error

+ func (s *Storage) DeleteBacklogItem(ctx context.Context, id string) error

+ func (s *Storage) DeleteItemSource(ctx context.Context, id string) error

+ func (s *Storage) FindInstanceDataByID(id string) (*InstanceData, error)

+ func (s *Storage) GetAllInstanceArtifacts() (map[string]string, error)

+ func (s *Storage) GetBacklogItem(ctx context.Context, id string) (*BacklogItemData, error)

+ func (s *Storage) GetEntClient() *ent.Client

+ func (s *Storage) GetInstanceArtifacts(title string) (string, error)

+ func (s *Storage) GetItemSession(ctx context.Context, id string) (*ent.ItemSession, error)

+ func (s *Storage) GetItemSessionBySessionAndItem(ctx context.Context, sessionUUID string, itemID string) (*ent.ItemSession, error)

+ func (s *Storage) GetItemSessionBySessionUUID(ctx context.Context, sessionUUID string) (*ent.ItemSession, error)

+ func (s *Storage) GetMostRecentReviewVerdictForItem(ctx context.Context, itemID string) (string, error)

+ func (s *Storage) GetSessionGoal(ctx context.Context, sessionUUID string) (*SessionGoalData, error)

+ func (s *Storage) GetSubcommandBreakdown(ctx context.Context, program string, since time.Time) ([]SubcommandDecisionCount, error)

+ func (s *Storage) GetSubcommandTrend(ctx context.Context, program, subcommand string, since time.Time) ([]AnalyticsData, error)

+ func (s *Storage) ListAnalyticsByProgramSince(ctx context.Context, program string, since time.Time, limit int) ([]AnalyticsData, error)

+ func (s *Storage) ListAnalyticsSince(ctx context.Context, since time.Time, limit int) ([]AnalyticsData, error)

+ func (s *Storage) ListBacklogItems(ctx context.Context, filter BacklogItemFilter) ([]BacklogItemData, error)

+ func (s *Storage) ListInstanceIDs() ([]string, error)

+ func (s *Storage) ListItemSessions(ctx context.Context, itemID string) ([]*ent.ItemSession, error)

+ func (s *Storage) ListItemSources(ctx context.Context) ([]ItemSourceData, error)

+ func (s *Storage) ListRecentCommandsByProgram(ctx context.Context, program, subcommand string, since time.Time, n int) ([]string, error)

+ func (s *Storage) ListSessionRecords() []tokens.SessionRecord

+ func (s *Storage) ListSourceSyncEvents(ctx context.Context, sourceID string) (events []*ent.SourceSyncEvent, truncated bool, err error)

+ func (s *Storage) SaveReviewVerdict(ctx context.Context, itemSessionID string, verdict ReviewVerdictData) (*ent.ReviewVerdict, error)

+ func (s *Storage) SetSessionGoal(ctx context.Context, sessionUUID string, goal string, status string, ...) (*SessionGoalData, error)

+ func (s *Storage) TransitionBacklogItemStatus(ctx context.Context, id string, toStatus BacklogStatus, ...) (*BacklogItemData, error)

+ func (s *Storage) UpdateAcCriterionStatus(ctx context.Context, itemID string, criterionIndex int, status string, ...) error

+ func (s *Storage) UpdateBacklogItem(ctx context.Context, id string, update BacklogItemUpdate, ...) (*BacklogItemData, error)

+ func (s *Storage) UpdateInstanceArtifacts(title string, blob string) error

+ func (s *Storage) UpdateItemSessionEnded(ctx context.Context, id string, endedAt time.Time) error

+ func (s *Storage) UpdateItemSessionSessionUUID(ctx context.Context, id string, sessionUUID string) error

+ func (s *Storage) UpdateItemSessionStarted(ctx context.Context, id string, startedAt time.Time) error

+ func (s *Storage) UpdateItemSessionTriageResult(ctx context.Context, id string, triageResult string) error

+ func (s *Storage) UpdateItemSource(ctx context.Context, id string, update ItemSourceUpdate) (*ItemSourceData, error)

+ func (s *Storage) UpdateSessionTaskStatus(ctx context.Context, sessionUUID string, taskID string, newStatus string) (*SessionGoalData, error)

+ type SubcommandDecisionCount struct

+ Count int

+ Decision string

+ Subcommand string

+ type SyncLoop struct

+ func NewSyncLoop(storage *Storage, registry *PluginRegistry) *SyncLoop

+ func NewSyncLoopWithKeyProvider(storage *Storage, registry *PluginRegistry, keyFunc func() ([]byte, error)) *SyncLoop

+ func (sl *SyncLoop) Start(ctx context.Context)

+ func (sl *SyncLoop) Stop()

+ func (sl *SyncLoop) SyncByID(ctx context.Context, sourceID string) error

+ func (sl *SyncLoop) SyncOne(ctx context.Context, source *ent.ItemSource) error

+ func (sl *SyncLoop) TestDecryptConfigToken(raw string) (string, error)

+ type TaskNode struct

+ Children []TaskNode

+ ID string

+ Status string

+ Title string

+ func DecodeTasks(s string) ([]TaskNode, error)

+ type TmuxBackend struct

+ func NewTmuxBackend(mgr TmuxManager) *TmuxBackend

+ func (b *TmuxBackend) Attach() (chan struct{}, error)

+ func (b *TmuxBackend) CapturePaneContent() (string, error)

+ func (b *TmuxBackend) CapturePaneContentRaw() (string, error)

+ func (b *TmuxBackend) CapturePaneContentWithOptions(start, end string) (string, error)

+ func (b *TmuxBackend) CaptureViewport(lines int) (string, error)

+ func (b *TmuxBackend) Close() error

+ func (b *TmuxBackend) DetachSafely() error

+ func (b *TmuxBackend) FilterBanners(content string) (string, int)

+ func (b *TmuxBackend) GetCurrentWorkingDirectory() (string, error)

+ func (b *TmuxBackend) GetCursorPosition() (x, y int, err error)

+ func (b *TmuxBackend) GetPTY() (*os.File, error)

+ func (b *TmuxBackend) GetPaneDimensions() (width, height int, err error)

+ func (b *TmuxBackend) GetPanePID() (int32, error)

+ func (b *TmuxBackend) GetSessionIdentifier() string

+ func (b *TmuxBackend) HasMeaningfulContent(content string) bool

+ func (b *TmuxBackend) HasSession() bool

+ func (b *TmuxBackend) HasUpdated() (updated bool, hasPrompt bool, content string)

+ func (b *TmuxBackend) IsAlive() bool

+ func (b *TmuxBackend) RefreshClient() error

+ func (b *TmuxBackend) ResetExitOnce()

+ func (b *TmuxBackend) RestoreWithWorkDir(w string) error

+ func (b *TmuxBackend) SendInputViaControlMode(ctx context.Context, data []byte) error

+ func (b *TmuxBackend) SendKeys(keys string) (int, error)

+ func (b *TmuxBackend) SendPromptWithEnter(p string) error

+ func (b *TmuxBackend) SetDetachedSize(w, h int, title string) error

+ func (b *TmuxBackend) SetOnExitCallback(fn func(string))

+ func (b *TmuxBackend) SetWindowSize(cols, rows int) error

+ func (b *TmuxBackend) Start(dir string) error

+ func (b *TmuxBackend) StartControlMode() error

+ func (b *TmuxBackend) StopControlMode() error

+ func (b *TmuxBackend) SubscribeToControlModeUpdates() (string, chan []byte)

+ func (b *TmuxBackend) TapEnter() error

+ func (b *TmuxBackend) TmuxManager() TmuxManager

+ func (b *TmuxBackend) UnsubscribeFromControlModeUpdates(id string)

type TmuxManager

+ SendInputViaControlMode func(ctx context.Context, data []byte) error

type TmuxProcessManager

+ func (tm *TmuxProcessManager) SendInputViaControlMode(ctx context.Context, data []byte) error

+ type TransitionDef struct

+ After func(ctx context.Context, i *Instance)

+ From Status

+ Guard func(ctx context.Context, i *Instance) error

+ To Status

+ type TriageSuggestion struct

+ Rationale string

+ Text string

+ type TriageTask struct

+ Category string

+ Estimate string

+ Text string

+ type TurnCallback func(turn, maxTurns int, prompt string)

+ type VNCProcessManager = vnc.VNCProcessManager

+ type WorkflowCreateInput struct

+ AgentType string

+ ArchiveAfterHours *int

+ Command string

+ CronEnabled bool

+ CronExpression string

+ Description string

+ InputTemplate string

+ KeepSessions *int

+ Model string

+ Name string

+ SessionType string

+ Slug string

+ TargetDirectory string

+ type WorkflowEngine interface

+ AllowedTransitions func(from BacklogStatus) []BacklogStatus

+ CanTransition func(from, to BacklogStatus) bool

+ ValidateGates func(item BacklogItemTransitionInput, to BacklogStatus) error

+ type WorkflowRepository interface

+ Create func(ctx context.Context, w WorkflowCreateInput) (*ent.Workflow, error)

+ Delete func(ctx context.Context, id uuid.UUID) error

+ GetByID func(ctx context.Context, id uuid.UUID) (*ent.Workflow, error)

+ GetBySlug func(ctx context.Context, slug string) (*ent.Workflow, error)

+ ListAll func(ctx context.Context) ([]*ent.Workflow, error)

+ ListEnabled func(ctx context.Context) ([]*ent.Workflow, error)

+ Update func(ctx context.Context, id uuid.UUID, w WorkflowUpdateInput) (*ent.Workflow, error)

+ type WorkflowUpdateInput struct

+ AgentType *string

+ ArchiveAfterHours *int

+ Command *string

+ CronEnabled *bool

+ CronExpression *string

+ Description *string

+ InputTemplate *string

+ KeepSessions *int

+ Model *string

+ Name *string

+ SessionType *string

+ TargetDirectory *string

+ type WorkspacePath string

+ func NewWorkspacePath(s string) (WorkspacePath, error)

+ type WorktreePRPoller struct

+ func NewWorktreePRPoller(etagCache *github.ETagCache, prPoller *PRStatusPoller) *WorktreePRPoller

+ func NewWorktreePRPollerWithConfig(etagCache *github.ETagCache, prPoller *PRStatusPoller, ...) *WorktreePRPoller

+ func (p *WorktreePRPoller) GetPRData(repoPath, branch string) *github.PRInfo

+ func (p *WorktreePRPoller) SetOnUpdated(fn func(repoPath, branch string, info *github.PRInfo))

+ func (p *WorktreePRPoller) SetSource(src WorktreeSource)

+ func (p *WorktreePRPoller) Start(ctx context.Context)

+ func (p *WorktreePRPoller) Stop()

+ type WorktreePRPollerConfig struct

+ AuthCacheDuration time.Duration

+ CallTimeout time.Duration

+ PollInterval time.Duration

+ func DefaultWorktreePRPollerConfig() WorktreePRPollerConfig

+ type WorktreeScanItem struct

+ Branch string

+ RepoPath string

+ WorktreePath string

+ type WorktreeSource interface

+ GetWorktrees func() []WorktreeScanItem

+ ScanDone func() <-chan time.Time

v1.24.0

Apr 30, 2026

Changes in this version

type ReviewQueuePoller

+ func (rqp *ReviewQueuePoller) ForceReconcile()

v1.23.1

Apr 28, 2026

Changes in this version

type Instance

+ func (i *Instance) RecoverFromStopped()

+ func (i *Instance) TmuxSessionExists() bool

type InstanceData

+ MCPServerURL string

v1.23.0

Apr 27, 2026

Changes in this version

type EntRepository

+ func (r *EntRepository) AssignSessionsToProject(ctx context.Context, projectName string, sessionTitles []string) error

+ func (r *EntRepository) CreateProject(ctx context.Context, data ProjectData) (*ProjectData, error)

+ func (r *EntRepository) DeleteProject(ctx context.Context, name string) error

+ func (r *EntRepository) ListProjects(ctx context.Context) ([]ProjectData, error)

+ func (r *EntRepository) UpdateProject(ctx context.Context, data ProjectData) (*ProjectData, error)

type Instance

+ OneShot bool

+ ProjectID string

type InstanceData

+ OneShot bool

+ ProjectID string

type InstanceOptions

+ OneShot bool

+ ProjectID string

+ type ProjectData struct

+ CreatedAt time.Time

+ Description string

+ ID string

+ Name string

+ UpdatedAt time.Time

type Repository

+ AssignSessionsToProject func(ctx context.Context, projectName string, sessionTitles []string) error

+ CreateProject func(ctx context.Context, data ProjectData) (*ProjectData, error)

+ DeleteProject func(ctx context.Context, name string) error

+ ListProjects func(ctx context.Context) ([]ProjectData, error)

+ UpdateProject func(ctx context.Context, data ProjectData) (*ProjectData, error)

type ReviewQueuePoller

+ func (rqp *ReviewQueuePoller) SetActivityChannel(ch <-chan struct{})

type ReviewQueuePollerConfig

+ SlowPollInterval time.Duration

type Storage

+ func (s *Storage) AssignSessionsToProject(ctx context.Context, projectName string, sessionTitles []string) error

+ func (s *Storage) CreateProject(ctx context.Context, data ProjectData) (*ProjectData, error)

+ func (s *Storage) DeleteProject(ctx context.Context, name string) error

+ func (s *Storage) ListProjects(ctx context.Context) ([]ProjectData, error)

+ func (s *Storage) UpdateProject(ctx context.Context, data ProjectData) (*ProjectData, error)

v1.22.0

Apr 26, 2026

v1.21.0

Apr 26, 2026

v1.20.1

Apr 25, 2026

v1.20.0

Apr 24, 2026

Changes in this version

type ClaudeSessionData

+ ConversationUUID string

+ SquadSessionID string

v1.19.0

Apr 23, 2026

v1.18.0

Apr 23, 2026

Changes in this version

type Instance

+ LaunchCommand string

+ func (i *Instance) MatchesID(id string) bool

type InstanceData

+ LaunchCommand string

type InstanceStore

+ ListInstanceData func() ([]InstanceData, error)

+ type PTYDiscoveryOption func(*PTYDiscovery)

+ func WithSessionLister(l tmux.SessionLister) PTYDiscoveryOption

type Storage

+ func (s *Storage) ListInstanceData() ([]InstanceData, error)

+ func (s *Storage) UpdateInstanceAcknowledged(title string) error

v1.17.0

Apr 21, 2026

Changes in this version

type Instance

+ MCPServerURL string

type InstanceOptions

+ MCPServerURL string

v1.16.0

Apr 21, 2026

Changes in this version

type Instance

+ ID string

v1.15.0

Apr 21, 2026

Changes in this version

type ClaudeController

+ func (cc *ClaudeController) GetExitContent() []byte

+ func (cc *ClaudeController) SetOnEOFCallback(fn func())

+ type GitManager interface

+ Cleanup func() error

+ ClearDiffStats func()

+ CommitChanges func(commitMsg string) error

+ ComputeDiff func() *git.DiffStats

+ ComputeDiffIfReady func() (stats *git.DiffStats, needsPause bool)

+ GetBaseCommitSHA func() string

+ GetBranchName func() string

+ GetCurrentCommitSHA func() (string, error)

+ GetDiffStats func() *git.DiffStats

+ GetRepoName func() string

+ GetRepoPath func() string

+ GetWorktree func() *git.GitWorktree

+ GetWorktreePath func() string

+ HasWorktree func() bool

+ IsBranchCheckedOut func() (bool, error)

+ IsDirty func() (bool, error)

+ OpenBranchURL func() error

+ Prune func() error

+ PushChanges func(commitMsg string, open bool) error

+ Remove func() error

+ SetDiffStats func(*git.DiffStats)

+ SetWorktree func(*git.GitWorktree)

+ Setup func() error

+ UpdateDiffStats func()

type Instance

+ func (i *Instance) GetExitContent() []byte

+ func (i *Instance) GetTmuxSessionName() string

+ func (i *Instance) RegisterLifecycleListener(l LifecycleListener)

+ func (i *Instance) StartControlMode() error

+ func (i *Instance) StopControlMode() error

+ func (i *Instance) SubscribeControlModeUpdates() (string, <-chan []byte)

+ func (i *Instance) UnsubscribeControlModeUpdates(id string)

+ type LifecycleEvent int

+ const EventExited

+ const EventStarted

+ type LifecycleListener interface

+ OnLifecycleEvent func(event LifecycleEvent, reason string)

type ResponseStream

+ OnEOF func()

+ func (rs *ResponseStream) GetExitTail() []byte

type ReviewQueuePollerConfig

+ ReconcileInterval time.Duration

+ type TmuxManager interface

+ Attach func() (chan struct{}, error)

+ CapturePaneContent func() (string, error)

+ CapturePaneContentRaw func() (string, error)

+ CapturePaneContentWithOptions func(startLine, endLine string) (string, error)

+ CaptureViewport func(lines int) (string, error)

+ Close func() error

+ DetachSafely func() error

+ DoesSessionExist func() bool

+ FilterBanners func(content string) (string, int)

+ GetCursorPosition func() (x, y int, err error)

+ GetPTY func() (*os.File, error)

+ GetPaneDimensions func() (width, height int, err error)

+ GetPanePID func() (int32, error)

+ GetTmuxSessionName func() string

+ HasMeaningfulContent func(content string) bool

+ HasSession func() bool

+ HasUpdated func() (updated bool, hasPrompt bool)

+ IsAlive func() bool

+ RefreshClient func() error

+ ResetExitOnce func()

+ RestoreWithWorkDir func(workDir string) error

+ SendKeys func(keys string) (int, error)

+ SendPromptWithEnter func(prompt string) error

+ Session func() *tmux.TmuxSession

+ SetDetachedSize func(width, height int, instanceTitle string) error

+ SetOnExitCallback func(fn func(string))

+ SetSession func(*tmux.TmuxSession)

+ SetWindowSize func(cols, rows int) error

+ Start func(dir string) error

+ StartControlMode func() error

+ StopControlMode func() error

+ SubscribeToControlModeUpdates func() (string, chan []byte)

+ TapEnter func() error

+ UnsubscribeFromControlModeUpdates func(id string)

type TmuxProcessManager

+ func (tm *TmuxProcessManager) GetTmuxSessionName() string

+ func (tm *TmuxProcessManager) ResetExitOnce()

+ func (tm *TmuxProcessManager) SetOnExitCallback(fn func(string))

+ func (tm *TmuxProcessManager) StartControlMode() error

+ func (tm *TmuxProcessManager) StopControlMode() error

+ func (tm *TmuxProcessManager) SubscribeToControlModeUpdates() (string, chan []byte)

+ func (tm *TmuxProcessManager) UnsubscribeFromControlModeUpdates(id string)

v1.14.0

Apr 17, 2026

Changes in this version

type Instance

+ UUID string

+ func (i *Instance) GetStableID() string

type InstanceData

+ UUID string

v1.13.3

Apr 16, 2026

v1.13.2

Apr 16, 2026

v1.13.1

Apr 16, 2026

v1.13.0

Apr 16, 2026

v1.12.1

Apr 15, 2026

v1.12.0

Apr 14, 2026

Changes in this version

+ func ClaudeProjectDirName(projectPath string) string

+ type AnalyticsData struct

+ Alternative string

+ ApprovalID string

+ CommandCategory string

+ CommandPreview string

+ CommandProgram string

+ CommandSubcategory string

+ CreatedAt time.Time

+ Cwd string

+ Decision string

+ DurationMs int64

+ ID string

+ PythonImports []string

+ Reason string

+ RiskLevel string

+ RuleID string

+ RuleName string

+ SessionID string

+ ToolName string

+ type ApprovalRuleData struct

+ Alternative string

+ CommandPattern string

+ CreatedAt time.Time

+ Decision int

+ Enabled bool

+ FilePattern string

+ ID string

+ Name string

+ Priority int

+ Reason string

+ RiskLevel int

+ Source string

+ ToolCategory string

+ ToolName string

+ ToolPattern string

+ UpdatedAt time.Time

type ClaudeController

+ func (cc *ClaudeController) GetRateLimitState() ratelimit.RateLimitState

+ func (cc *ClaudeController) IsRateLimitEnabled() bool

+ func (cc *ClaudeController) SetRateLimitEnabled(enabled bool)

type EntRepository

+ func (r *EntRepository) AllRules(ctx context.Context) ([]ApprovalRuleData, error)

+ func (r *EntRepository) DeleteRule(ctx context.Context, id string) error

+ func (r *EntRepository) ListAnalytics(ctx context.Context, limit int) ([]AnalyticsData, error)

+ func (r *EntRepository) RecordAnalytics(ctx context.Context, data AnalyticsData) error

+ func (r *EntRepository) UpsertRule(ctx context.Context, data ApprovalRuleData) error

type HistoryFileDetector

+ func NewHistoryFileDetectorWithHomeDir(inspector ProcessFileInspector, homeDir string) *HistoryFileDetector

+ func (d *HistoryFileDetector) DetectByPath(projectPath string) (*HistoryFileInfo, error)

type Instance

+ GitHubApprovedCount int

+ GitHubChangesReqCount int

+ GitHubCheckConclusion string

+ GitHubIsFork bool

+ GitHubPRIsDraft bool

+ GitHubPRPriority string

+ GitHubPRState string

+ GitHubPRStatusTerminal bool

+ LastPRStatusCheck time.Time

+ func (i *Instance) GetRateLimitState() int

+ func (i *Instance) GetStatus() int

+ func (i *Instance) IsRateLimitEnabled() bool

+ func (i *Instance) SetRateLimitEnabled(enabled bool)

+ func (i *Instance) UpdatePRStatus(state, priority, checkConclusion string, approvedCount, changesReqCount int, ...)

+ func (i *Instance) Workspace() Workspace

type InstanceContext

+ GetStatus func() int

+ WriteToPTY func(data []byte) (int, error)

type InstanceData

+ GitHubApprovedCount int

+ GitHubChangesReqCount int

+ GitHubCheckConclusion string

+ GitHubIsFork bool

+ GitHubPRIsDraft bool

+ GitHubPRPriority string

+ GitHubPRState string

+ GitHubPRStatusTerminal bool

+ LastPRStatusCheck time.Time

+ type PRStatusPoller struct

+ func NewPRStatusPoller(storage *Storage) *PRStatusPoller

+ func NewPRStatusPollerWithConfig(storage *Storage, config PRStatusPollerConfig) *PRStatusPoller

+ func (p *PRStatusPoller) AddInstance(inst *Instance)

+ func (p *PRStatusPoller) RemoveInstance(title string)

+ func (p *PRStatusPoller) SetInstances(instances []*Instance)

+ func (p *PRStatusPoller) SetOnUpdated(fn func(*Instance))

+ func (p *PRStatusPoller) Start(ctx context.Context)

+ func (p *PRStatusPoller) Stop()

+ type PRStatusPollerConfig struct

+ AuthCacheDuration time.Duration

+ CallTimeout time.Duration

+ ConcurrentFetches int

+ PollInterval time.Duration

+ func DefaultPRStatusPollerConfig() PRStatusPollerConfig

type Repository

+ AllRules func(ctx context.Context) ([]ApprovalRuleData, error)

+ DeleteRule func(ctx context.Context, id string) error

+ ListAnalytics func(ctx context.Context, limit int) ([]AnalyticsData, error)

+ RecordAnalytics func(ctx context.Context, data AnalyticsData) error

+ UpsertRule func(ctx context.Context, rule ApprovalRuleData) error

type Storage

+ func (s *Storage) AllRules(ctx context.Context) ([]ApprovalRuleData, error)

+ func (s *Storage) DeleteRule(ctx context.Context, id string) error

+ func (s *Storage) ListAnalytics(ctx context.Context, limit int) ([]AnalyticsData, error)

+ func (s *Storage) RecordAnalytics(ctx context.Context, data AnalyticsData) error

+ func (s *Storage) UpdateInstanceForkFlag(title string, isFork bool) error

+ func (s *Storage) UpdateInstancePRNumber(title string, prNumber int) error

+ func (s *Storage) UpdateInstancePRStatus(title, state, priority, checkConclusion string, ...) error

+ func (s *Storage) UpsertRule(ctx context.Context, rule ApprovalRuleData) error

type TerminalState

+ SavedCursorCol int

+ SavedCursorRow int

+ TabStops map[int]bool

+ type Workspace struct

+ EffectivePath string

+ RepoRoot string

v1.11.1

Apr 10, 2026

v1.11.0

Apr 9, 2026

v1.10.0

Apr 9, 2026

v1.9.0

Apr 9, 2026

Changes in this version

+ const MaxTagCount

+ type ErrTooManyTags struct

+ Count int

+ MaxCount int

+ func (e ErrTooManyTags) Error() string

type ResponseStream

+ func (rs *ResponseStream) SetOnOutput(fn func())

v1.8.1

Apr 9, 2026

v1.8.0

Apr 9, 2026

Changes in this version

type HistoryLinker

+ func NewHistoryLinkerFromRealInspector() *HistoryLinker

+ func (hl *HistoryLinker) Instances() []*Instance

v1.7.3

Apr 9, 2026

v1.7.2

Apr 9, 2026

v1.7.1

Apr 8, 2026

v1.7.0

Apr 8, 2026

v1.1.6

Apr 8, 2026

v1.1.5

Apr 8, 2026

v1.1.4

Apr 8, 2026

v1.1.3

Apr 8, 2026

v1.1.2

Apr 8, 2026

v1.1.1

Apr 8, 2026

Changes in this version

type Instance

+ AutonomousMode bool

type InstanceData

+ AutonomousMode bool

v1.1.0

Apr 8, 2026

Changes in this version

type Instance

+ func (i *Instance) GetCreatedAt() time.Time

+ func (i *Instance) GetTitle() string

+ func (i *Instance) LastMeaningfulOutputTime() time.Time

+ func (i *Instance) MarkAcknowledged()

+ func (i *Instance) MarkNeedsApproval() error

+ func (i *Instance) MarkUserResponded() time.Time

+ func (i *Instance) MarkViewed()

+ func (i *Instance) SetLastMeaningfulOutput(t time.Time)

+ type InstanceContext interface

+ GetCreatedAt func() time.Time

+ GetPTYReader func() (*os.File, error)

+ GetTitle func() string

+ LastMeaningfulOutputTime func() time.Time

+ Preview func() (string, error)

+ SetLastMeaningfulOutput func(t time.Time)

+ type InstanceStore interface

+ AddInstance func(*Instance) error

+ DeleteInstance func(title string) error

+ LoadInstances func() ([]*Instance, error)

+ SaveInstances func([]*Instance) error

+ UpdateInstanceLastUserResponse func(title string, t time.Time) error

v1.0.12

Apr 7, 2026

v1.0.0

Apr 7, 2026

Changes in this version

+ const DefaultBufferSize

+ const MaxTagLength

+ const MaxTitleLength

+ const MinTitleLength

+ const PriorityHigh

+ const PriorityLow

+ const PriorityMedium

+ const PriorityUrgent

+ const ReasonApprovalPending

+ const ReasonErrorState

+ const ReasonIdle

+ const ReasonIdleTimeout

+ const ReasonInputRequired

+ const ReasonStale

+ const ReasonTaskComplete

+ const ReasonTestsFailing

+ const ReasonUncommittedChanges

+ const ReasonWaitingForUser

+ var ContextCloudSession = ContextOptions

+ var ContextDetailView = ContextOptions

+ var ContextForReviewQueue = ContextOptions

+ var ContextForSearch = ContextOptions

+ var ContextFull = ContextOptions

+ var ContextMinimal = ContextOptions

+ var ContextTerminalView = ContextOptions

+ var ContextUIView = ContextOptions

+ var DefaultRepoPathManager = NewRepoPathManager()

+ var DeterminePriority = queue.DeterminePriority

+ var ErrCannotRestart = errors.New("session cannot be restarted in current state")

+ var ErrDuplicateTitle = errors.New("a session with this title already exists")

+ var ErrInvalidTitleChars = errors.New("title contains invalid characters")

+ var ErrInvalidTitleLength = errors.New("title must be 1-32 characters")

+ var LoadDiffOnly = LoadOptions

+ var LoadForReviewQueue = LoadOptions

+ var LoadFull = LoadOptions

+ var LoadMinimal = LoadOptions

+ var LoadSummary = LoadOptions

+ func CanTransition(from, to Status) bool

+ func CreateFullSyncDeltaFromRawContent(rawContent string, cursorRow, cursorCol, rows, cols int) *sessionv1.TerminalData

+ func ForkClaudeConversation(srcConvPath string, lineCount uint64, dstDir string) (string, error)

+ func GetMainRepoPath(path string) (string, error)

+ func IsGitHubURL(input string) bool

+ func RollbackMigration(backupPath, sqlitePath string) error

+ func ValidateEntMigration(jsonPath, entDBPath string) error

+ type ActivityTracking struct

+ LastAcknowledged time.Time

+ LastAddedToQueue time.Time

+ LastMeaningfulOutput time.Time

+ LastOutputSignature string

+ LastTerminalUpdate time.Time

+ LastViewed time.Time

+ func (a *ActivityTracking) HasRecentActivity(within time.Duration) bool

+ func (a *ActivityTracking) IsEmpty() bool

+ type ApprovalAutomation struct

+ func NewApprovalAutomation(sessionName string, controller *ClaudeController) *ApprovalAutomation

+ func (aa *ApprovalAutomation) GetDetector() *detection.ApprovalDetector

+ func (aa *ApprovalAutomation) GetPendingApprovals() []*PendingApproval

+ func (aa *ApprovalAutomation) GetPolicyEngine() *PolicyEngine

+ func (aa *ApprovalAutomation) GetSessionName() string

+ func (aa *ApprovalAutomation) IsRunning() bool

+ func (aa *ApprovalAutomation) RespondToApproval(requestID string, approved bool, userInput string, ...) error

+ func (aa *ApprovalAutomation) Start(ctx context.Context, options ApprovalAutomationOptions) error

+ func (aa *ApprovalAutomation) Stop() error

+ func (aa *ApprovalAutomation) Subscribe(subscriberID string) <-chan ApprovalEvent

+ func (aa *ApprovalAutomation) Unsubscribe(subscriberID string)

+ type ApprovalAutomationOptions struct

+ AutoExecute bool

+ EnableAuditLog bool

+ MaxQueueSize int

+ ProcessingDelay time.Duration

+ UserTimeout time.Duration

+ func DefaultApprovalAutomationOptions() ApprovalAutomationOptions

+ type ApprovalEvent struct

+ Decision *PolicyDecision

+ Details string

+ Request *detection.ApprovalRequest

+ Timestamp time.Time

+ Type ApprovalEventType

+ type ApprovalEventType string

+ const EventAutoApproved

+ const EventAutoRejected

+ const EventAwaitingUser

+ const EventDetected

+ const EventExecuted

+ const EventExecutionFail

+ const EventExpired

+ const EventUserApproved

+ const EventUserRejected

+ type ApprovalMetadata struct

+ ApprovalID string

+ Cwd string

+ Orphaned bool

+ ToolInput map[string]interface{}

+ ToolName string

+ type ApprovalMetadataProvider interface

+ GetApprovalMetadataBySession func(sessionID string) []ApprovalMetadata

+ type ApprovalPolicy struct

+ Action PolicyAction

+ ApprovalTypes []detection.ApprovalType

+ Conditions []PolicyCondition

+ CreatedAt time.Time

+ Description string

+ Enabled bool

+ ID string

+ Name string

+ Priority int

+ TimeRestriction *TimeRestriction

+ UpdatedAt time.Time

+ UsageLimit *UsageLimit

+ func CreateBusinessHoursPolicy() *ApprovalPolicy

+ func CreateNoDestructivePolicy() *ApprovalPolicy

+ func CreateSafeCommandPolicy() *ApprovalPolicy

+ type AttentionReason = queue.AttentionReason

+ func AttentionReasonFromDetected(detected detection.DetectedStatus) AttentionReason

+ type AvailableTargets struct

+ Bookmarks []BookmarkTarget

+ RecentRevisions []RevisionTarget

+ VCSType string

+ Worktrees []WorktreeTarget

+ type BookmarkTarget struct

+ IsRemote bool

+ Name string

+ RevisionID string

+ type Cell struct

+ Char rune

+ Style CellStyle

+ type CellStyle struct

+ BgColor string

+ Bold bool

+ FgColor string

+ Italic bool

+ Reverse bool

+ Underline bool

+ func DefaultStyle() CellStyle

+ type Checkpoint struct

+ ClaudeConvUUID string

+ ConvLineCount uint64

+ GitCommitSHA string

+ ID string

+ Label string

+ ParentID string

+ ScrollbackPath string

+ ScrollbackSeq uint64

+ SessionID string

+ Timestamp time.Time

+ type CheckpointList []Checkpoint

+ func (cl CheckpointList) FindByID(id string) *Checkpoint

+ func (cl CheckpointList) FindByLabel(label string) *Checkpoint

+ func (cl CheckpointList) Latest() *Checkpoint

+ type CircularBuffer struct

+ func NewCircularBuffer(size int) *CircularBuffer

+ func (cb *CircularBuffer) Cap() int

+ func (cb *CircularBuffer) Clear()

+ func (cb *CircularBuffer) Close() error

+ func (cb *CircularBuffer) DisableDiskFallback() error

+ func (cb *CircularBuffer) EnableDiskFallback(diskPath string) error

+ func (cb *CircularBuffer) GetAll() []byte

+ func (cb *CircularBuffer) GetRecent(n int) []byte

+ func (cb *CircularBuffer) Len() int

+ func (cb *CircularBuffer) Write(data []byte) (int, error)

+ func (cb *CircularBuffer) WriteTo(w io.Writer) (int64, error)

+ type ClaudeCommandBuilder struct

+ func NewClaudeCommandBuilder(baseProgram string, claudeSession *ClaudeSessionData) *ClaudeCommandBuilder

+ func (b *ClaudeCommandBuilder) Build() string

+ type ClaudeController struct

+ func NewClaudeController(instance *Instance) (*ClaudeController, error)

+ func (cc *ClaudeController) CancelCommand(commandID string) error

+ func (cc *ClaudeController) ClearHistory() error

+ func (cc *ClaudeController) ClearQueue() error

+ func (cc *ClaudeController) GetCommandHistory(limit int) []*HistoryEntry

+ func (cc *ClaudeController) GetCommandStatus(commandID string) (*Command, error)

+ func (cc *ClaudeController) GetCurrentCommand() *Command

+ func (cc *ClaudeController) GetCurrentStatus() (detection.DetectedStatus, string)

+ func (cc *ClaudeController) GetExecutionOptions() ExecutionOptions

+ func (cc *ClaudeController) GetHistoryStatistics() HistoryStatistics

+ func (cc *ClaudeController) GetIdleDuration() time.Duration

+ func (cc *ClaudeController) GetIdleState() (detection.IdleState, time.Time)

+ func (cc *ClaudeController) GetIdleStateInfo() detection.IdleStateInfo

+ func (cc *ClaudeController) GetInstance() *Instance

+ func (cc *ClaudeController) GetQueuedCommands() []*Command

+ func (cc *ClaudeController) GetRecentOutput(bytes int) []byte

+ func (cc *ClaudeController) GetSessionName() string

+ func (cc *ClaudeController) IsActive() bool

+ func (cc *ClaudeController) IsIdle() bool

+ func (cc *ClaudeController) IsStarted() bool

+ func (cc *ClaudeController) SearchHistory(query string) []*HistoryEntry

+ func (cc *ClaudeController) SendCommand(text string, priority int) (string, error)

+ func (cc *ClaudeController) SendCommandImmediate(text string) (*ExecutionResult, error)

+ func (cc *ClaudeController) SetExecutionOptions(options ExecutionOptions)

+ func (cc *ClaudeController) Start(ctx context.Context) error

+ func (cc *ClaudeController) Stop() error

+ func (cc *ClaudeController) Subscribe(subscriberID string) (<-chan ResponseChunk, error)

+ func (cc *ClaudeController) Unsubscribe(subscriberID string) error

+ type ClaudeConversationMessage struct

+ Content string

+ Model string

+ Role string

+ Timestamp time.Time

+ type ClaudeHistoryEntry struct

+ CreatedAt time.Time

+ ID string

+ MessageCount int

+ Model string

+ Name string

+ Project string

+ UpdatedAt time.Time

+ type ClaudeSession struct

+ ConversationID string

+ ID string

+ IsActive bool

+ LastActive time.Time

+ ProjectName string

+ WorkingDir string

+ type ClaudeSessionData struct

+ ConversationID string

+ LastAttached time.Time

+ Metadata map[string]string

+ ProjectName string

+ SessionID string

+ Settings ClaudeSettings

+ type ClaudeSessionHistory struct

+ func NewClaudeSessionHistory(historyPath string) (*ClaudeSessionHistory, error)

+ func NewClaudeSessionHistoryFromClaudeDir() (*ClaudeSessionHistory, error)

+ func (sh *ClaudeSessionHistory) Count() int

+ func (sh *ClaudeSessionHistory) GetAll() []ClaudeHistoryEntry

+ func (sh *ClaudeSessionHistory) GetByID(id string) (*ClaudeHistoryEntry, error)

+ func (sh *ClaudeSessionHistory) GetByProject(projectPath string) []ClaudeHistoryEntry

+ func (sh *ClaudeSessionHistory) GetMessagesFromConversationFile(sessionID string) ([]ClaudeConversationMessage, error)

+ func (sh *ClaudeSessionHistory) GetProjects() []string

+ func (sh *ClaudeSessionHistory) LastLoadTime() time.Time

+ func (sh *ClaudeSessionHistory) Reload() error

+ func (sh *ClaudeSessionHistory) Search(query string) []ClaudeHistoryEntry

+ type ClaudeSessionManager struct

+ func NewClaudeSessionManager() *ClaudeSessionManager

+ func (csm *ClaudeSessionManager) AttachToSession(sessionID string) error

+ func (csm *ClaudeSessionManager) CreateSessionData(session ClaudeSession, settings ClaudeSettings) ClaudeSessionData

+ func (csm *ClaudeSessionManager) DetectAvailableSessions() ([]ClaudeSession, error)

+ func (csm *ClaudeSessionManager) FindSessionByProject(projectPath string) ([]ClaudeSession, error)

+ func (csm *ClaudeSessionManager) GetSessionByID(sessionID string) (*ClaudeSession, error)

+ type ClaudeSettings struct

+ AutoReattach bool

+ CreateNewOnMissing bool

+ PreferredSessionName string

+ SessionTimeoutMinutes int

+ ShowSessionSelector bool

+ type CloudContext struct

+ APIEndpoint string

+ APIKeyRef string

+ CloudSessionID string

+ ConversationID string

+ InstanceID string

+ Provider string

+ Region string

+ func (c *CloudContext) IsConfigured() bool

+ func (c *CloudContext) IsEmpty() bool

+ type Command struct

+ EndTime time.Time

+ Error string

+ ID string

+ Priority int

+ Result string

+ StartTime time.Time

+ Status CommandStatus

+ Text string

+ Timestamp time.Time

+ type CommandExecutor struct

+ func NewCommandExecutor(sessionName string, ptyAccess *PTYAccess, responseStream *ResponseStream, ...) *CommandExecutor

+ func NewCommandExecutorWithOptions(sessionName string, ptyAccess *PTYAccess, responseStream *ResponseStream, ...) *CommandExecutor

+ func (ce *CommandExecutor) ExecuteImmediate(cmd *Command) (*ExecutionResult, error)

+ func (ce *CommandExecutor) GetCurrentCommand() *Command

+ func (ce *CommandExecutor) GetOptions() ExecutionOptions

+ func (ce *CommandExecutor) GetSessionName() string

+ func (ce *CommandExecutor) IsExecuting() bool

+ func (ce *CommandExecutor) SetOptions(options ExecutionOptions)

+ func (ce *CommandExecutor) SetResultCallback(callback func(*ExecutionResult))

+ func (ce *CommandExecutor) Start(ctx context.Context) error

+ func (ce *CommandExecutor) Stop() error

+ type CommandHistory struct

+ func NewCommandHistory(sessionName string) *CommandHistory

+ func NewCommandHistoryWithPersistence(sessionName string, persistDir string) (*CommandHistory, error)

+ func (ch *CommandHistory) Add(entry *HistoryEntry) error

+ func (ch *CommandHistory) AddFromResult(result *ExecutionResult) error

+ func (ch *CommandHistory) Clear() error

+ func (ch *CommandHistory) Count() int

+ func (ch *CommandHistory) GetAll() []*HistoryEntry

+ func (ch *CommandHistory) GetByCommandID(commandID string) []*HistoryEntry

+ func (ch *CommandHistory) GetByStatus(status CommandStatus) []*HistoryEntry

+ func (ch *CommandHistory) GetByTimeRange(start, end time.Time) []*HistoryEntry

+ func (ch *CommandHistory) GetFailed() []*HistoryEntry

+ func (ch *CommandHistory) GetMaxEntries() int

+ func (ch *CommandHistory) GetPersistPath() string

+ func (ch *CommandHistory) GetRecent(n int) []*HistoryEntry

+ func (ch *CommandHistory) GetSessionName() string

+ func (ch *CommandHistory) GetStatistics() HistoryStatistics

+ func (ch *CommandHistory) GetSuccessful() []*HistoryEntry

+ func (ch *CommandHistory) Load() error

+ func (ch *CommandHistory) Save() error

+ func (ch *CommandHistory) Search(query string) []*HistoryEntry

+ func (ch *CommandHistory) SetMaxEntries(max int)

+ func (ch *CommandHistory) SetPersistPath(path string)

+ type CommandQueue struct

+ func NewCommandQueue(sessionName string) *CommandQueue

+ func NewCommandQueueWithPersistence(sessionName string, persistDir string) (*CommandQueue, error)

+ func (cq *CommandQueue) Cancel(id string) error

+ func (cq *CommandQueue) Clear() error

+ func (cq *CommandQueue) Dequeue() *Command

+ func (cq *CommandQueue) Enqueue(cmd *Command) error

+ func (cq *CommandQueue) Get(id string) (*Command, error)

+ func (cq *CommandQueue) GetPersistPath() string

+ func (cq *CommandQueue) IsEmpty() bool

+ func (cq *CommandQueue) Len() int

+ func (cq *CommandQueue) List() []*Command

+ func (cq *CommandQueue) ListByStatus(status CommandStatus) []*Command

+ func (cq *CommandQueue) Load() error

+ func (cq *CommandQueue) NotifyChannel() <-chan struct{}

+ func (cq *CommandQueue) Peek() *Command

+ func (cq *CommandQueue) Save() error

+ func (cq *CommandQueue) SetPersistPath(path string)

+ func (cq *CommandQueue) Update(cmd *Command) error

+ type CommandStatus int

+ const CommandCancelled

+ const CommandCompleted

+ const CommandExecuting

+ const CommandFailed

+ const CommandPending

+ func (cs CommandStatus) String() string

+ type ContextOptions struct

+ LoadActivity bool

+ LoadClaudeSession bool

+ LoadCloud bool

+ LoadDiffContent bool

+ LoadDiffStats bool

+ LoadFilesystem bool

+ LoadGit bool

+ LoadTags bool

+ LoadTerminal bool

+ LoadUI bool

+ LoadWorktree bool

+ func FromLoadOptions(lo LoadOptions) ContextOptions

+ func (o ContextOptions) AnyChildDataLoaded() bool

+ func (o ContextOptions) AnyContextLoaded() bool

+ func (o ContextOptions) Merge(other ContextOptions) ContextOptions

+ func (o ContextOptions) String() string

+ func (o ContextOptions) ToLoadOptions() LoadOptions

+ func (o ContextOptions) WithActivity() ContextOptions

+ func (o ContextOptions) WithCloud() ContextOptions

+ func (o ContextOptions) WithDiffContent() ContextOptions

+ func (o ContextOptions) WithFilesystem() ContextOptions

+ func (o ContextOptions) WithGit() ContextOptions

+ func (o ContextOptions) WithTags() ContextOptions

+ func (o ContextOptions) WithTerminal() ContextOptions

+ func (o ContextOptions) WithUI() ContextOptions

+ func (o ContextOptions) WithoutDiffContent() ContextOptions

+ func (o ContextOptions) WithoutTags() ContextOptions

+ type ControllerManager struct

+ func (cm *ControllerManager) GetController() *ClaudeController

+ func (cm *ControllerManager) GetStatusManager() *InstanceStatusManager

+ func (cm *ControllerManager) HasController() bool

+ func (cm *ControllerManager) RegisterController(title string, controller *ClaudeController)

+ func (cm *ControllerManager) SetController(c *ClaudeController)

+ func (cm *ControllerManager) SetStatusManager(m *InstanceStatusManager)

+ func (cm *ControllerManager) StopAndClearController()

+ func (cm *ControllerManager) UnregisterController(title string)

+ type DiffStatsData struct

+ Added int

+ Content string

+ Removed int

+ type DiscoveryMode int

+ const DiscoveryModeExtended

+ const DiscoveryModeFull

+ const DiscoveryModeManaged

+ func ParseDiscoveryMode(s string) DiscoveryMode

+ func (dm DiscoveryMode) String() string

+ type EntRepository struct

+ func NewEntRepository(opts ...RepositoryOption) (*EntRepository, error)

+ func (r *EntRepository) Close() error

+ func (r *EntRepository) Create(ctx context.Context, data InstanceData) error

+ func (r *EntRepository) CreateSession(ctx context.Context, session *Session) error

+ func (r *EntRepository) Delete(ctx context.Context, title string) error

+ func (r *EntRepository) Get(ctx context.Context, title string) (*InstanceData, error)

+ func (r *EntRepository) GetSession(ctx context.Context, title string, opts ContextOptions) (*Session, error)

+ func (r *EntRepository) GetWithOptions(ctx context.Context, title string, options LoadOptions) (*InstanceData, error)

+ func (r *EntRepository) List(ctx context.Context) ([]InstanceData, error)

+ func (r *EntRepository) ListByStatus(ctx context.Context, status Status) ([]InstanceData, error)

+ func (r *EntRepository) ListByStatusWithOptions(ctx context.Context, status Status, options LoadOptions) ([]InstanceData, error)

+ func (r *EntRepository) ListByTag(ctx context.Context, tagName string) ([]InstanceData, error)

+ func (r *EntRepository) ListByTagWithOptions(ctx context.Context, tag string, options LoadOptions) ([]InstanceData, error)

+ func (r *EntRepository) ListSessions(ctx context.Context, opts ContextOptions) ([]*Session, error)

+ func (r *EntRepository) ListWithOptions(ctx context.Context, options LoadOptions) ([]InstanceData, error)

+ func (r *EntRepository) Update(ctx context.Context, data InstanceData) error

+ func (r *EntRepository) UpdateSession(ctx context.Context, session *Session) error

+ func (r *EntRepository) UpdateTimestamps(ctx context.Context, title string, ...) error

+ type ErrDuplicateTag struct

+ Tag string

+ func (e ErrDuplicateTag) Error() string

+ type ErrInvalidTransition struct

+ From Status

+ To Status

+ func (e ErrInvalidTransition) Error() string

+ type ErrTagTooLong struct

+ MaxLen int

+ Tag string

+ func (e ErrTagTooLong) Error() string

+ type ExecutionOptions struct

+ MaxOutputSize int

+ StatusCheckInterval time.Duration

+ TerminalStatuses []detection.DetectedStatus

+ Timeout time.Duration

+ func DefaultExecutionOptions() ExecutionOptions

+ type ExecutionResult struct

+ Command *Command

+ EndTime time.Time

+ Error error

+ FinalStatus detection.DetectedStatus

+ Output string

+ StartTime time.Time

+ StatusChanges []StatusChange

+ Success bool

+ type ExternalApprovalCallback func(*ExternalApprovalEvent)

+ type ExternalApprovalEvent struct

+ Command string

+ Cwd string

+ Request *detection.ApprovalRequest

+ SessionID string

+ SessionTitle string

+ Source ExternalApprovalSource

+ type ExternalApprovalMonitor struct

+ func NewExternalApprovalMonitor() *ExternalApprovalMonitor

+ func (m *ExternalApprovalMonitor) GetAllPendingApprovals() map[string][]*detection.ApprovalRequest

+ func (m *ExternalApprovalMonitor) GetDetector() *detection.ApprovalDetector

+ func (m *ExternalApprovalMonitor) GetMonitoredSessions() []string

+ func (m *ExternalApprovalMonitor) GetPendingApprovals(socketPath string) []*detection.ApprovalRequest

+ func (m *ExternalApprovalMonitor) IntegrateWithDiscovery(discovery *ExternalSessionDiscovery, streamerManager *ExternalStreamerManager)

+ func (m *ExternalApprovalMonitor) IntegrateWithDiscoveryTmux(discovery *ExternalSessionDiscovery, ...)

+ func (m *ExternalApprovalMonitor) MarkApprovalHandled(socketPath, requestID string, approved bool) error

+ func (m *ExternalApprovalMonitor) MonitorSession(streamer *ExternalStreamer, title string, source ExternalApprovalSource) error

+ func (m *ExternalApprovalMonitor) MonitorSessionTmux(streamer *ExternalTmuxStreamer, tmuxSessionName string, title string, ...) error

+ func (m *ExternalApprovalMonitor) OnApproval(callback ExternalApprovalCallback)

+ func (m *ExternalApprovalMonitor) Start()

+ func (m *ExternalApprovalMonitor) Stop()

+ func (m *ExternalApprovalMonitor) StopMonitoringSession(socketPath string)

+ type ExternalApprovalSource string

+ const SourceIntelliJ

+ const SourceMux

+ const SourceTerminal

+ const SourceUnknown

+ const SourceVSCode

+ type ExternalInstanceMetadata struct

+ DiscoveredAt time.Time

+ LastSeen time.Time

+ MuxEnabled bool

+ MuxSocketPath string

+ OriginalPID int

+ SourceTerminal string

+ TmuxSessionName string

+ TmuxSocket string

+ type ExternalSessionDiscovery struct

+ func NewExternalSessionDiscovery() *ExternalSessionDiscovery

+ func (e *ExternalSessionDiscovery) GetSession(socketPath string) *Instance

+ func (e *ExternalSessionDiscovery) GetSessionByTmux(tmuxSessionName string) *Instance

+ func (e *ExternalSessionDiscovery) GetSessions() []*Instance

+ func (e *ExternalSessionDiscovery) OnSessionAdded(callback func(*Instance))

+ func (e *ExternalSessionDiscovery) OnSessionRemoved(callback func(*Instance))

+ func (e *ExternalSessionDiscovery) SetSocketRegistry(r *mux.SocketRegistry)

+ func (e *ExternalSessionDiscovery) Start(interval time.Duration)

+ func (e *ExternalSessionDiscovery) Stop()

+ type ExternalStreamer struct

+ func NewExternalStreamer(socketPath string, bufferSize int) *ExternalStreamer

+ func (s *ExternalStreamer) AddConsumer(consumer OutputConsumer, catchUp bool)

+ func (s *ExternalStreamer) ConsumerCount() int

+ func (s *ExternalStreamer) GetMetadata() *mux.SessionMetadata

+ func (s *ExternalStreamer) GetRecentOutput() []byte

+ func (s *ExternalStreamer) GetSnapshot() ([]byte, error)

+ func (s *ExternalStreamer) IsConnected() bool

+ func (s *ExternalStreamer) RemoveConsumer(consumer OutputConsumer)

+ func (s *ExternalStreamer) SendInput(data []byte) error

+ func (s *ExternalStreamer) SendResize(cols, rows uint16) error

+ func (s *ExternalStreamer) SocketPath() string

+ func (s *ExternalStreamer) Start() error

+ func (s *ExternalStreamer) Stop()

+ type ExternalStreamerManager struct

+ func NewExternalStreamerManager(bufferSize int) *ExternalStreamerManager

+ func (m *ExternalStreamerManager) Count() int

+ func (m *ExternalStreamerManager) Get(socketPath string) *ExternalStreamer

+ func (m *ExternalStreamerManager) GetOrCreate(socketPath string) (*ExternalStreamer, error)

+ func (m *ExternalStreamerManager) Remove(socketPath string)

+ func (m *ExternalStreamerManager) StopAll()

+ type ExternalTmuxStreamer struct

+ func NewExternalTmuxStreamer(tmuxSessionName string) *ExternalTmuxStreamer

+ func (s *ExternalTmuxStreamer) AddConsumer(consumer func(content string))

+ func (s *ExternalTmuxStreamer) ConsumerCount() int

+ func (s *ExternalTmuxStreamer) GetContent() string

+ func (s *ExternalTmuxStreamer) IsRunning() bool

+ func (s *ExternalTmuxStreamer) RemoveConsumer(consumer func(content string))

+ func (s *ExternalTmuxStreamer) Start() error

+ func (s *ExternalTmuxStreamer) Stop()

+ type ExternalTmuxStreamerManager struct

+ func NewExternalTmuxStreamerManager() *ExternalTmuxStreamerManager

+ func (m *ExternalTmuxStreamerManager) Count() int

+ func (m *ExternalTmuxStreamerManager) Get(tmuxSessionName string) *ExternalTmuxStreamer

+ func (m *ExternalTmuxStreamerManager) GetOrCreate(tmuxSessionName string) (*ExternalTmuxStreamer, error)

+ func (m *ExternalTmuxStreamerManager) Remove(tmuxSessionName string)

+ func (m *ExternalTmuxStreamerManager) StopAll()

+ type FilesystemContext struct

+ ClonedRepoPath string

+ ExistingWorktree string

+ IsWorktree bool

+ MainRepoPath string

+ ProjectPath string

+ SessionType SessionType

+ WorkingDir string

+ func (f *FilesystemContext) IsEmpty() bool

+ type GitContext struct

+ BaseCommitSHA string

+ Branch string

+ Owner string

+ PRNumber int

+ PRURL string

+ Repo string

+ SourceRef string

+ WorktreeID *int64

+ func (g *GitContext) IsEmpty() bool

+ type GitHubMetadataView struct

+ ClonedRepoPath string

+ Owner string

+ PRNumber int

+ PRURL string

+ Repo string

+ SourceRef string

+ func (gh GitHubMetadataView) IsEmpty() bool

+ func (gh GitHubMetadataView) IsGitHubSession() bool

+ func (gh GitHubMetadataView) IsPRSession() bool

+ func (gh GitHubMetadataView) PRDisplayInfo() string

+ func (gh GitHubMetadataView) RepoFullName() string

+ type GitHubRef struct

+ Branch string

+ Owner string

+ PRNumber int

+ Repo string

+ Type GitHubRefType

+ func ParseGitHubURL(input string) (*GitHubRef, error)

+ func ResolveGitHubInput(input string) (localPath string, ref *GitHubRef, err error)

+ type GitHubRefType int

+ const GitHubRefTypeBranch

+ const GitHubRefTypePR

+ const GitHubRefTypeRepo

+ type GitWorktreeData struct

+ BaseCommitSHA string

+ BranchName string

+ RepoPath string

+ SessionName string

+ WorktreePath string

+ type GitWorktreeManager struct

+ func (gm *GitWorktreeManager) Cleanup() error

+ func (gm *GitWorktreeManager) ClearDiffStats()

+ func (gm *GitWorktreeManager) CommitChanges(commitMsg string) error

+ func (gm *GitWorktreeManager) ComputeDiff() *git.DiffStats

+ func (gm *GitWorktreeManager) ComputeDiffIfReady() (stats *git.DiffStats, needsPause bool)

+ func (gm *GitWorktreeManager) GetBaseCommitSHA() string

+ func (gm *GitWorktreeManager) GetBranchName() string

+ func (gm *GitWorktreeManager) GetCurrentCommitSHA() (string, error)

+ func (gm *GitWorktreeManager) GetDiffStats() *git.DiffStats

+ func (gm *GitWorktreeManager) GetRepoName() string

+ func (gm *GitWorktreeManager) GetRepoPath() string

+ func (gm *GitWorktreeManager) GetWorktree() *git.GitWorktree

+ func (gm *GitWorktreeManager) GetWorktreePath() string

+ func (gm *GitWorktreeManager) HasWorktree() bool

+ func (gm *GitWorktreeManager) IsBranchCheckedOut() (bool, error)

+ func (gm *GitWorktreeManager) IsDirty() (bool, error)

+ func (gm *GitWorktreeManager) OpenBranchURL() error

+ func (gm *GitWorktreeManager) Prune() error

+ func (gm *GitWorktreeManager) PushChanges(commitMsg string, open bool) error

+ func (gm *GitWorktreeManager) Remove() error

+ func (gm *GitWorktreeManager) SetDiffStats(stats *git.DiffStats)

+ func (gm *GitWorktreeManager) SetWorktree(wt *git.GitWorktree)

+ func (gm *GitWorktreeManager) Setup() error

+ func (gm *GitWorktreeManager) UpdateDiffStats()

+ type HealthCheckResult struct

+ Actions []string

+ InstanceTitle string

+ IsHealthy bool

+ Issues []string

+ RecoveryAttempted bool

+ RecoverySuccess bool

+ type HistoryEntry struct

+ Command Command

+ ExecutionTime time.Duration

+ Result *ExecutionResult

+ SessionName string

+ Timestamp time.Time

+ type HistoryFileDetector struct

+ func NewHistoryFileDetector(inspector ProcessFileInspector) *HistoryFileDetector

+ func NewHistoryFileDetectorWithRealInspector() *HistoryFileDetector

+ func (d *HistoryFileDetector) Detect(pid int32) (*HistoryFileInfo, error)

+ type HistoryFileInfo struct

+ ConversationUUID string

+ HistoryFilePath string

+ ProjectDir string

+ type HistoryFileWatcher struct

+ func NewHistoryFileWatcher(watchDir string, callback func(filePath string)) *HistoryFileWatcher

+ func (w *HistoryFileWatcher) Start(ctx context.Context) error

+ func (w *HistoryFileWatcher) Stop()

+ type HistoryLinker struct

+ func NewHistoryLinker(detector *HistoryFileDetector, watcher *HistoryFileWatcher) *HistoryLinker

+ func (hl *HistoryLinker) AddInstance(instance *Instance)

+ func (hl *HistoryLinker) RemoveInstance(title string)

+ func (hl *HistoryLinker) ScanAll()

+ func (hl *HistoryLinker) SetInstances(instances []*Instance)

+ func (hl *HistoryLinker) Start(ctx context.Context)

+ type HistoryStatistics struct

+ AverageExecutionTime time.Duration

+ CancelledCommands int

+ FailedCommands int

+ FirstCommandTime time.Time

+ LastCommandTime time.Time

+ SuccessfulCommands int

+ TotalCommands int

+ type Instance struct

+ ActiveCheckpoint string

+ AutoYes bool

+ Branch string

+ Category string

+ Checkpoints CheckpointList

+ ClonedRepoPath string

+ CreatedAt time.Time

+ ExistingWorktree string

+ ExternalMetadata *ExternalInstanceMetadata

+ ForkedFromID string

+ GitHubOwner string

+ GitHubPRNumber int

+ GitHubPRURL string

+ GitHubRepo string

+ GitHubSourceRef string

+ Height int

+ HistoryFilePath string

+ InstanceType InstanceType

+ IsExpanded bool

+ IsManaged bool

+ IsWorktree bool

+ MainRepoPath string

+ Path string

+ Permissions InstancePermissions

+ Program string

+ Prompt string

+ SessionType SessionType

+ Status Status

+ Tags []string

+ Title string

+ TmuxPrefix string

+ TmuxServerSocket string

+ UpdatedAt time.Time

+ Width int

+ WorkingDir string

+ func FromInstanceData(data InstanceData) (*Instance, error)

+ func NewInstance(opts InstanceOptions) (*Instance, error)

+ func NewInstanceWithCleanup(opts InstanceOptions) (*Instance, tmux.CleanupFunc, error)

+ func SessionToInstance(s *Session) *Instance

+ func (i *Instance) AddTag(tag string) error

+ func (i *Instance) Approve() error

+ func (i *Instance) Attach() (chan struct{}, error)

+ func (i *Instance) CaptureCurrentState() error

+ func (i *Instance) CapturePaneContent() (string, error)

+ func (i *Instance) CapturePaneContentRaw() (string, error)

+ func (i *Instance) CleanupWorktree() error

+ func (i *Instance) ClosePR() error

+ func (i *Instance) CreateCheckpoint(label string, scrollbackSeq uint64) (*Checkpoint, error)

+ func (i *Instance) Deny() error

+ func (i *Instance) Destroy() error

+ func (i *Instance) DetectAndPopulateWorktreeInfo() error

+ func (i *Instance) ForkFromCheckpoint(checkpointID, newTitle string, configDir string) (*Instance, error)

+ func (i *Instance) GeneratePRContextPrompt() (string, error)

+ func (i *Instance) GetCategoryPath() []string

+ func (i *Instance) GetCheckpoints() CheckpointList

+ func (i *Instance) GetClaudeSession() *ClaudeSessionData

+ func (i *Instance) GetController() *ClaudeController

+ func (i *Instance) GetConversationUUID() string

+ func (i *Instance) GetCurrentPaneContent(lines int) (string, error)

+ func (i *Instance) GetDiffStats() *git.DiffStats

+ func (i *Instance) GetEffectiveRootDir() string

+ func (i *Instance) GetEffectiveStatus() Status

+ func (i *Instance) GetGitHubRepoFullName() string

+ func (i *Instance) GetGitWorktree() (*git.GitWorktree, error)

+ func (i *Instance) GetPRComments() ([]github.PRComment, error)

+ func (i *Instance) GetPRDiff() (string, error)

+ func (i *Instance) GetPRDisplayInfo() string

+ func (i *Instance) GetPTYReader() (*os.File, error)

+ func (i *Instance) GetPaneCursorPosition() (x, y int, err error)

+ func (i *Instance) GetPaneDimensions() (width, height int, err error)

+ func (i *Instance) GetPanePID() (int32, error)

+ func (i *Instance) GetPermissions() InstancePermissions

+ func (i *Instance) GetReviewItem() (*ReviewItem, bool)

+ func (i *Instance) GetReviewQueue() *ReviewQueue

+ func (i *Instance) GetScrollbackHistory(startLine, endLine string) (string, error)

+ func (i *Instance) GetStatusIconForType() string

+ func (i *Instance) GetStatusManager() *InstanceStatusManager

+ func (i *Instance) GetTags() []string

+ func (i *Instance) GetTimeSinceLastMeaningfulOutput() time.Duration

+ func (i *Instance) GetTimeSinceLastTerminalUpdate() time.Duration

+ func (i *Instance) GetTmuxSession() *tmux.TmuxSession

+ func (i *Instance) GetVCSInfo() (*VCSInfo, error)

+ func (i *Instance) GetWorkingDirectory() string

+ func (i *Instance) GitHub() GitHubMetadataView

+ func (i *Instance) HasClaudeSession() bool

+ func (i *Instance) HasGitWorktree() bool

+ func (i *Instance) HasTag(tag string) bool

+ func (i *Instance) HasUpdated() (updated bool, hasPrompt bool)

+ func (i *Instance) IsGitHubSession() bool

+ func (i *Instance) IsPRSession() bool

+ func (i *Instance) Kill() error

+ func (i *Instance) KillExternalSession() error

+ func (i *Instance) KillSession() error

+ func (i *Instance) KillSessionKeepWorktree() error

+ func (i *Instance) ListAvailableTargets() (*AvailableTargets, error)

+ func (i *Instance) MergePR(method string) error

+ func (i *Instance) NeedsReview() bool

+ func (i *Instance) Pause() error

+ func (i *Instance) Paused() bool

+ func (i *Instance) PostComment(body string) error

+ func (i *Instance) Preview() (string, error)

+ func (i *Instance) PreviewFullHistory() (string, error)

+ func (i *Instance) RefreshPRInfo() (*github.PRInfo, error)

+ func (i *Instance) RefreshTmuxClient() error

+ func (i *Instance) RemoveTag(tag string)

+ func (i *Instance) Rename(newTitle string) error

+ func (i *Instance) RepoName() (string, error)

+ func (i *Instance) ResizePTY(cols, rows int) error

+ func (i *Instance) Restart(preserveOutput bool) error

+ func (i *Instance) Resume() error

+ func (i *Instance) SendKeys(keys string) error

+ func (i *Instance) SendPrompt(prompt string) error

+ func (i *Instance) SetClaudeSession(sessionData *ClaudeSessionData)

+ func (i *Instance) SetGitWorktree(worktree *git.GitWorktree)

+ func (i *Instance) SetHistoryInfo(conversationUUID, historyFilePath string)

+ func (i *Instance) SetPreviewSize(width, height int) error

+ func (i *Instance) SetReviewQueue(queue *ReviewQueue)

+ func (i *Instance) SetStatus(status Status)

+ func (i *Instance) SetStatusManager(manager *InstanceStatusManager)

+ func (i *Instance) SetTags(tags []string) error

+ func (i *Instance) SetTitle(title string) error

+ func (i *Instance) SetTmuxSession(session *tmux.TmuxSession)

+ func (i *Instance) SetWindowSize(cols, rows int) error

+ func (i *Instance) Start(firstTimeSetup bool) error

+ func (i *Instance) StartController() error

+ func (i *Instance) StartWithCleanup(firstTimeSetup bool) (tmux.CleanupFunc, error)

+ func (i *Instance) Started() bool

+ func (i *Instance) StopController()

+ func (i *Instance) SwitchWorkspace(req WorkspaceSwitchRequest) (*WorkspaceSwitchResult, error)

+ func (i *Instance) TapEnter()

+ func (i *Instance) TmuxAlive() bool

+ func (i *Instance) ToInstanceData() InstanceData

+ func (i *Instance) ToSession() *Session

+ func (i *Instance) UpdateDiffStats() error

+ func (i *Instance) UpdateTerminalTimestamps(content string, forceUpdate bool)

+ func (i *Instance) WriteToPTY(data []byte) (int, error)

+ type InstanceData struct

+ ActiveCheckpoint string

+ AutoYes bool

+ Branch string

+ Category string

+ Checkpoints CheckpointList

+ ClaudeSession ClaudeSessionData

+ ClonedRepoPath string

+ CreatedAt time.Time

+ DiffStats DiffStatsData

+ ExistingWorktree string

+ ForkedFromID string

+ GitHubOwner string

+ GitHubPRNumber int

+ GitHubPRURL string

+ GitHubRepo string

+ GitHubSourceRef string

+ Height int

+ HistoryFilePath string

+ IsExpanded bool

+ IsWorktree bool

+ LastAcknowledged time.Time

+ LastAddedToQueue time.Time

+ LastMeaningfulOutput time.Time

+ LastOutputSignature string

+ LastPromptDetected time.Time

+ LastPromptSignature string

+ LastTerminalUpdate time.Time

+ LastUserResponse time.Time

+ LastViewed time.Time

+ MainRepoPath string

+ Path string

+ ProcessingGraceUntil time.Time

+ Program string

+ Prompt string

+ SessionType SessionType

+ Status Status

+ Tags []string

+ Title string

+ TmuxPrefix string

+ UpdatedAt time.Time

+ Width int

+ WorkingDir string

+ Worktree GitWorktreeData

+ type InstanceOptions struct

+ AutoYes bool

+ Branch string

+ Category string

+ ClonedRepoPath string

+ ExistingWorktree string

+ GitHubOwner string

+ GitHubPRNumber int

+ GitHubPRURL string

+ GitHubRepo string

+ GitHubSourceRef string

+ Path string

+ Program string

+ Prompt string

+ ResumeId string

+ SessionType SessionType

+ Tags []string

+ Title string

+ TmuxPrefix string

+ TmuxServerSocket string

+ WorkingDir string

+ type InstancePermissions struct

+ CanAddToQueue bool

+ CanAttach bool

+ CanDestroy bool

+ CanModifyGit bool

+ CanPause bool

+ CanResume bool

+ CanSendCommand bool

+ CanView bool

+ RequiresConfirmation map[string]bool

+ func GetExternalPermissions(allowAttach bool) InstancePermissions

+ func GetManagedPermissions() InstancePermissions

+ func GetMuxExternalPermissions() InstancePermissions

+ type InstanceStatusInfo struct

+ BasicStatus Status

+ ClaudeStatus detection.DetectedStatus

+ IdleState detection.IdleStateInfo

+ IsControllerActive bool

+ LastCommandStatus string

+ PendingApprovals int

+ QueuedCommands int

+ StatusContext string

+ func (info InstanceStatusInfo) GetColorCode() string

+ func (info InstanceStatusInfo) GetStatusDescription() string

+ func (info InstanceStatusInfo) GetStatusIcon() string

+ func (info InstanceStatusInfo) HasPendingWork() bool

+ func (info InstanceStatusInfo) IsWaitingForUser() bool

+ func (info InstanceStatusInfo) NeedsAttention() bool

+ type InstanceStatusManager struct

+ func NewInstanceStatusManager() *InstanceStatusManager

+ func (ism *InstanceStatusManager) GetAllControllers() map[string]*ClaudeController

+ func (ism *InstanceStatusManager) GetController(instanceTitle string) (*ClaudeController, bool)

+ func (ism *InstanceStatusManager) GetStatus(instance *Instance) InstanceStatusInfo

+ func (ism *InstanceStatusManager) RegisterController(instanceTitle string, controller *ClaudeController)

+ func (ism *InstanceStatusManager) UnregisterController(instanceTitle string)

+ type InstanceType int

+ const InstanceTypeExternal

+ const InstanceTypeManaged

+ func (it InstanceType) String() string

+ type LoadOptions struct

+ LoadClaudeSession bool

+ LoadDiffContent bool

+ LoadDiffStats bool

+ LoadTags bool

+ LoadWorktree bool

+ func (o LoadOptions) WithDiffContent() LoadOptions

+ func (o LoadOptions) WithTags() LoadOptions

+ func (o LoadOptions) WithoutDiffContent() LoadOptions

+ func (o LoadOptions) WithoutTags() LoadOptions

+ type MigrationOptions struct

+ BackupPath string

+ DryRun bool

+ ForceOverwrite bool

+ JSONPath string

+ SQLitePath string

+ type MigrationResult struct

+ BackupCreated bool

+ BackupPath string

+ Duration time.Duration

+ Errors []string

+ MigratedSessions int

+ SQLiteDatabasePath string

+ SkippedSessions int

+ TotalSessions int

+ func MigrateJSONToEnt(opts MigrationOptions) (*MigrationResult, error)

+ type OutputConsumer func(data []byte)

+ type PTYAccess struct

+ func NewPTYAccess(sessionName string, pty *os.File, buffer *CircularBuffer) *PTYAccess

+ func (p *PTYAccess) Close() error

+ func (p *PTYAccess) GetBuffer() []byte

+ func (p *PTYAccess) GetRecentOutput(n int) []byte

+ func (p *PTYAccess) GetSessionName() string

+ func (p *PTYAccess) IsClosed() bool

+ func (p *PTYAccess) Read(buf []byte) (int, error)

+ func (p *PTYAccess) UpdatePTY(pty *os.File) error

+ func (p *PTYAccess) Write(data []byte) (int, error)

+ type PTYCategory int

+ const PTYCategoryOrphaned

+ const PTYCategoryOther

+ const PTYCategorySquad

+ func (c PTYCategory) String() string

+ type PTYConnection struct

+ CanAttach bool

+ CanDestroy bool

+ Command string

+ Controller *ClaudeController

+ IsManaged bool

+ LastActivity time.Time

+ Owner string

+ PID int

+ Path string

+ SessionName string

+ Status PTYStatus

+ TmuxSessionName string

+ TmuxSocket string

+ func (conn *PTYConnection) GetDisplayName() string

+ func (conn *PTYConnection) GetPTYBasename() string

+ func (conn *PTYConnection) GetStatusColor() string

+ func (conn *PTYConnection) GetStatusIcon() string

+ type PTYDiscovery struct

+ func NewPTYDiscovery() *PTYDiscovery

+ func NewPTYDiscoveryWithConfig(config PTYDiscoveryConfig) *PTYDiscovery

+ func (pd *PTYDiscovery) GetConnection(path string) *PTYConnection

+ func (pd *PTYDiscovery) GetConnections() []*PTYConnection

+ func (pd *PTYDiscovery) GetConnectionsByCategory() map[PTYCategory][]*PTYConnection

+ func (pd *PTYDiscovery) Refresh() error

+ func (pd *PTYDiscovery) SetSessions(sessions []*Instance)

+ func (pd *PTYDiscovery) Start()

+ func (pd *PTYDiscovery) Stop()

+ type PTYDiscoveryConfig struct

+ AllowExternalAttach bool

+ DiscoverExternal bool

+ DiscoveryInterval time.Duration

+ ExternalSockets []string

+ ManagedPrefix string

+ Mode DiscoveryMode

+ ParallelDiscovery bool

+ PrimarySocket string

+ RequireConfirmation bool

+ func DefaultPTYDiscoveryConfig() PTYDiscoveryConfig

+ func (c *PTYDiscoveryConfig) CanAttachExternal() bool

+ func (c *PTYDiscoveryConfig) ShouldDiscoverExternal() bool

+ type PTYStatus int

+ const PTYBusy

+ const PTYError

+ const PTYIdle

+ const PTYReady

+ func (s PTYStatus) String() string

+ type PendingApproval struct

+ Decision *PolicyDecision

+ ExpiresAt time.Time

+ ReceivedAt time.Time

+ Request *detection.ApprovalRequest

+ Status PendingApprovalStatus

+ UserResponse *detection.ApprovalResponse

+ type PendingApprovalStatus string

+ const PendingStatusAwaiting

+ const PendingStatusCancelled

+ const PendingStatusExpired

+ const PendingStatusProcessed

+ type PolicyAction string

+ const ActionAutoApprove

+ const ActionAutoReject

+ const ActionLog

+ const ActionPrompt

+ type PolicyAuditEntry struct

+ Action PolicyAction

+ MatchedRequest *detection.ApprovalRequest

+ PolicyID string

+ PolicyName string

+ Reason string

+ RequestID string

+ Timestamp time.Time

+ type PolicyCondition struct

+ Field string

+ Operator string

+ Value string

+ type PolicyDecision struct

+ Decision PolicyAction

+ Matched bool

+ MatchedPolicy *ApprovalPolicy

+ Reason string

+ Request *detection.ApprovalRequest

+ Timestamp time.Time

+ type PolicyEngine struct

+ func NewPolicyEngine() *PolicyEngine

+ func (pe *PolicyEngine) AddPolicy(policy *ApprovalPolicy) error

+ func (pe *PolicyEngine) ClearAuditLog()

+ func (pe *PolicyEngine) Evaluate(request *detection.ApprovalRequest) (*PolicyDecision, error)

+ func (pe *PolicyEngine) GetAuditLog(limit int) []PolicyAuditEntry

+ func (pe *PolicyEngine) GetPolicy(id string) *ApprovalPolicy

+ func (pe *PolicyEngine) GetStatistics() PolicyStatistics

+ func (pe *PolicyEngine) ListPolicies() []*ApprovalPolicy

+ func (pe *PolicyEngine) RemovePolicy(id string) bool

+ func (pe *PolicyEngine) SetMaxAuditLog(max int)

+ func (pe *PolicyEngine) UpdatePolicy(updated *ApprovalPolicy) error

+ type PolicyStatistics struct

+ AutoApprovals int

+ AutoRejections int

+ EnabledPolicies int

+ LoggedOnly int

+ PromptedApprovals int

+ TotalEvaluations int

+ TotalPolicies int

+ type Priority = queue.Priority

+ type ProcessFileInspector interface

+ IsAlive func(pid int32, expectedCreateTimeMs int64) bool

+ OpenFiles func(pid int32) ([]string, error)

+ type RepoPathManager struct

+ func NewRepoPathManager() *RepoPathManager

+ func NewRepoPathManagerWithBase(baseDir string) *RepoPathManager

+ func (m *RepoPathManager) EnsureRepoCloned(ref *GitHubRef) (string, error)

+ func (m *RepoPathManager) GetCloneURL(ref *GitHubRef) string

+ func (m *RepoPathManager) GetRepoPath(ref *GitHubRef) string

+ func (m *RepoPathManager) ResolveGitHubInput(input string) (localPath string, ref *GitHubRef, err error)

+ type Repository interface

+ Close func() error

+ Create func(ctx context.Context, data InstanceData) error

+ CreateSession func(ctx context.Context, session *Session) error

+ Delete func(ctx context.Context, title string) error

+ Get func(ctx context.Context, title string) (*InstanceData, error)

+ GetSession func(ctx context.Context, title string, opts ContextOptions) (*Session, error)

+ GetWithOptions func(ctx context.Context, title string, options LoadOptions) (*InstanceData, error)

+ List func(ctx context.Context) ([]InstanceData, error)

+ ListByStatus func(ctx context.Context, status Status) ([]InstanceData, error)

+ ListByStatusWithOptions func(ctx context.Context, status Status, options LoadOptions) ([]InstanceData, error)

+ ListByTag func(ctx context.Context, tag string) ([]InstanceData, error)

+ ListByTagWithOptions func(ctx context.Context, tag string, options LoadOptions) ([]InstanceData, error)

+ ListSessions func(ctx context.Context, opts ContextOptions) ([]*Session, error)

+ ListWithOptions func(ctx context.Context, options LoadOptions) ([]InstanceData, error)

+ Update func(ctx context.Context, data InstanceData) error

+ UpdateSession func(ctx context.Context, session *Session) error

+ UpdateTimestamps func(ctx context.Context, title string, ...) error

+ type RepositoryOption func(interface{}) error

+ func WithDatabasePath(path string) RepositoryOption

+ type ResponseChunk struct

+ Data []byte

+ Error error

+ Timestamp time.Time

+ type ResponseStream struct

+ func NewResponseStream(sessionName string, ptyAccess *PTYAccess) *ResponseStream

+ func NewResponseStreamWithBuffer(sessionName string, ptyAccess *PTYAccess, bufferSize int) *ResponseStream

+ func (rs *ResponseStream) GetBufferSize() int

+ func (rs *ResponseStream) GetSubscriberCount() int

+ func (rs *ResponseStream) GetSubscriberIDs() []string

+ func (rs *ResponseStream) GetSubscriberInfo(subscriberID string) (created time.Time, exists bool)

+ func (rs *ResponseStream) IsStarted() bool

+ func (rs *ResponseStream) SetBufferSize(size int)

+ func (rs *ResponseStream) Start(ctx context.Context) error

+ func (rs *ResponseStream) Stop() error

+ func (rs *ResponseStream) Subscribe(subscriberID string) (<-chan ResponseChunk, error)

+ func (rs *ResponseStream) Unsubscribe(subscriberID string) error

+ type RestartState struct

+ AutoYes bool

+ ClaudeSessionID string

+ Environment map[string]string

+ Program string

+ Prompt string

+ WorkingDir string

+ type ReviewItem = queue.ReviewItem

+ type ReviewQueue = queue.ReviewQueue

+ func NewReviewQueue() *ReviewQueue

+ type ReviewQueueObserver = queue.ReviewQueueObserver

+ type ReviewQueuePoller struct

+ func NewReviewQueuePoller(queue *ReviewQueue, statusManager *InstanceStatusManager, storage *Storage) *ReviewQueuePoller

+ func NewReviewQueuePollerWithConfig(queue *ReviewQueue, statusManager *InstanceStatusManager, storage *Storage, ...) *ReviewQueuePoller

+ func (rqp *ReviewQueuePoller) AddInstance(instance *Instance)

+ func (rqp *ReviewQueuePoller) CheckSession(inst *Instance)

+ func (rqp *ReviewQueuePoller) FindInstance(sessionID string) *Instance

+ func (rqp *ReviewQueuePoller) GetConfig() ReviewQueuePollerConfig

+ func (rqp *ReviewQueuePoller) GetInstances() []*Instance

+ func (rqp *ReviewQueuePoller) GetMonitoredCount() int

+ func (rqp *ReviewQueuePoller) IsRunning() bool

+ func (rqp *ReviewQueuePoller) RemoveInstance(instanceTitle string)

+ func (rqp *ReviewQueuePoller) SetApprovalProvider(provider ApprovalMetadataProvider)

+ func (rqp *ReviewQueuePoller) SetInstances(instances []*Instance)

+ func (rqp *ReviewQueuePoller) Start(ctx context.Context)

+ func (rqp *ReviewQueuePoller) Stop()

+ func (rqp *ReviewQueuePoller) UpdateConfig(config ReviewQueuePollerConfig)

+ type ReviewQueuePollerConfig struct

+ IdleThreshold time.Duration

+ InputWaitDuration time.Duration

+ PollInterval time.Duration

+ StalenessThreshold time.Duration

+ func DefaultReviewQueuePollerConfig() ReviewQueuePollerConfig

+ type ReviewQueueStatistics = queue.ReviewQueueStatistics

+ type ReviewState struct

+ LastAcknowledged time.Time

+ LastAddedToQueue time.Time

+ LastMeaningfulOutput time.Time

+ LastOutputSignature string

+ LastPromptDetected time.Time

+ LastPromptSignature string

+ LastTerminalUpdate time.Time

+ LastUserResponse time.Time

+ LastViewed time.Time

+ ProcessingGraceUntil time.Time

+ func (rs *ReviewState) ComputePromptSignature(content string) string

+ func (rs *ReviewState) DetectAndTrackPrompt(content string, statusInfo InstanceStatusInfo, sessionTitle string) bool

+ func (rs *ReviewState) IsAcknowledgedAfterOutput() bool

+ func (rs *ReviewState) IsInProcessingGracePeriod() bool

+ func (rs *ReviewState) TimeSinceLastMeaningfulOutput(createdAt time.Time) time.Duration

+ func (rs *ReviewState) TimeSinceLastTerminalUpdate(createdAt time.Time) time.Duration

+ func (rs *ReviewState) UpdateTimestamps(rawContent, filteredContent string, shouldUpdateMeaningful bool, ...)

+ func (rs *ReviewState) UserRespondedAfterPrompt() bool

+ type RevisionTarget struct

+ Author string

+ Description string

+ ID string

+ IsCurrent bool

+ ShortID string

+ Timestamp time.Time

+ type Session struct

+ Activity *ActivityTracking

+ AutoYes bool

+ Cloud *CloudContext

+ CreatedAt time.Time

+ Filesystem *FilesystemContext

+ Git *GitContext

+ ID string

+ Program string

+ Prompt string

+ Status Status

+ Terminal *TerminalContext

+ Title string

+ UI *UIPreferences

+ UpdatedAt time.Time

+ func InstanceToSession(i *Instance) *Session

+ func NewSession(title, program string) *Session

+ func (s *Session) GetBranch() string

+ func (s *Session) GetCategory() string

+ func (s *Session) GetLastMeaningfulOutput() time.Time

+ func (s *Session) GetLastViewed() time.Time

+ func (s *Session) GetPath() string

+ func (s *Session) GetTags() []string

+ func (s *Session) GetTerminalDimensions() (width, height int)

+ func (s *Session) GetTmuxSessionName() string

+ func (s *Session) GetWorkingDir() string

+ func (s *Session) HasActivityTracking() bool

+ func (s *Session) HasCloudContext() bool

+ func (s *Session) HasFilesystemContext() bool

+ func (s *Session) HasGitContext() bool

+ func (s *Session) HasTerminalContext() bool

+ func (s *Session) HasUIPreferences() bool

+ func (s *Session) IsCloudConfigured() bool

+ func (s *Session) NeedsReviewQueueAttention() bool

+ func (s *Session) WithActivityTracking(activity *ActivityTracking) *Session

+ func (s *Session) WithCloudContext(cloud *CloudContext) *Session

+ func (s *Session) WithFilesystemContext(fs *FilesystemContext) *Session

+ func (s *Session) WithGitContext(git *GitContext) *Session

+ func (s *Session) WithTerminalContext(terminal *TerminalContext) *Session

+ func (s *Session) WithUIPreferences(ui *UIPreferences) *Session

+ type SessionHealthChecker struct

+ func NewSessionHealthChecker(storage *Storage) *SessionHealthChecker

+ func (h *SessionHealthChecker) CheckAllSessions() ([]HealthCheckResult, error)

+ func (h *SessionHealthChecker) RecoverUnhealthySessions() error

+ func (h *SessionHealthChecker) ScheduledHealthCheck(interval time.Duration, stopChan <-chan struct{})

+ type SessionType string

+ const SessionTypeDirectory

+ const SessionTypeExistingWorktree

+ const SessionTypeNewWorktree

+ func (st SessionType) IsValid() bool

+ type Status int

+ const Creating

+ const Loading

+ const NeedsApproval

+ const Paused

+ const Ready

+ const Running

+ const Stopped

+ func StatusFromDetected(detected detection.DetectedStatus) Status

+ func (s Status) String() string

+ type StatusChange struct

+ Context string

+ Status detection.DetectedStatus

+ Timestamp time.Time

+ type Storage struct

+ func NewStorageWithRepository(repo Repository) (*Storage, error)

+ func (s *Storage) AddInstance(instance *Instance) error

+ func (s *Storage) Close() error

+ func (s *Storage) DeleteAllInstances() error

+ func (s *Storage) DeleteInstance(title string) error

+ func (s *Storage) GetSession(ctx context.Context, title string, opts ContextOptions) (*Session, error)

+ func (s *Storage) ListSessions(ctx context.Context, opts ContextOptions) ([]*Session, error)

+ func (s *Storage) LoadInstances() ([]*Instance, error)

+ func (s *Storage) SaveInstances(instances []*Instance) error

+ func (s *Storage) SaveInstancesSync(instances []*Instance) error

+ func (s *Storage) SaveSession(ctx context.Context, session *Session) error

+ func (s *Storage) UpdateInstance(instance *Instance) error

+ func (s *Storage) UpdateInstanceLastAddedToQueue(title string, lastAddedToQueue time.Time) error

+ func (s *Storage) UpdateInstanceLastUserResponse(title string, lastUserResponse time.Time) error

+ func (s *Storage) UpdateInstanceProcessingGrace(title string, processingGraceUntil time.Time) error

+ func (s *Storage) UpdateInstanceTimestampsOnly(title string, lastTerminalUpdate, lastMeaningfulOutput time.Time, ...) error

+ type Subscriber struct

+ Ch chan ResponseChunk

+ ID string

+ type TagManager struct

+ func NewTagManager(tags *[]string) TagManager

+ func (tm *TagManager) Add(tag string) error

+ func (tm *TagManager) All() []string

+ func (tm *TagManager) Has(tag string) bool

+ func (tm *TagManager) Remove(tag string)

+ func (tm *TagManager) Set(tags []string) error

+ type TerminalContext struct

+ Height int

+ TerminalType string

+ TmuxPrefix string

+ TmuxServerSocket string

+ TmuxSessionName string

+ Width int

+ func (t *TerminalContext) IsEmpty() bool

+ type TerminalState struct

+ Cols int

+ CurrentStyle CellStyle

+ CursorCol int

+ CursorRow int

+ CursorVisible bool

+ Grid [][]Cell

+ Rows int

+ Version uint64

+ func NewTerminalState(rows, cols int) *TerminalState

+ func (ts *TerminalState) Clone() *TerminalState

+ func (ts *TerminalState) GenerateDelta(fromState *TerminalState) *sessionv1.TerminalData

+ func (ts *TerminalState) GenerateState() *sessionv1.TerminalData

+ func (ts *TerminalState) ProcessOutput(data []byte) error

+ func (ts *TerminalState) Resize(rows, cols int)

+ type TimeRestriction struct

+ DaysOfWeek []time.Weekday

+ EndHour int

+ StartHour int

+ type TmuxProcessManager struct

+ func (tm *TmuxProcessManager) Attach() (chan struct{}, error)

+ func (tm *TmuxProcessManager) CapturePaneContent() (string, error)

+ func (tm *TmuxProcessManager) CapturePaneContentRaw() (string, error)

+ func (tm *TmuxProcessManager) CapturePaneContentWithOptions(startLine, endLine string) (string, error)

+ func (tm *TmuxProcessManager) CaptureViewport(lines int) (string, error)

+ func (tm *TmuxProcessManager) Close() error

+ func (tm *TmuxProcessManager) DetachSafely() error

+ func (tm *TmuxProcessManager) DoesSessionExist() bool

+ func (tm *TmuxProcessManager) FilterBanners(content string) (string, int)

+ func (tm *TmuxProcessManager) GetCursorPosition() (x, y int, err error)

+ func (tm *TmuxProcessManager) GetPTY() (*os.File, error)

+ func (tm *TmuxProcessManager) GetPaneCurrentPath() (string, error)

+ func (tm *TmuxProcessManager) GetPaneDimensions() (width, height int, err error)

+ func (tm *TmuxProcessManager) GetPanePID() (int32, error)

+ func (tm *TmuxProcessManager) HasMeaningfulContent(content string) bool

+ func (tm *TmuxProcessManager) HasSession() bool

+ func (tm *TmuxProcessManager) HasUpdated() (updated bool, hasPrompt bool)

+ func (tm *TmuxProcessManager) IsAlive() bool

+ func (tm *TmuxProcessManager) RefreshClient() error

+ func (tm *TmuxProcessManager) RestoreWithWorkDir(workDir string) error

+ func (tm *TmuxProcessManager) SendKeys(keys string) (int, error)

+ func (tm *TmuxProcessManager) SendPromptWithEnter(prompt string) error

+ func (tm *TmuxProcessManager) Session() *tmux.TmuxSession

+ func (tm *TmuxProcessManager) SetDetachedSize(width, height int, instanceTitle string) error

+ func (tm *TmuxProcessManager) SetSession(s *tmux.TmuxSession)

+ func (tm *TmuxProcessManager) SetWindowSize(cols, rows int) error

+ func (tm *TmuxProcessManager) Start(dir string) error

+ func (tm *TmuxProcessManager) TapEnter() error

+ type UIPreferences struct

+ Category string

+ GroupingStrategy string

+ IsExpanded bool

+ SortOrder string

+ Tags []string

+ func (u *UIPreferences) HasTag(tag string) bool

+ func (u *UIPreferences) IsEmpty() bool

+ type UsageLimit struct

+ MaxUses int

+ PerApproval bool

+ TimeWindow time.Duration

+ type VCSInfo struct

+ CurrentBookmark string

+ CurrentRevision string

+ HasGit bool

+ HasJJ bool

+ HasUncommittedChanges bool

+ IsColocated bool

+ ModifiedFileCount int

+ RepoPath string

+ VCSType string

+ type WorkspaceSwitchRequest struct

+ BaseRevision string

+ ChangeStrategy vcs.ChangeStrategy

+ CreateIfMissing bool

+ Target string

+ Type WorkspaceSwitchType

+ VCSPreference vcs.VCSPreference

+ type WorkspaceSwitchResult struct

+ ChangesHandled string

+ CurrentRevision string

+ Error error

+ PreviousRevision string

+ Success bool

+ VCSType vcs.VCSType

+ type WorkspaceSwitchType int

+ const SwitchTypeDirectory

+ const SwitchTypeRevision

+ const SwitchTypeWorktree

+ func (t WorkspaceSwitchType) String() string

+ type WorktreeInfo struct

+ GitHubOwner string

+ GitHubRepo string

+ IsWorktree bool

+ MainRepoPath string

+ MainRepoRoot string

+ RemoteURL string

+ func DetectWorktree(path string) (*WorktreeInfo, error)

+ type WorktreeTarget struct

+ Bookmark string

+ IsCurrent bool

+ Name string

+ Path string

+ RevisionID string

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