shared

package

Go to main page

Versions in this module

v0

v0.6.1

Mar 27, 2026

v0.6.0

Mar 26, 2026

v0.5.2

Mar 20, 2026

v0.5.1

Mar 20, 2026

v0.5.0

Mar 20, 2026

Changes in this version

type LoopContainerConfig

+ Firewall func(context.Context) (firewall.FirewallManager, error)

v0.4.0

Mar 16, 2026

v0.3.2

Feb 26, 2026

Changes in this version

type LoopContainerConfig

+ Log *logger.Logger

v0.3.1

Feb 25, 2026

v0.3.0

Feb 24, 2026

v0.2.5

Feb 23, 2026

v0.2.4

Feb 23, 2026

Changes in this version

type LoopContainerConfig

+ ProjectManager func() (project.ProjectManager, error)

v0.2.3

Feb 23, 2026

v0.2.2

Feb 23, 2026

v0.2.1

Feb 23, 2026

v0.2.0

Feb 22, 2026

Changes in this version

+ const ErrorLogPrefix

+ const ReadyLogPrefix

type LoopContainerConfig

+ ProjectName string

type LoopContainerResult

+ ProjectName string

type Options

+ ProjectName string

v0.1.9

Feb 18, 2026

v0.1.8

Feb 17, 2026

v0.1.7

Feb 17, 2026

v0.1.6

Feb 16, 2026

Changes in this version

type Options

+ Logger iostreams.Logger

v0.1.5

Feb 15, 2026

v0.1.4

Feb 14, 2026

Changes in this version

+ const ContentTypeText

+ const ContentTypeThinking

+ const ContentTypeToolResult

+ const ContentTypeToolUse

+ const DefaultCallsPerHour

+ const DefaultCompletionThreshold

+ const DefaultLoopDelaySeconds

+ const DefaultMaxConsecutiveTestLoops

+ const DefaultMaxLoops

+ const DefaultOutputDeclineThreshold

+ const DefaultSafetyCompletionThreshold

+ const DefaultSameErrorThreshold

+ const DefaultSessionExpirationHours

+ const DefaultStagnationThreshold

+ const DefaultTimeoutMinutes

+ const EventNotification

+ const EventPostToolUse

+ const EventPreToolUse

+ const EventSessionStart

+ const EventStop

+ const HandlerAgent

+ const HandlerCommand

+ const HandlerPrompt

+ const HookScriptDir

+ const LoopStatusInstructions

+ const MaxHistoryEntries

+ const ResultSubtypeErrorDuringExecution

+ const ResultSubtypeErrorMaxBudget

+ const ResultSubtypeErrorMaxTurns

+ const ResultSubtypeSuccess

+ const StatusBlocked

+ const StatusComplete

+ const StatusPending

+ const StopCheckScriptPath

+ const SystemSubtypeCompactBoundary

+ const SystemSubtypeInit

+ const TestsFailing

+ const TestsNotRun

+ const TestsPassing

+ const WorkTypeDocumentation

+ const WorkTypeImplementation

+ const WorkTypeRefactoring

+ const WorkTypeTesting

+ func AddLoopFlags(cmd *cobra.Command, opts *LoopOptions)

+ func ApplyLoopConfigDefaults(loopOpts *LoopOptions, flags *pflag.FlagSet, cfg *config.LoopConfig)

+ func BuildSystemPrompt(additional string) string

+ func CountCompletionIndicators(output string) int

+ func DefaultHookFiles() map[string][]byte

+ func DetectRateLimitError(output string) bool

+ func ExtractErrorSignature(output string) string

+ func GenerateAgentName() string

+ func InjectLoopHooks(ctx context.Context, containerID string, hooksFile string, ...) error

+ func MakeCreateContainerFunc(cfg *LoopContainerConfig) func(context.Context) (*ContainerStartConfig, error)

+ func MarkVerboseExclusive(cmd *cobra.Command)

