acpclient

Jul 4, 2026

Changes in this version

+ const FlowNodeTypeCheckpoint

type FlowRunStore

+ func (s *FlowRunStore) WriteACPXManifest(manifest acpx.Manifest) error

+ type FlowSwitchEdge = flowjson.SwitchEdge

Jul 3, 2026

Changes in this version

+ const FlowReplayBundleSchema

+ var ErrInvalidJSONRPCMessage = errors.New("invalid acp json-rpc message")

+ var ErrRawHistoryUnavailable = errors.New("acp client raw event history unavailable")

+ func ValidateJSONRPCMessage(message json.RawMessage) error

type Archive

+ RawHistory []json.RawMessage

+ SummaryHistory []ArchiveHistoryEvent

+ func (a *Archive) UnmarshalJSON(b []byte) error

+ type ArchiveHistoryMode string

+ const ArchiveHistoryModeBoth

+ const ArchiveHistoryModeRaw

+ const ArchiveHistoryModeSummary

type Callbacks

+ func (c *Callbacks) EventSnapshot() []EventLogLine

+ func (c *Callbacks) RecordEvent(direction EventDirection, message json.RawMessage) error

type CompareRow

+ Events []EventLogLine

+ type CompareRun struct

+ FinishedAt time.Time

+ PromptDigest string

+ Rows []CompareRow

+ RunDir string

+ RunID string

+ StartedAt time.Time

+ Status string

+ type CompareRunBundle struct

+ AgentDirs map[string]string

+ type CompareRunStore struct

+ func NewCompareRunStore(root string) *CompareRunStore

+ func (s *CompareRunStore) Save(run CompareRun) (CompareRunBundle, error)

+ type EventDirection string

+ const EventDirectionInbound

+ const EventDirectionOutbound

+ type EventLogLine struct

+ At time.Time

+ Direction EventDirection

+ Message json.RawMessage

+ Seq int

+ type EventLogMetadata struct

+ Count int

+ Exists bool

+ Path string

+ SessionID string

type ExportOptions

+ HistoryMode ArchiveHistoryMode

+ type FlowReplayArtifactRef struct

+ Kind string

+ Path string

+ SHA256 string

+ type FlowReplayProjections struct

+ Live string

+ Run string

+ Steps string

+ type FlowReplaySession struct

+ Events string

+ Handle string

+ SessionID string

+ type FlowReplayStep struct

+ Error string

+ NodeID string

+ Output string

+ OutputArtifact FlowReplayArtifactRef

+ PromptArtifact FlowReplayArtifactRef

+ Status string

+ StderrArtifact FlowReplayArtifactRef

+ StdoutArtifact FlowReplayArtifactRef

+ Type string

+ type FlowReplaySummary struct

+ ManifestPath string

+ RunID string

+ SessionCount int

+ Status string

+ StepCount int

+ TraceCount int

+ func LoadFlowReplaySummary(runDir string) (FlowReplaySummary, error)

+ type FlowRunManifest struct

+ Artifacts []FlowReplayArtifactRef

+ Definition string

+ Input string

+ Projections FlowReplayProjections

+ RunID string

+ Schema string

+ Sessions []FlowReplaySession

+ State string

+ Status string

+ Steps []FlowReplayStep

+ Trace string

type FlowRunStore

+ func (s *FlowRunStore) AppendTraceEvent(event FlowTraceEvent) (err error)

+ func (s *FlowRunStore) WriteArtifact(kind string, data []byte) (FlowReplayArtifactRef, error)

+ func (s *FlowRunStore) WriteManifest(manifest FlowRunManifest) error

+ func (s *FlowRunStore) WriteProjection(name string, value any) error

+ type FlowTraceEvent struct

+ Artifact string

+ At time.Time

+ Error string

+ Kind string

+ NodeID string

+ Output string

+ Seq int

+ Session string

+ Status string

+ Type string

+ type JSONRPCMessage json.RawMessage

