provider

type AbsolutePath string

type AgentCLICommand string

type AgentCLIProcess interface {
	PID() int
	Stdin() io.WriteCloser
	Stdout() io.ReadCloser
	Stderr() io.ReadCloser
	Wait() error
	Stop(context.Context) error
}

type AgentCLIProcessManager interface {
	Start(context.Context, AgentCLIProcessSpec) (AgentCLIProcess, error)
}

type AgentCLIProcessSpec struct {
	Command          AgentCLICommand
	Args             []string
	WorkingDirectory *AbsolutePath
	Environment      []string
}

type CLIRateLimit struct {
	Provider   CLIRateLimitProvider `json:"provider"`
	ClaudeCode *ClaudeCodeRateLimit `json:"claude_code,omitempty"`
	Codex      *CodexRateLimit      `json:"codex,omitempty"`
	Gemini     *GeminiRateLimit     `json:"gemini,omitempty"`
	Raw        map[string]any       `json:"raw,omitempty"`
}

type CLIRateLimitProvider string

type CLIUsage struct {
	Provider           CLIUsageProvider `json:"provider"`
	Source             CLIUsageSource   `json:"source"`
	Model              string           `json:"model,omitempty"`
	CostUSD            *float64         `json:"cost_usd,omitempty"`
	ModelContextWindow *int64           `json:"model_context_window,omitempty"`
	Total              CLIUsageTokens   `json:"total"`
	Delta              CLIUsageTokens   `json:"delta,omitempty"`
	Raw                json.RawMessage  `json:"raw,omitempty"`
	Claude             *ClaudeCodeUsage `json:"claude,omitempty"`
	Gemini             *GeminiCLIUsage  `json:"gemini,omitempty"`
}

type CLIUsageProvider string

type CLIUsageSource string

type CLIUsageTokens struct {
	InputTokens              int64 `json:"input_tokens,omitempty"`
	OutputTokens             int64 `json:"output_tokens,omitempty"`
	TotalTokens              int64 `json:"total_tokens,omitempty"`
	CachedInputTokens        int64 `json:"cached_input_tokens,omitempty"`
	CacheCreationInputTokens int64 `json:"cache_creation_input_tokens,omitempty"`
	ReasoningTokens          int64 `json:"reasoning_tokens,omitempty"`
	PromptTokens             int64 `json:"prompt_tokens,omitempty"`
	CandidateTokens          int64 `json:"candidate_tokens,omitempty"`
	ToolTokens               int64 `json:"tool_tokens,omitempty"`
}

type ClaudeCodeAdapter interface {
	Start(context.Context, ClaudeCodeSessionSpec) (ClaudeCodeSession, error)
}

type ClaudeCodeContentBlock struct {
	Kind      ClaudeCodeContentBlockKind
	ID        string
	Name      string
	Input     map[string]any
	Text      string
	ToolUseID string
	Content   any
	IsError   bool
}

type ClaudeCodeContentBlockKind string

type ClaudeCodeEvent struct {
	Kind            ClaudeCodeEventKind
	Raw             json.RawMessage
	UnknownType     string
	Subtype         string
	SessionID       string
	ParentToolUseID string
	Message         json.RawMessage
	Data            json.RawMessage
	Result          string
	Model           string
	Usage           json.RawMessage
	UsageInfo       *CLIUsage
	RateLimit       json.RawMessage
	RateLimitInfo   *CLIRateLimit
	Event           json.RawMessage
	UUID            string
	IsError         bool
	NumTurns        int
	DurationMS      int
	DurationAPIMS   int
	TotalCostUSD    *float64
}

type ClaudeCodeEventKind string

type ClaudeCodeRateLimit struct {
	Status                string     `json:"status,omitempty"`
	RateLimitType         string     `json:"rate_limit_type,omitempty"`
	ResetsAt              *time.Time `json:"resets_at,omitempty"`
	Utilization           *float64   `json:"utilization,omitempty"`
	SurpassedThreshold    *float64   `json:"surpassed_threshold,omitempty"`
	OverageStatus         string     `json:"overage_status,omitempty"`
	OverageDisabledReason string     `json:"overage_disabled_reason,omitempty"`
	IsUsingOverage        *bool      `json:"is_using_overage,omitempty"`
}

type ClaudeCodeSession interface {
	SessionID() (ClaudeCodeSessionID, bool)
	Events() <-chan ClaudeCodeEvent
	Errors() <-chan error
	Send(context.Context, ClaudeCodeTurnInput) error
	Close(context.Context) error
}

type ClaudeCodeSessionID string

type ClaudeCodeSessionSpec struct {
	Command                AgentCLICommand
	BaseArgs               []string
	WorkingDirectory       *AbsolutePath
	Environment            []string
	AllowedTools           []string
	AppendSystemPrompt     string
	MaxTurns               *int
	MaxBudgetUSD           *float64
	ResumeSessionID        *ClaudeCodeSessionID
	IncludePartialMessages bool
}

type ClaudeCodeToolUseSemantics struct {
	Command string
}