+ func NewTextAccumulator() (*TextAccumulator, *StreamHandler)

+ func ResolveLoopImage(ctx context.Context, client *docker.Client, ios *iostreams.IOStreams, ...) (string, error)

+ func ResolvePrompt(prompt, promptFile string) (string, error)

+ func ResolveTasksPrompt(tasksFile, taskPrompt, taskPromptFile string) (string, error)

+ func WireLoopDashboard(opts *Options, ch chan<- LoopDashEvent, setup *LoopContainerResult, ...)

+ func WriteResult(out, errOut io.Writer, result *Result, format *cmdutil.FormatFlags) error

+ type AnalysisResult struct

+ CompletionCount int

+ DurationMS int

+ ErrorSignature string

+ NumTurns int

+ OutputSize int

+ RateLimitHit bool

+ Status *Status

+ TotalCostUSD float64

+ func AnalyzeOutput(output string) *AnalysisResult

+ func AnalyzeStreamResult(text string, result *ResultEvent) *AnalysisResult

+ type AssistantEvent struct

+ Message AssistantMessage

+ ParentToolUseID *string

+ SessionID string

+ Type EventType

+ UUID string

+ type AssistantMessage struct

+ Content []ContentBlock

+ ID string

+ Model string

+ Role string

+ StopReason string

+ Usage *TokenUsage

+ func (m *AssistantMessage) ExtractText() string

+ func (m *AssistantMessage) ToolUseBlocks() []ContentBlock

+ type CircuitBreaker struct

+ func NewCircuitBreaker(threshold int) *CircuitBreaker

+ func NewCircuitBreakerWithConfig(cfg CircuitBreakerConfig) *CircuitBreaker

+ func (cb *CircuitBreaker) Check() bool

+ func (cb *CircuitBreaker) ConsecutiveTestLoops() int

+ func (cb *CircuitBreaker) IsTripped() bool

+ func (cb *CircuitBreaker) NoProgressCount() int

+ func (cb *CircuitBreaker) Reset()

+ func (cb *CircuitBreaker) RestoreState(state CircuitBreakerState)

+ func (cb *CircuitBreaker) SameErrorCount() int

+ func (cb *CircuitBreaker) State() CircuitBreakerState

+ func (cb *CircuitBreaker) Threshold() int

+ func (cb *CircuitBreaker) TripReason() string

+ func (cb *CircuitBreaker) Update(status *Status) (tripped bool, reason string)

+ func (cb *CircuitBreaker) UpdateWithAnalysis(status *Status, analysis *AnalysisResult) UpdateResult

+ type CircuitBreakerConfig struct

+ CompletionThreshold int

+ MaxConsecutiveTestLoops int

+ OutputDeclineThreshold int

+ SafetyCompletionThreshold int

+ SameErrorThreshold int

+ StagnationThreshold int

+ func DefaultCircuitBreakerConfig() CircuitBreakerConfig

+ type CircuitBreakerState struct

+ ConsecutiveCompletionCount int

+ ConsecutiveTestLoops int

+ DeclineCount int

+ LastErrorSignature string

+ LastOutputSize int

+ NoProgressCount int

+ SameErrorCount int

+ TripReason string

+ Tripped bool

+ type CircuitHistory struct

+ Agent string

+ Entries []CircuitHistoryEntry

+ Project string

+ type CircuitHistoryEntry struct

+ CompletionCount int

+ FromState string

+ NoProgressCount int

+ Reason string

+ SameErrorCount int

+ TestLoopCount int

+ Timestamp time.Time

+ ToState string

+ type CircuitState struct

+ Agent string

+ NoProgressCount int

+ Project string

+ TripReason string

+ Tripped bool

+ TrippedAt *time.Time

+ UpdatedAt time.Time

+ type CompactMetadata struct

+ PreTokens int

+ Trigger string

+ type ConcurrencyAction int

+ const ActionAbort