type Result

+ Events []EventLogLine

type SessionRunner

+ func (r *SessionRunner) LastEvents() []EventLogLine

type Store

+ func (s *Store) AppendEventLog(id string, events []EventLogLine) (err error)

+ func (s *Store) CopyEventLog(id, outputPath string) (err error)

+ func (s *Store) EventLogMetadata(id string) (EventLogMetadata, error)

+ func (s *Store) ReadEventLog(id string) ([]EventLogLine, error)

+ func (s *Store) WriteEventLog(id string, events []EventLogLine) error

Jul 2, 2026

Changes in this version

+ var ErrProfileNotFound = errors.New("acp client profile not found")

+ var ErrProfileShadowsBuiltin = errors.New("acp client profile shadows built-in agent")

type FlowRunOptions

+ Registry Registry

+ type Profile struct

+ CreatedAt time.Time

+ Cwd string

+ Hash string

+ Name string

+ PluginName string

+ PluginVersion string

+ SourceID string

+ SourceKind string

+ Spec AgentSpec

+ Trusted bool

+ UpdatedAt time.Time

+ func (p Profile) DescriptorHash() string

+ type ProfileStore struct

+ func NewDefaultProfileStore() (*ProfileStore, error)

+ func NewProfileStore(path string) *ProfileStore

+ func (s *ProfileStore) Add(profile Profile) error

+ func (s *ProfileStore) Get(name string) (Profile, error)

+ func (s *ProfileStore) List() ([]Profile, error)

+ func (s *ProfileStore) Path() string

+ func (s *ProfileStore) Remove(name string) error

+ func (s *ProfileStore) Trust(name string) error

type Registry

+ func (r Registry) WithProfiles(profiles []Profile) (Registry, error)

Jul 2, 2026

Changes in this version

+ const FlowNodeTypeAction

+ type ActionResult struct

+ Duration time.Duration

+ ExitCode int

+ Stderr string

+ Stdout string

+ type ActionRunOptions struct

+ Args []string

+ Command string

+ Cwd string

+ Env map[string]string

+ Input json.RawMessage

+ type ActionRunner interface

+ RunAction func(context.Context, ActionRunOptions) (ActionResult, error)

type FlowDefinition

+ Requires []string

type FlowNode

+ Cwd string

+ Env map[string]string

+ Input json.RawMessage

type FlowRunOptions

+ ActionOutputLimit int

+ ActionRunner ActionRunner

+ AllowedPermissions []string

+ type WatchCycle struct

+ ACPSessionID string

+ Canceled int

+ Completed int

+ CompletedAt time.Time

+ Cycle int

+ Failed int

+ Idle bool

+ PendingBefore int

+ Processed int

+ Remaining int

+ SessionID string

+ StartedAt time.Time

+ type WatchOptions struct

+ Interval time.Duration

+ MaxCycles int

+ MaxPerCycle int

+ Now func() time.Time

+ Sleep func(context.Context, time.Duration) error

+ StartRunner func(context.Context, AgentSpec, RunOptions, string) (DrainPromptRunner, func() error, error)

+ StopWhenEmpty bool

+ type WatchResult struct

+ ACPSessionID string

+ Canceled int

+ Completed int

+ Cycles int

+ Failed int

+ Processed int

+ Remaining int

+ SessionID string

+ func WatchQueue(ctx context.Context, store *Store, spec AgentSpec, opts RunOptions, ...) (WatchResult, error)

Jul 2, 2026

Changes in this version

+ const FlowNodeTypeACP

+ const FlowNodeTypeCompute

+ const FlowRunStatusCompleted

+ const FlowRunStatusFailed

+ const FlowRunStatusRunning

+ const FlowStepStatusCompleted

+ const FlowStepStatusFailed

+ var ErrInvalidFlowDefinition = errors.New("invalid acp client flow definition")

+ var ErrInvalidSessionArchive = errors.New("invalid acp client archive")

