llm

Jul 12, 2026

Changes in this version

+ type BaseStream struct

+ func NewBaseStream(cancel context.CancelFunc) BaseStream

+ func NewProcessStream(process *LaunchedProcess, cleanup func() error) BaseStream

+ func (s *BaseStream) Cancel()

+ func (s *BaseStream) Cleanup()

+ func (s *BaseStream) CloseLog()

+ func (s *BaseStream) CloseProcessGroup()

+ func (s *BaseStream) Finish(response Response, err error)

+ func (s *BaseStream) HasLog() bool

+ func (s *BaseStream) SessionID() string

+ func (s *BaseStream) SetSessionID(id string)

+ func (s *BaseStream) Wait(ctx context.Context) (Response, error)

+ func (s *BaseStream) WithLogFile(write func(*os.File) (int, error)) (int, error)

+ func (s *BaseStream) Write(p []byte) (int, error)

+ func (s *BaseStream) WriteLog(p []byte)

+ type LaunchedProcess struct

+ func LaunchProcess(ctx context.Context, command string, args []string, dir string, env []string, ...) (*LaunchedProcess, error)

+ func (p *LaunchedProcess) Abort(cleanup func() error)

+ func (p *LaunchedProcess) Command() *exec.Cmd

+ func (p *LaunchedProcess) Context() context.Context

+ func (p *LaunchedProcess) Stderr() io.ReadCloser

+ func (p *LaunchedProcess) Stdin() io.WriteCloser

+ func (p *LaunchedProcess) Stdout() io.ReadCloser

Jul 11, 2026

Changes in this version

type APIOptions

+ FastModeModels []string

type PiRPCOptions

+ FastModeModels []string

type Request

+ Fast bool

type SubprocessOptions

+ FastModeModels []string

type Usage

+ Speed string

Jul 6, 2026

Changes in this version

type Request

+ DurableSession bool

Jun 29, 2026

Changes in this version

+ var ErrReviewerWorkspaceUnsupported = errors.New("llm adapter: missing reviewer workspace capability")

+ func RequireReviewerWorkspace(adapter Adapter) error

+ func SupportsReviewerWorkspace(adapter Adapter) bool

type FakeAdapter

+ ReviewerWorkspaceModeSet bool

+ ReviewerWorkspaceModeValue ReviewerWorkspaceMode

+ func (f *FakeAdapter) ReviewerWorkspaceMode() ReviewerWorkspaceMode

type Request

+ FreshValidationRetrySession bool

+ OnValidationRetry func(*Request) error

+ ReviewerWorkspace *ReviewerWorkspaceRequest

+ type ReviewerWorkspaceCapable interface

+ ReviewerWorkspaceMode func() ReviewerWorkspaceMode

+ type ReviewerWorkspaceMode string

+ const ReviewerWorkspaceNone

+ const ReviewerWorkspacePermissionBounded

+ const ReviewerWorkspaceWrite

+ func AdapterReviewerWorkspaceMode(adapter Adapter) ReviewerWorkspaceMode

+ type ReviewerWorkspaceRequest struct

+ AllowedFiles []string

+ CacheDir string

+ Env []string

+ MaxToolOutputBytes int

+ RepoDir string

+ ScratchDir string

+ TempDir string

type SubprocessAdapter

+ func (a *SubprocessAdapter) ReviewerWorkspaceMode() ReviewerWorkspaceMode

Jun 28, 2026

Changes in this version

+ var ErrCheckoutAccessUnsupported = errors.New("llm adapter: missing checkout access capability")

+ func RequireCheckoutAccess(adapter Adapter) error

+ func SupportsCheckoutAccess(adapter Adapter) bool

+ type CheckoutAccessCapable interface

+ CheckoutAccessLevel func() CheckoutAccessLevel

+ type CheckoutAccessLevel string

+ const CheckoutAccessNone

+ const CheckoutAccessPermissionBounded

+ const CheckoutAccessReadonly

+ func AdapterCheckoutAccessLevel(adapter Adapter) CheckoutAccessLevel

+ type CheckoutAccessRequest struct

+ AllowedFiles []string

+ MaxToolOutputBytes int

+ RootDir string

+ ScratchDir string

type FakeAdapter

+ CheckoutAccessLevelSet bool

+ CheckoutAccessLevelValue CheckoutAccessLevel

+ func (f *FakeAdapter) CheckoutAccessLevel() CheckoutAccessLevel

type Request

+ CheckoutAccess *CheckoutAccessRequest

type SubprocessAdapter

+ func (a *SubprocessAdapter) CheckoutAccessLevel() CheckoutAccessLevel

Jun 27, 2026

Changes in this version