type ClaudeCodeTurnInput struct {
	Prompt string
}

type ClaudeCodeUsage struct {
	ServiceTier  string `json:"service_tier,omitempty"`
	InferenceGeo string `json:"inference_geo,omitempty"`
}

type CodexRateLimit struct {
	LimitID   string                `json:"limit_id,omitempty"`
	LimitName string                `json:"limit_name,omitempty"`
	Primary   *CodexRateLimitWindow `json:"primary,omitempty"`
	Secondary *CodexRateLimitWindow `json:"secondary,omitempty"`
	PlanType  string                `json:"plan_type,omitempty"`
}

type CodexRateLimitWindow struct {
	UsedPercent   *float64   `json:"used_percent,omitempty"`
	WindowMinutes int64      `json:"window_minutes,omitempty"`
	ResetsAt      *time.Time `json:"resets_at,omitempty"`
}

type Counter interface {
	Add(float64)
}

type Event struct {
	Topic       Topic           `json:"topic"`
	Type        EventType       `json:"type"`
	Payload     json.RawMessage `json:"payload,omitempty"`
	PublishedAt time.Time       `json:"published_at"`
}

type EventProvider interface {
	Publish(ctx context.Context, event Event) error
	Subscribe(ctx context.Context, topics ...Topic) (<-chan Event, error)
	Close() error
}

type EventType string

type ExecutableResolver interface {
	LookPath(name string) (string, error)
}

type Gauge interface {
	Set(float64)
}

type GeminiCLIAPIUsage struct {
	TotalRequests  int64 `json:"total_requests,omitempty"`
	TotalErrors    int64 `json:"total_errors,omitempty"`
	TotalLatencyMS int64 `json:"total_latency_ms,omitempty"`
}

type GeminiCLIModelUsage struct {
	API    GeminiCLIAPIUsage             `json:"api"`
	Tokens CLIUsageTokens                `json:"tokens"`
	Roles  map[string]GeminiCLIRoleUsage `json:"roles,omitempty"`
}

type GeminiCLIRoleUsage struct {
	API    GeminiCLIAPIUsage `json:"api"`
	Tokens CLIUsageTokens    `json:"tokens"`
}

type GeminiCLIUsage struct {
	DurationMS int64                          `json:"duration_ms,omitempty"`
	ToolCalls  int64                          `json:"tool_calls,omitempty"`
	Models     map[string]GeminiCLIModelUsage `json:"models,omitempty"`
}

type GeminiRateLimit struct {
	AuthType  string                  `json:"auth_type,omitempty"`
	Remaining *int64                  `json:"remaining,omitempty"`
	Limit     *int64                  `json:"limit,omitempty"`
	ResetTime *time.Time              `json:"reset_time,omitempty"`
	Buckets   []GeminiRateLimitBucket `json:"buckets,omitempty"`
}

type GeminiRateLimitBucket struct {
	ModelID           string     `json:"model_id,omitempty"`
	TokenType         string     `json:"token_type,omitempty"`
	RemainingAmount   string     `json:"remaining_amount,omitempty"`
	RemainingFraction *float64   `json:"remaining_fraction,omitempty"`
	ResetTime         *time.Time `json:"reset_time,omitempty"`
}

type Histogram interface {
	Record(float64)
}

type MetricsProvider interface {
	Counter(name string, tags Tags) Counter
	Histogram(name string, tags Tags) Histogram
	Gauge(name string, tags Tags) Gauge
}

type ServiceName string

type Span interface {
	End()
	RecordError(err error)
	SetAttributes(attrs ...SpanAttribute)
	SetStatus(code SpanStatusCode, description string)
	TraceID() string
	SpanID() string
}

type SpanAttribute struct {
	Key         string
	Type        SpanAttributeType
	StringValue string
	Int64Value  int64
	BoolValue   bool
}

type SpanAttributeType uint8

type SpanKind string

type SpanStartOption interface {
	// contains filtered or unexported methods
}

type SpanStatusCode string

type Tags map[string]string

type Topic string

type TraceProvider interface {
	ExtractHTTPContext(ctx context.Context, header http.Header) context.Context
	InjectHTTPHeaders(ctx context.Context, header http.Header)
	StartSpan(ctx context.Context, name string, opts ...SpanStartOption) (context.Context, Span)
	Shutdown(ctx context.Context) error
}

type UserServiceInstallSpec struct {
	Name             ServiceName
	Description      string
	ProgramPath      AbsolutePath
	Arguments        []string
	WorkingDirectory AbsolutePath
	EnvironmentFile  AbsolutePath
	StdoutPath       AbsolutePath
	StderrPath       AbsolutePath
}

type UserServiceLogsOptions struct {
	Follow bool
	Lines  int
	Stdout io.Writer
	Stderr io.Writer
}

type UserServiceManager interface {
	Platform() string
	Apply(context.Context, UserServiceInstallSpec) error
	Down(context.Context, ServiceName) error
	Restart(context.Context, ServiceName) error
	Logs(context.Context, ServiceName, UserServiceLogsOptions) error
}