+ var ErrSessionActive = errors.New("acp client session is active")

+ var ErrSessionArchiveCollision = errors.New("acp client archive destination session exists")

+ var ErrUnsupportedArchiveVersion = errors.New("unsupported acp client archive format version")

+ func ExportSession(store *Store, id, outputPath string, opts ExportOptions) error

+ type Archive struct

+ ExportedAt string

+ ExportedBy string

+ FormatVersion int

+ History []ArchiveHistoryEvent

+ Session ArchiveSession

+ type ArchiveHistoryEvent struct

+ CreatedAt time.Time

+ ID string

+ Kind string

+ Prompt string

+ Response string

+ Status string

+ StopReason string

+ UpdatedAt time.Time

+ type ArchiveSession struct

+ Agent string

+ AgentName string

+ CWDOriginal string

+ CWDRelative string

+ CreatedAt string

+ Name *string

+ RecordID string

+ State SessionRecord

+ UpdatedAt string

+ type CompareAgent struct

+ Name string

+ Spec AgentSpec

+ type CompareOptions struct

+ Cwd string

+ Runner CompareRunner

+ Timeout time.Duration

+ type CompareRow struct

+ Agent string

+ Error string

+ Final string

+ Status string

+ StopReason string

+ WallMS int64

+ func Compare(ctx context.Context, agents []CompareAgent, prompt string, opts CompareOptions) ([]CompareRow, error)

+ type CompareRunner interface

+ RunPrompt func(context.Context, AgentSpec, RunOptions, string) (Result, error)

+ type ExportOptions struct

+ HomeDir string

+ Now func() time.Time

+ type FlowDefinition struct

+ Edges []FlowEdge

+ FormatVersion int

+ Name string

+ Nodes []FlowNode

+ StartAt string

+ func LoadFlowDefinition(path string) (FlowDefinition, error)

+ func (def FlowDefinition) Validate() error

+ type FlowEdge struct

+ From string

+ To string

+ type FlowNode struct

+ Agent string

+ Args []string

+ Command string

+ ID string

+ Prompt string

+ Select string

+ Session string

+ Type string

+ Value json.RawMessage

+ type FlowPromptRunner interface

+ Prompt func(context.Context, string) (Result, error)

+ SessionID func() acpsdk.SessionId

+ type FlowRunOptions struct

+ Cwd string

+ DefaultAgent string

+ DefaultArgs []string

+ DefaultCommand string

+ RunID string

+ RunRoot string

+ StartRunner func(context.Context, AgentSpec, RunOptions, string) (FlowPromptRunner, func() error, error)

+ type FlowRunResult struct

+ Outputs map[string]json.RawMessage

+ RunDir string

+ RunID string

+ Status string

+ Steps []FlowStepRecord

+ func RunFlow(ctx context.Context, def FlowDefinition, input map[string]any, ...) (FlowRunResult, error)

+ type FlowRunState struct

+ RunID string

+ Status string

+ Steps []FlowStepRecord

+ type FlowRunStore struct

+ func NewFlowRunStore(rootDir, runID string) (*FlowRunStore, error)

+ func (s *FlowRunStore) Dir() string

+ func (s *FlowRunStore) WriteDefinition(def FlowDefinition) error

+ func (s *FlowRunStore) WriteInput(input any) error

+ func (s *FlowRunStore) WriteState(state FlowRunState) error

+ func (s *FlowRunStore) WriteStep(nodeID string, output json.RawMessage) error

+ type FlowStepRecord struct

+ Error string

+ NodeID string

+ Output json.RawMessage

+ Status string

+ Type string

+ type ImportOptions struct

+ Agent string

+ CommandFingerprint string

+ Cwd string

+ HomeDir string

+ SessionID string

type SessionRecord

+ func ImportSession(store *Store, archivePath string, opts ImportOptions) (SessionRecord, error)

Jul 2, 2026