type StructuredResult

+ AcceptedOutput []byte

Jun 24, 2026

Changes in this version

type Findings

+ Constraints []string

+ InspectedFiles []string

+ SkippedFiles []string

Jun 24, 2026

Changes in this version

type FakeAdapter

+ SupportsCheckoutReadonlySet bool

Jun 24, 2026

Changes in this version

+ var ErrCheckoutReadonlyUnsupported = errors.New("llm adapter: missing checkout-readonly capability")

+ func RequireCheckoutReadonly(adapter Adapter) error

+ func SupportsCheckoutReadonly(adapter Adapter) bool

+ type CheckoutReadonlyCapable interface

+ SupportsCheckoutReadonly func() bool

+ type CheckoutReadonlyRequest struct

+ AllowedFiles []string

+ MaxToolOutputBytes int

+ RootDir string

+ ScratchDir string

type FakeAdapter

+ SupportsCheckoutReadonlyValue bool

+ func (f *FakeAdapter) SupportsCheckoutReadonly() bool

type Request

+ CheckoutReadonly *CheckoutReadonlyRequest

type SubprocessAdapter

+ func (a *SubprocessAdapter) SupportsCheckoutReadonly() bool

Jun 24, 2026

Changes in this version

type SelectedAgent

+ AllowedFiles []string

Jun 24, 2026

Changes in this version

type StructuredResult

+ ValidationAttempts []StructuredValidationAttempt

+ type StructuredValidationAttempt struct

+ DecodeError error

+ Label string

+ Response Response

+ SessionID string

+ type StructuredValidationError struct

+ Attempts []StructuredValidationAttempt

+ func (e *StructuredValidationError) Error() string

+ func (e *StructuredValidationError) Is(target error) bool

Jun 16, 2026

Changes in this version

+ var ErrTransient = errors.New("llm: transient provider error")

Jun 9, 2026

Changes in this version

+ var ErrStructuredOutputInvalidAfterRetry = errors.New("structured output invalid after retry")

Jun 2, 2026

Changes in this version

+ type PiRPCAdapter struct

+ func NewPiRPCAdapter(opts PiRPCOptions) *PiRPCAdapter

+ func (a *PiRPCAdapter) Name() string

+ func (a *PiRPCAdapter) Quota(context.Context) (Quota, bool, error)

+ func (a *PiRPCAdapter) Resume(context.Context, string, Request) (Stream, error)

+ func (a *PiRPCAdapter) Start(ctx context.Context, req Request) (Stream, error)

+ func (a *PiRPCAdapter) SupportsCacheAccounting() bool

+ func (a *PiRPCAdapter) SupportsCostReporting() bool

+ func (a *PiRPCAdapter) SupportsResume() bool

+ type PiRPCOptions struct

+ Command string

+ Env []string

+ ScratchDirFactory ScratchDirFactory

+ Timeout time.Duration

Jun 1, 2026

Changes in this version

+ const DefaultMaxFindingBodyLen

+ const DefaultMaxFindingsPerAgent

+ const DefaultMaxResolvedThreads

+ const SchemaVersion

+ var ErrAPIAdapterConfig = errors.New("llm api: invalid configuration")

+ var ErrToolUse = errors.New("llm subprocess: tool use event")

+ var ErrUnsafeSubprocessConfig = errors.New("llm subprocess: unsafe configuration")

+ func DecodeRollup(data []byte, opts RollupOptions) (review.Rollup, error)

+ type APIAdapter struct

+ func NewAPIAdapterFromConfig(llmConfig config.LLMConfig, store APITokenStore, opts APIOptions) (*APIAdapter, error)

+ func NewAnthropicAPIAdapter(opts APIOptions) (*APIAdapter, error)

+ func NewOpenAIAPIAdapter(opts APIOptions) (*APIAdapter, error)

+ func (a *APIAdapter) Name() string

+ func (a *APIAdapter) Quota(context.Context) (Quota, bool, error)

+ func (a *APIAdapter) Resume(context.Context, string, Request) (Stream, error)

+ func (a *APIAdapter) Start(ctx context.Context, req Request) (Stream, error)

+ func (a *APIAdapter) SupportsCacheAccounting() bool

+ func (a *APIAdapter) SupportsCostReporting() bool

+ func (a *APIAdapter) SupportsResume() bool

+ type APIOptions struct

+ APIKey string

+ AnthropicVersion string

+ BaseURL string

+ HTTPClient *http.Client

+ MaxTokens int

+ type APITokenStore interface

+ Get func(profile string, key string) (string, error)

+ type Adapter interface

+ Name func() string

+ Quota func(context.Context) (Quota, bool, error)

