adapter

Documentation

Overview

Package adapter — resolve: CLI binary path resolution with well-known fallbacks.

LaunchD and other daemon environments have restricted PATH. This resolver searches well-known installation locations when exec.LookPath fails.

Index

• func ResolveBinary(name string) string
• type Artifact
• type AuditMetadata
• type ClaudeAdapter
  • func NewClaudeAdapter() *ClaudeAdapter
  • func (a *ClaudeAdapter) BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd
  • func (a *ClaudeAdapter) ExtractResult(event StreamEvent) TaskResult
  • func (a *ClaudeAdapter) Name() string
  • func (a *ClaudeAdapter) ParseEvent(line []byte) (StreamEvent, error)
• type CodexAdapter
  • func NewCodexAdapter() *CodexAdapter
  • func (a *CodexAdapter) BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd
  • func (a *CodexAdapter) ExtractResult(event StreamEvent) TaskResult
  • func (a *CodexAdapter) Name() string
  • func (a *CodexAdapter) ParseEvent(line []byte) (StreamEvent, error)
• type GeminiAdapter
  • func NewGeminiAdapter() *GeminiAdapter
  • func (a *GeminiAdapter) BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd
  • func (a *GeminiAdapter) ExtractResult(event StreamEvent) TaskResult
  • func (a *GeminiAdapter) Name() string
  • func (a *GeminiAdapter) ParseEvent(line []byte) (StreamEvent, error)
• type ProviderAdapter
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) Get(name string) (ProviderAdapter, error)
  • func (r *Registry) List() []string
  • func (r *Registry) Register(adapter ProviderAdapter)
• type StreamEvent
• type TaskConfig
• type TaskResult

Functions

func ResolveBinary

func ResolveBinary(name string) string

ResolveBinary finds the full path to a CLI binary. First checks exec.LookPath (respects PATH), then searches well-known directories.

Types

type Artifact

type Artifact struct {
	Name     string
	MimeType string
	Data     string
}

Artifact holds a single output artifact from task execution.

type AuditMetadata

type AuditMetadata struct {
	ComputerUse bool
}

AuditMetadata represents audit event metadata generated from task config.

type ClaudeAdapter

type ClaudeAdapter struct{}

ClaudeAdapter implements ProviderAdapter for Claude Code CLI.

func NewClaudeAdapter

func NewClaudeAdapter() *ClaudeAdapter

NewClaudeAdapter creates a new ClaudeAdapter.

func (*ClaudeAdapter) BuildCommand

func (a *ClaudeAdapter) BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd

BuildCommand constructs the exec.Cmd for Claude Code with stream-json output.

func (*ClaudeAdapter) ExtractResult

func (a *ClaudeAdapter) ExtractResult(event StreamEvent) TaskResult

ExtractResult extracts the final task result from a result event.

func (*ClaudeAdapter) Name

func (a *ClaudeAdapter) Name() string

Name returns "claude".

func (*ClaudeAdapter) ParseEvent

func (a *ClaudeAdapter) ParseEvent(line []byte) (StreamEvent, error)

ParseEvent parses a single line of stream-json output into a StreamEvent. Maps Claude's "tool_use" type to the canonical EventToolCall type.

type CodexAdapter

type CodexAdapter struct{}

CodexAdapter implements ProviderAdapter for OpenAI Codex CLI.

func NewCodexAdapter

func NewCodexAdapter() *CodexAdapter

NewCodexAdapter creates a new CodexAdapter.

func (*CodexAdapter) BuildCommand

func (a *CodexAdapter) BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd

BuildCommand constructs the exec.Cmd for Codex CLI.

func (*CodexAdapter) ExtractResult

func (a *CodexAdapter) ExtractResult(event StreamEvent) TaskResult

ExtractResult extracts the final task result from a Codex result event.

func (*CodexAdapter) Name

func (a *CodexAdapter) Name() string

Name returns "codex".

func (*CodexAdapter) ParseEvent

func (a *CodexAdapter) ParseEvent(line []byte) (StreamEvent, error)

ParseEvent parses a single line of Codex JSON output into a StreamEvent. Maps Codex's "tool_call" type to the canonical EventToolCall type.

type GeminiAdapter

type GeminiAdapter struct{}

GeminiAdapter implements ProviderAdapter for Gemini CLI.

func NewGeminiAdapter

func NewGeminiAdapter() *GeminiAdapter

NewGeminiAdapter creates a new GeminiAdapter.

func (*GeminiAdapter) BuildCommand

func (a *GeminiAdapter) BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd

BuildCommand constructs the exec.Cmd for Gemini CLI with stream-json output.

func (*GeminiAdapter) ExtractResult

func (a *GeminiAdapter) ExtractResult(event StreamEvent) TaskResult

ExtractResult extracts the final task result from a Gemini result event.

func (*GeminiAdapter) Name

func (a *GeminiAdapter) Name() string

Name returns "gemini".

func (*GeminiAdapter) ParseEvent

func (a *GeminiAdapter) ParseEvent(line []byte) (StreamEvent, error)

ParseEvent parses a single line of Gemini JSON output into a StreamEvent. Maps Gemini's "tool_call" type to the canonical EventToolCall type.

type ProviderAdapter

type ProviderAdapter interface {
	// Name returns the provider name (e.g., "claude", "codex", "gemini").
	Name() string
	// BuildCommand constructs the exec.Cmd for this provider with the given task context.
	BuildCommand(ctx context.Context, task TaskConfig) *exec.Cmd
	// ParseEvent parses a single line of stream output into a typed event.
	ParseEvent(line []byte) (StreamEvent, error)
	// ExtractResult extracts the final task result from a result event.
	ExtractResult(event StreamEvent) TaskResult
}

ProviderAdapter abstracts CLI provider execution.

type Registry

type Registry struct {
	// contains filtered or unexported fields
}

Registry provides thread-safe storage and lookup of ProviderAdapters.

func NewRegistry

func NewRegistry() *Registry

NewRegistry creates an empty adapter registry.

func (*Registry) Get

func (r *Registry) Get(name string) (ProviderAdapter, error)

Get returns the adapter registered under the given name. Returns an error if no adapter is found.

func (*Registry) List

func (r *Registry) List() []string

List returns the names of all registered adapters in sorted order.

func (*Registry) Register

func (r *Registry) Register(adapter ProviderAdapter)

Register adds a provider adapter to the registry, keyed by adapter.Name().

type StreamEvent

type StreamEvent struct {
	Type    string          // e.g., "system.init", "result"
	Subtype string          // e.g., "init", "task_started"
	Data    json.RawMessage // raw event data
}

StreamEvent represents a parsed event from subprocess output.

type TaskConfig

type TaskConfig struct {
	TaskID      string            // unique task identifier
	SessionID   string            // for --resume
	Prompt      string            // delivered via stdin
	MCPConfig   string            // path to worker-mcp.json
	WorkDir     string            // working directory for subprocess
	EnvVars     map[string]string // additional env vars
	Model       string            // provider-specific model override
	ComputerUse bool              // enable computer use for this task
}

TaskConfig holds the configuration for a subprocess execution.

type TaskResult

type TaskResult struct {
	CostUSD    float64
	DurationMS int64
	SessionID  string
	Output     string
	Artifacts  []Artifact
}

TaskResult holds the extracted result from a completed subprocess.