+ const ActionProceed

+ const ActionWorktree

+ func CheckConcurrency(ctx context.Context, cfg *ConcurrencyCheckConfig) (ConcurrencyAction, error)

+ type ConcurrencyCheckConfig struct

+ Client *docker.Client

+ IOStreams *iostreams.IOStreams

+ Project string

+ Prompter func() *prompter.Prompter

+ WorkDir string

+ type Config struct

+ AutoConfirm bool

+ CallsPerHour int

+ CompletionThreshold int

+ LoopDelaySeconds int

+ MaxConsecutiveTestLoops int

+ MaxLoops int

+ OutputDeclineThreshold int

+ SafetyCompletionThreshold int

+ SameErrorThreshold int

+ SessionExpirationHours int

+ StagnationThreshold int

+ TimeoutMinutes int

+ func DefaultConfig() Config

+ func (c Config) GetCallsPerHour() int

+ func (c Config) GetCompletionThreshold() int

+ func (c Config) GetLoopDelaySeconds() int

+ func (c Config) GetMaxConsecutiveTestLoops() int

+ func (c Config) GetMaxLoops() int

+ func (c Config) GetOutputDeclineThreshold() int

+ func (c Config) GetSafetyCompletionThreshold() int

+ func (c Config) GetSameErrorThreshold() int

+ func (c Config) GetSessionExpirationHours() int

+ func (c Config) GetStagnationThreshold() int

+ func (c Config) Timeout() time.Duration

+ type ContainerStartConfig struct

+ Cleanup func()

+ ContainerID string

+ type ContentBlock struct

+ Content json.RawMessage

+ ID string

+ Input json.RawMessage

+ IsError bool

+ Name string

+ Text string

+ Thinking string

+ ToolUseID string

+ Type string

+ func (b *ContentBlock) ToolResultText() string

+ type EventType string

+ const EventTypeAssistant

+ const EventTypeResult

+ const EventTypeStreamEvent

+ const EventTypeSystem

+ const EventTypeUser

+ type HistoryStore struct

+ func DefaultHistoryStore() (*HistoryStore, error)

+ func NewHistoryStore(baseDir string) *HistoryStore

+ func (h *HistoryStore) AddCircuitEntry(project, agent, fromState, toState, reason string, ...) error

+ func (h *HistoryStore) AddSessionEntry(project, agent, event, status, errorMsg string, loopCount int) error

+ func (h *HistoryStore) DeleteCircuitHistory(project, agent string) error

+ func (h *HistoryStore) DeleteSessionHistory(project, agent string) error

+ func (h *HistoryStore) LoadCircuitHistory(project, agent string) (*CircuitHistory, error)

+ func (h *HistoryStore) LoadSessionHistory(project, agent string) (*SessionHistory, error)

+ func (h *HistoryStore) SaveCircuitHistory(history *CircuitHistory) error

+ func (h *HistoryStore) SaveSessionHistory(history *SessionHistory) error

+ type HookConfig map[string][]HookMatcherGroup

+ func DefaultHooks() HookConfig

+ func ResolveHooks(hooksFile string) (HookConfig, map[string][]byte, error)

+ func (hc HookConfig) MarshalSettingsJSON() ([]byte, error)

+ func (hc HookConfig) Validate() error

+ type HookHandler struct

+ Command string

+ Prompt string

+ Timeout int

+ Type string

+ type HookMatcherGroup struct

+ Hooks []HookHandler

+ Matcher string

+ type LoopContainerConfig struct

+ Client *docker.Client

+ Command []string

+ Config *config.Config

+ Flags *pflag.FlagSet

+ GitManager func() (*git.GitManager, error)

+ HostProxy func() hostproxy.HostProxyService

+ IOStreams *iostreams.IOStreams

+ LoopOpts *LoopOptions

+ SocketBridge func() socketbridge.SocketBridgeManager

+ Version string

+ type LoopContainerResult struct