Changes in this version

+ const QueuePromptStatusCanceled

+ const QueuePromptStatusCompleted

+ const QueuePromptStatusFailed

+ const QueuePromptStatusPending

+ const QueuePromptStatusRunning

+ var ErrDrainBusy = errors.New("acp client session is already being drained")

+ var ErrInvalidOwnerLock = errors.New("acp client owner lock is invalid")

+ var ErrQueuePromptNotFound = errors.New("acp client queue prompt not found")

type Client

+ func (c *Client) StartSession(ctx context.Context, existingSessionID string) (*SessionRunner, error)

+ type DrainOptions struct

+ Max int

+ Now func() time.Time

+ StartRunner func(context.Context, AgentSpec, RunOptions, string) (DrainPromptRunner, func() error, error)

+ type DrainPromptRunner interface

+ Prompt func(context.Context, string) (Result, error)

+ SessionID func() acpsdk.SessionId

+ type DrainResult struct

+ ACPSessionID string

+ Canceled int

+ Completed int

+ Failed int

+ Processed int

+ Remaining int

+ SessionID string

+ func DrainQueue(ctx context.Context, store *Store, spec AgentSpec, opts RunOptions, ...) (DrainResult, error)

+ type QueuedPrompt struct

+ CanceledAt *time.Time

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ Error string

+ ID string

+ Prompt string

+ Response string

+ StartedAt *time.Time

+ Status string

+ StopReason string

type SessionRecord

+ ACPSessionID string

+ PromptQueue []QueuedPrompt

+ type SessionRunner struct

+ func (r *SessionRunner) Prompt(ctx context.Context, prompt string) (Result, error)

+ func (r *SessionRunner) SessionID() acpsdk.SessionId

type Store

+ func (s *Store) AcquireOwner(owner OwnerLock) error

+ func (s *Store) AppendQueuedPrompt(rec SessionRecord, prompt QueuedPrompt) (SessionRecord, error)

+ func (s *Store) CancelPendingQueue(id string, when time.Time) (int, error)

+ func (s *Store) MarkQueueCompleted(id, queueID, response, stopReason string, when time.Time) error

+ func (s *Store) MarkQueueFailed(id, queueID, message string, when time.Time) error

+ func (s *Store) MarkQueueRunning(id, queueID string, when time.Time) error

+ func (s *Store) NextQueuedPrompt(id string) (QueuedPrompt, bool, error)

+ func (s *Store) RecoverStaleQueue(id string, when time.Time) (int, error)

Jul 1, 2026

Changes in this version

+ const PendingPromptStatusCanceled

+ const PendingPromptStatusPending

+ const SessionStatusCancelRequested

+ const SessionStatusCanceled

+ const SessionStatusCompleted

+ const SessionStatusQueued

+ const SessionStatusRunning

+ var ErrMissingCommand = errors.New("acp client command is required")

+ var ErrPathOutsideCWD = errors.New("acp client path is outside cwd")

+ var ErrSessionNotFound = errors.New("acp client session not found")

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

+ var ErrUnknownAgent = errors.New("unknown acp client agent")

+ var ErrWritesDisabled = errors.New("acp client filesystem writes are disabled")

+ type AgentSpec struct

+ Args []string

+ Command string

+ EnvKeys []string

+ Name string

+ func (s AgentSpec) Fingerprint() string

+ func (s AgentSpec) Validate() error

+ type Callbacks struct

+ func NewCallbacks(opts RunOptions) *Callbacks

+ func (*Callbacks) CreateTerminal(context.Context, acpsdk.CreateTerminalRequest) (acpsdk.CreateTerminalResponse, error)

+ func (*Callbacks) KillTerminalCommand(context.Context, acpsdk.KillTerminalCommandRequest) (acpsdk.KillTerminalCommandResponse, error)

+ func (*Callbacks) ReleaseTerminal(context.Context, acpsdk.ReleaseTerminalRequest) (acpsdk.ReleaseTerminalResponse, error)