+ Resume func(context.Context, string, Request) (Stream, error)

+ Start func(context.Context, Request) (Stream, error)

+ SupportsCacheAccounting func() bool

+ SupportsCostReporting func() bool

+ SupportsResume func() bool

+ type Decoder func([]byte) (T, error)

+ type FakeAdapter struct

+ NameValue string

+ QuotaErr error

+ QuotaSupported bool

+ QuotaValue Quota

+ SupportsCacheAccountingValue bool

+ SupportsCostReportingValue bool

+ SupportsResumeValue bool

+ func (f *FakeAdapter) Name() string

+ func (f *FakeAdapter) Queue(result FakeResult)

+ func (f *FakeAdapter) Quota(context.Context) (Quota, bool, error)

+ func (f *FakeAdapter) Requests() []Request

+ func (f *FakeAdapter) Resume(ctx context.Context, sessionID string, req Request) (Stream, error)

+ func (f *FakeAdapter) Resumes() []ResumeRequest

+ func (f *FakeAdapter) Start(ctx context.Context, req Request) (Stream, error)

+ func (f *FakeAdapter) SupportsCacheAccounting() bool

+ func (f *FakeAdapter) SupportsCostReporting() bool

+ func (f *FakeAdapter) SupportsResume() bool

+ type FakeResult struct

+ Response Response

+ SessionID string

+ StartErr error

+ WaitErr error

+ type FindingIDGenerator func() (review.FindingID, error)

+ type Findings struct

+ AgentID string

+ Findings []review.Finding

+ func DecodeFindings(data []byte, opts FindingsOptions) (Findings, error)

+ type FindingsOptions struct

+ ChangedFiles map[string]bool

+ KnownAgents map[string]bool

+ MaxBodyLength int

+ MaxFindingsPerAgent int

+ NewFindingID FindingIDGenerator

+ SeverityCaps map[review.Severity]int

+ type Quota struct

+ BlockRemainingPct float64

+ WeeklyRemainingPct float64

+ type Request struct

+ Effort string

+ LogPath string

+ Model string

+ Prompt string

+ type Response struct

+ DurationMS int64

+ StructuredOutput []byte

+ Usage Usage

+ func RunStructured[T any](ctx context.Context, adapter Adapter, req Request, decode Decoder[T]) (T, Response, error)

+ type ResumeRequest struct

+ Request Request

+ SessionID string

+ type RollupOptions struct

+ FindingSeverities map[review.FindingID]review.Severity

+ MajorEventRequestsChanges bool

+ type ScratchDirFactory func() (string, func() error, error)

+ type SelectedAgent struct

+ AgentID string

+ Files []string

+ Rationale string

+ type Selection struct

+ Reasoning string

+ SelectedAgents []SelectedAgent

+ ThreadActions []review.ThreadAction

+ func DecodeSelection(data []byte, opts SelectionOptions) (Selection, error)

+ type SelectionOptions struct

+ ChangedFiles map[string]bool

+ KnownAgents map[string]bool

+ KnownThreads map[string]bool

+ MaxResolvedThreads int

+ type Stream interface

+ SessionID func() string

+ Wait func(context.Context) (Response, error)

+ type StructuredResult struct

+ Response Response

+ SessionID string

+ Value T

+ func RunStructuredWithSessionResume[T any](ctx context.Context, adapter Adapter, resumeSessionID string, req Request, ...) (StructuredResult[T], error)

+ func RunStructuredWithSession[T any](ctx context.Context, adapter Adapter, req Request, decode Decoder[T]) (StructuredResult[T], error)

+ type SubprocessAdapter struct

+ func NewClaudeCLIAdapter(opts SubprocessOptions) *SubprocessAdapter

+ func NewCodexCLIAdapter(opts SubprocessOptions) *SubprocessAdapter

+ func (a *SubprocessAdapter) Name() string

+ func (a *SubprocessAdapter) Quota(context.Context) (Quota, bool, error)

+ func (a *SubprocessAdapter) Resume(context.Context, string, Request) (Stream, error)

+ func (a *SubprocessAdapter) Start(ctx context.Context, req Request) (Stream, error)

+ func (a *SubprocessAdapter) SupportsCacheAccounting() bool

+ func (a *SubprocessAdapter) SupportsCostReporting() bool

+ func (a *SubprocessAdapter) SupportsResume() bool

+ type SubprocessOptions struct

+ AllowBestEffortNoTools bool

+ Command string

+ Env []string

+ ScratchDirFactory ScratchDirFactory

+ Timeout time.Duration

+ type Usage struct

+ CacheCreate *int

+ CacheRead *int

+ CostUSD *float64

+ TokensIn *int

+ TokensOut *int