+ AgentName string

+ ContainerID string

+ ContainerName string

+ ProjectCfg *config.Project

+ WorkDir string

+ func SetupLoopContainer(ctx context.Context, cfg *LoopContainerConfig) (*LoopContainerResult, func(), error)

+ type LoopDashEvent struct

+ AgentName string

+ CircuitProgress int

+ CircuitThreshold int

+ CircuitTripped bool

+ Error error

+ ExitReason string

+ ExitSignal bool

+ FilesModified int

+ IterCostUSD float64

+ IterDuration time.Duration

+ IterTokens int

+ IterTurns int

+ Iteration int

+ Kind LoopDashEventKind

+ MaxIterations int

+ OutputChunk string

+ OutputKind OutputKind

+ Project string

+ RateLimit int

+ RateRemaining int

+ StatusText string

+ TasksCompleted int

+ TestsStatus string

+ TotalFiles int

+ TotalTasks int

+ type LoopDashEventKind int

+ const LoopDashEventComplete

+ const LoopDashEventIterEnd

+ const LoopDashEventIterStart

+ const LoopDashEventOutput

+ const LoopDashEventRateLimit

+ const LoopDashEventStart

+ func (k LoopDashEventKind) String() string

+ type LoopDashboardConfig struct

+ AgentName string

+ MaxLoops int

+ Project string

+ type LoopDashboardResult struct

+ Detached bool

+ Err error

+ Interrupted bool

+ func RunLoopDashboard(ios *iostreams.IOStreams, cfg LoopDashboardConfig, ch <-chan LoopDashEvent) LoopDashboardResult

+ type LoopOptions struct

+ Agent string

+ AppendSystemPrompt string

+ CallsPerHour int

+ CompletionThreshold int

+ HooksFile string

+ Image string

+ LoopDelay int

+ MaxConsecutiveTestLoops int

+ MaxLoops int

+ OutputDeclineThreshold int

+ ResetCircuit bool

+ SafetyCompletionThreshold int

+ SameErrorThreshold int

+ SkipPermissions bool

+ StagnationThreshold int

+ StrictCompletion bool

+ TimeoutMinutes int

+ Verbose bool

+ Worktree string

+ func NewLoopOptions() *LoopOptions

+ type Monitor struct

+ func NewMonitor(opts MonitorOptions) *Monitor

+ func (m *Monitor) FormatAPILimitError(isInteractive bool) string

+ func (m *Monitor) FormatLoopEnd(loopNum int, status *Status, err error, outputSize int, elapsed time.Duration) string

+ func (m *Monitor) FormatLoopProgress(loopNum int, status *Status, circuit *CircuitBreaker) string

+ func (m *Monitor) FormatLoopStart(loopNum int) string

+ func (m *Monitor) FormatRateLimitWait(resetTime time.Time) string

+ func (m *Monitor) FormatResult(result *Result) string

+ func (m *Monitor) PrintLoopEnd(loopNum int, status *Status, err error, outputSize int, elapsed time.Duration)

+ func (m *Monitor) PrintLoopProgress(loopNum int, status *Status, circuit *CircuitBreaker)

+ func (m *Monitor) PrintLoopStart(loopNum int)

+ func (m *Monitor) PrintResult(result *Result)

+ type MonitorOptions struct

+ MaxLoops int

+ RateLimiter *RateLimiter

+ ShowRateLimit bool

+ Verbose bool

+ Writer io.Writer

+ type Options struct

+ Agent string

+ CallsPerHour int

+ CompletionThreshold int

+ CreateContainer func(ctx context.Context) (*ContainerStartConfig, error)

+ LoopDelaySeconds int

+ MaxConsecutiveTestLoops int

+ MaxLoops int

+ Monitor *Monitor

+ OnLoopEnd func(loopNum int, status *Status, resultEvent *ResultEvent, err error)

+ OnLoopStart func(loopNum int)