+ func (*Callbacks) RequestPermission(_ context.Context, p acpsdk.RequestPermissionRequest) (acpsdk.RequestPermissionResponse, error)

+ func (*Callbacks) TerminalOutput(context.Context, acpsdk.TerminalOutputRequest) (acpsdk.TerminalOutputResponse, error)

+ func (*Callbacks) WaitForTerminalExit(context.Context, acpsdk.WaitForTerminalExitRequest) (acpsdk.WaitForTerminalExitResponse, error)

+ func (c *Callbacks) Cwd() string

+ func (c *Callbacks) ReadTextFile(_ context.Context, p acpsdk.ReadTextFileRequest) (acpsdk.ReadTextFileResponse, error)

+ func (c *Callbacks) Reset()

+ func (c *Callbacks) SessionUpdate(ctx context.Context, n acpsdk.SessionNotification) error

+ func (c *Callbacks) Snapshot() ([]acpsdk.SessionNotification, string)

+ func (c *Callbacks) UpdateCount() int

+ func (c *Callbacks) WaitForUpdate(ctx context.Context, previous int)

+ func (c *Callbacks) WriteTextFile(_ context.Context, p acpsdk.WriteTextFileRequest) (acpsdk.WriteTextFileResponse, error)

+ type CancelRequest struct

+ RequestedAt time.Time

+ SessionID string

+ type Client struct

+ func NewInProcessClient(peerInput io.Writer, peerOutput io.Reader, opts RunOptions) *Client

+ func Start(ctx context.Context, spec AgentSpec, opts RunOptions) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) RunPrompt(ctx context.Context, prompt string) (Result, error)

+ type OwnerLock struct

+ CommandFingerprint string

+ PID int

+ SessionID string

+ StartedAt time.Time

+ type PendingPrompt struct

+ CanceledAt *time.Time

+ CreatedAt time.Time

+ ID string

+ Prompt string

+ Status string

+ type Registry struct

+ func DefaultRegistry() Registry

+ func NewRegistry(specs []AgentSpec) Registry

+ func (r Registry) Lookup(name string) (AgentSpec, bool)

+ func (r Registry) Resolve(opts RunOptions) (AgentSpec, error)

+ type Result struct

+ Duration time.Duration

+ SessionID acpsdk.SessionId

+ Stderr string

+ StopReason acpsdk.StopReason

+ Text string

+ Updates []acpsdk.SessionNotification

+ type RunOptions struct

+ Agent string

+ AllowWrites bool

+ Args []string

+ CancelRequested func(sessionID string) bool

+ Command string

+ Cwd string

+ SessionStarted func(sessionID string) error

+ Timeout time.Duration

+ type SessionRecord struct

+ Agent string

+ CommandFingerprint string

+ CreatedAt time.Time

+ Cwd string

+ ID string

+ LastStopReason string

+ PendingPrompt *PendingPrompt

+ Status string

+ Summary string

+ Turns []TurnSummary

+ UpdatedAt time.Time

+ type Store struct

+ func NewDefaultStore() (*Store, error)

+ func NewStore(path string) *Store

+ func (s *Store) CancelRequest(id string) (CancelRequest, error)

+ func (s *Store) ClearOwner(id string) error

+ func (s *Store) Get(id string) (SessionRecord, error)

+ func (s *Store) List() ([]SessionRecord, error)

+ func (s *Store) MarkPendingCanceled(id string, when time.Time) error

+ func (s *Store) Owner(id string) (OwnerLock, error)

+ func (s *Store) Path() string

+ func (s *Store) RequestCancel(id string, when time.Time) error

+ func (s *Store) Upsert(rec SessionRecord) error

+ func (s *Store) WriteOwner(owner OwnerLock) error

+ type TurnSummary struct

+ CreatedAt time.Time

+ Prompt string

+ Response string

+ StopReason string