acp

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

type AcpSessionStatus struct {
	SessionKey     string                         `json:"session_key"`
	Backend        string                         `json:"backend"`
	Agent          string                         `json:"agent"`
	Identity       *SessionIdentity               `json:"identity,omitempty"`
	State          string                         `json:"state"`
	Mode           runtime.AcpRuntimeSessionMode  `json:"mode"`
	RuntimeOptions map[string]any                 `json:"runtime_options"`
	Capabilities   runtime.AcpRuntimeCapabilities `json:"capabilities"`
	RuntimeStatus  *runtime.AcpRuntimeStatus      `json:"runtime_status,omitempty"`
	LastActivityAt int64                          `json:"last_activity_at"`
	LastError      string                         `json:"last_error,omitempty"`
}

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

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

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

type CancelSessionInput struct {
	Cfg        *config.Config
	SessionKey string
	Reason     string
}

type CloseSessionInput struct {
	Cfg               *config.Config
	SessionKey        string
	Reason            string
	RequireAcpSession bool
	ClearMeta         bool
}

type CloseSessionResult struct {
	RuntimeClosed bool
	RuntimeNotice string
	MetaCleared   bool
}

type GetSessionStatusInput struct {
	Cfg        *config.Config
	SessionKey string
}

type IdleCandidate struct {
	SessionKey    string
	LastTouchedAt time.Time
	Handle        *runtime.AcpRuntimeHandle
}

type InitializeSessionInput struct {
	Cfg        *config.Config
	SessionKey string
	Agent      string
	Mode       runtime.AcpRuntimeSessionMode
	Cwd        string
	BackendID  string
}

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

type ManagerObservabilitySnapshot struct {
	RuntimeCache RuntimeCacheSnapshot `json:"runtime_cache"`
	Turns        TurnsSnapshot        `json:"turns"`
	ErrorsByCode map[string]int       `json:"errors_by_code"`
}

type RunTrackedTurnInput struct {
	Cfg        *config.Config
	SessionKey string
	Text       string
	Mode       runtime.AcpRuntimePromptMode
	RequestID  string
}

type RunTrackedTurnResult struct {
	EventChan <-chan runtime.AcpRuntimeEvent
	RequestID string
}

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

type RuntimeCacheSnapshot struct {
	ActiveSessions int    `json:"active_sessions"`
	IdleTtlMs      int64  `json:"idle_ttl_ms"`
	EvictedTotal   int    `json:"evicted_total"`
	LastEvictedAt  *int64 `json:"last_evicted_at,omitempty"`
}

type SessionAcpMeta struct {
	Backend            string                        `json:"backend"`
	Agent              string                        `json:"agent"`
	RuntimeSessionName string                        `json:"runtime_session_name"`
	Identity           *SessionIdentity              `json:"identity,omitempty"`
	Mode               runtime.AcpRuntimeSessionMode `json:"mode"`
	RuntimeOptions     map[string]any                `json:"runtime_options,omitempty"`
	Cwd                string                        `json:"cwd"`
	State              string                        `json:"state"` // "idle", "running", "error"
	LastError          string                        `json:"last_error,omitempty"`
	LastActivityAt     int64                         `json:"last_activity_at"`
}

type SessionIdentity struct {
	State            string `json:"state"`  // "pending" or "resolved"
	Source           string `json:"source"` // "ensure" or "status"
	LastUpdatedAt    int64  `json:"last_updated_at"`
	BackendSessionID string `json:"backend_session_id,omitempty"`
	AgentSessionID   string `json:"agent_session_id,omitempty"`
}

type SessionResolution struct {
	Kind       string // "none", "ready", "stale"
	SessionKey string
	Meta       *SessionAcpMeta
	Error      error
}

type SessionRuntimeOptions struct {
	RuntimeMode string `json:"runtime_mode"`
	Cwd         string `json:"cwd"`
}

type SetSessionConfigOptionInput struct {
	Cfg        *config.Config
	SessionKey string
	Key        string
	Value      string
}

type SetSessionRuntimeModeInput struct {
	Cfg         *config.Config
	SessionKey  string
	RuntimeMode string
}

type SpawnAcpContext struct {
	AgentSessionKey string // Parent session key
	AgentChannel    string // Channel type
	AgentAccountID  string // Channel account ID
	AgentTo         string // Target recipient
	AgentThreadID   string // Thread ID
}

type SpawnAcpMode string

type SpawnAcpParams struct {
	Task    string       // The task to execute
	Label   string       // Optional label for the session
	AgentID string       // Target agent ID
	Cwd     string       // Working directory
	Mode    SpawnAcpMode // "run" or "session"
	Thread  bool         // Whether to bind to a thread
}

type SpawnAcpResult struct {
	Status          string       // "accepted", "forbidden", "error"
	ChildSessionKey string       // The session key of the spawned ACP session
	RunID           string       // The run ID
	Mode            SpawnAcpMode // The spawn mode
	Note            string       // Optional note
	Error           string       // Error message if status is "error"
}

type StartupIdentityReconcileResult struct {
	Checked  int
	Resolved int
	Failed   int
}

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

type ThreadBindingPolicy struct {
	Channel       string // Channel type
	AccountID     string // Account identifier
	Kind          string // "acp" or "subagent"
	Enabled       bool   // Whether thread bindings are enabled
	SpawnEnabled  bool   // Whether spawning new bindings is allowed
	IdleTimeoutMs int    // Idle timeout in milliseconds
	MaxAgeMs      int    // Maximum age in milliseconds
}

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

type TurnsSnapshot struct {
	Active           int   `json:"active"`
	QueueDepth       int   `json:"queue_depth"`
	Completed        int   `json:"completed"`
	Failed           int   `json:"failed"`
	AverageLatencyMs int64 `json:"average_latency_ms"`
	MaxLatencyMs     int64 `json:"max_latency_ms"`
}