+ OnOutput func(chunk []byte)

+ OnRateLimitHit func() bool

+ OnStreamEvent func(*StreamDeltaEvent)

+ OutputDeclineThreshold int

+ ProjectCfg *config.Project

+ Prompt string

+ ResetCircuit bool

+ SafetyCompletionThreshold int

+ SameErrorThreshold int

+ SessionExpirationHours int

+ SkipPermissions bool

+ StagnationThreshold int

+ SystemPrompt string

+ Timeout time.Duration

+ UseStrictCompletion bool

+ Verbose bool

+ WorkDir string

+ func BuildRunnerOptions(loopOpts *LoopOptions, project *config.Project, agent, prompt, workDir string, ...) Options

+ type OutputKind int

+ const OutputText

+ const OutputToolStart

+ type RateLimitState struct

+ Calls int

+ WindowStart time.Time

+ type RateLimiter struct

+ func NewRateLimiter(limit int) *RateLimiter

+ func (r *RateLimiter) Allow() bool

+ func (r *RateLimiter) CallCount() int

+ func (r *RateLimiter) IsEnabled() bool

+ func (r *RateLimiter) Limit() int

+ func (r *RateLimiter) Record()

+ func (r *RateLimiter) Remaining() int

+ func (r *RateLimiter) ResetTime() time.Time

+ func (r *RateLimiter) RestoreState(state RateLimitState) bool

+ func (r *RateLimiter) State() RateLimitState

+ type Result struct

+ Error error

+ ExitReason string

+ FinalStatus *Status

+ LoopsCompleted int

+ RateLimitHit bool

+ Session *Session

+ func RunLoop(ctx context.Context, cfg RunLoopConfig) (*Result, error)

+ type ResultEvent struct

+ DurationAPIMS int

+ DurationMS int

+ Errors []string

+ IsError bool

+ NumTurns int

+ Result string

+ SessionID string

+ Subtype string

+ TotalCostUSD float64

+ Type EventType

+ Usage *TokenUsage

+ func ParseStream(ctx context.Context, r io.Reader, handler *StreamHandler) (*ResultEvent, error)

+ func (r *ResultEvent) CombinedText() string

+ func (r *ResultEvent) IsSuccess() bool

+ type ResultOutput struct

+ Error string

+ ExitReason string

+ FinalStatus string

+ LoopsCompleted int

+ RateLimitHit bool

+ Success bool

+ TotalFilesModified int

+ TotalTasksCompleted int

+ func NewResultOutput(result *Result) *ResultOutput

+ type RunLoopConfig struct

+ CommandName string

+ Format *cmdutil.FormatFlags

+ IOStreams *iostreams.IOStreams

+ Runner *Runner

+ RunnerOpts Options

+ Setup *LoopContainerResult

+ TUI interface{}

+ Verbose bool

+ type Runner struct

+ func NewRunner(client *docker.Client) (*Runner, error)

+ func NewRunnerWith(client *docker.Client, store *SessionStore, history *HistoryStore) *Runner

+ func (r *Runner) GetCircuitState(project, agent string) (*CircuitState, error)

+ func (r *Runner) GetSession(project, agent string) (*Session, error)

+ func (r *Runner) ResetCircuit(project, agent string) error

+ func (r *Runner) ResetSession(project, agent string) error

+ func (r *Runner) Run(ctx context.Context, opts Options) (*Result, error)

+ func (r *Runner) StartContainer(ctx context.Context, projectCfg *config.Project, ...) (string, *ResultEvent, int, error)

+ type Session struct

+ Agent string

+ InitialPrompt string

+ LastError string

+ LoopsCompleted int

+ NoProgressCount int

+ Project string

+ RateLimitState *RateLimitState

+ StartedAt time.Time

+ Status string

+ TotalFilesModified int

+ TotalTasksCompleted int

+ UpdatedAt time.Time

+ WorkDir string

+ func NewSession(project, agent, prompt, workDir string) *Session

+ func (sess *Session) Age() time.Duration

+ func (sess *Session) IsExpired(hours int) bool

+ func (sess *Session) Update(status *Status, loopErr error)

+ type SessionHistory struct

+ Agent string

+ Entries []SessionHistoryEntry

+ Project string

+ type SessionHistoryEntry struct

+ Error string

+ Event string

+ LoopCount int

+ Status string

+ Timestamp time.Time

+ type SessionStore struct

+ func DefaultSessionStore() (*SessionStore, error)

+ func NewSessionStore(baseDir string) *SessionStore

+ func (s *SessionStore) DeleteCircuitState(project, agent string) error

+ func (s *SessionStore) DeleteSession(project, agent string) error

+ func (s *SessionStore) ListSessions(project string) ([]*Session, error)

+ func (s *SessionStore) LoadCircuitState(project, agent string) (*CircuitState, error)

+ func (s *SessionStore) LoadSession(project, agent string) (*Session, error)

+ func (s *SessionStore) LoadSessionWithExpiration(project, agent string, expirationHours int) (*Session, bool, error)

+ func (s *SessionStore) SaveCircuitState(state *CircuitState) error

+ func (s *SessionStore) SaveSession(session *Session) error

+ type Status struct

+ CompletionIndicators int

+ ExitSignal bool

+ FilesModified int

+ Recommendation string

+ Status string

+ TasksCompleted int

+ TestsStatus string

+ WorkType string

+ func ParseStatus(output string) *Status

+ func (s *Status) HasProgress() bool

+ func (s *Status) IsBlocked() bool

+ func (s *Status) IsComplete() bool

+ func (s *Status) IsCompleteStrict(threshold int) bool

+ func (s *Status) IsTestOnly() bool

+ func (s *Status) String() string

+ type StreamAPIEvent struct

+ ContentBlock *StreamContentBlock

+ Delta *StreamDelta

+ Index int

+ Message *StreamMessageDelta

+ Type string

+ Usage *TokenUsage

+ type StreamContentBlock struct

+ ID string

+ Name string

+ Type string

+ type StreamDelta struct

+ PartialJSON string

+ Text string

+ Type string

+ type StreamDeltaEvent struct

+ Event StreamAPIEvent

+ ParentToolUseID *string

+ SessionID string

+ Type EventType

+ UUID string

+ func (e *StreamDeltaEvent) IsContentBlockStop() bool

+ func (e *StreamDeltaEvent) IsToolStart() bool

+ func (e *StreamDeltaEvent) TextDelta() string

+ func (e *StreamDeltaEvent) ToolName() string

+ type StreamHandler struct

+ OnAssistant func(*AssistantEvent)

+ OnResult func(*ResultEvent)

+ OnStreamEvent func(*StreamDeltaEvent)

+ OnSystem func(*SystemEvent)

+ OnUser func(*UserEvent)

+ type StreamMessageDelta struct

+ StopReason string

+ type SystemEvent struct

+ CWD string

+ CompactMetadata *CompactMetadata

+ Model string

+ PermissionMode string

+ SessionID string

+ Subtype string

+ Tools []string

+ Type EventType

+ UUID string

+ type TextAccumulator struct

+ func (a *TextAccumulator) Text() string

+ func (a *TextAccumulator) ToolCallCount() int

+ type TokenUsage struct

+ CacheCreationInputTokens int

+ CacheReadInputTokens int

+ InputTokens int

+ OutputTokens int

+ func (u *TokenUsage) Total() int

+ type UpdateResult struct

+ CompletionMsg string

+ IsComplete bool

+ Reason string

+ Tripped bool

+ type UserEvent struct

+ Message UserEventMessage

+ ParentToolUseID *string

+ SessionID string

+ Type EventType

+ UUID string

+ type UserEventMessage struct

+ Content []ContentBlock

+ Role string

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