agent

type ACPRouteServiceLookup ¶

type ACPRouteServiceLookup interface {
	ACPRouteServiceID(ctx context.Context, routeID string) (string, error)
}

ACPRouteServiceLookup resolves an ACP route id to its backing service id. The agent manager uses it to enforce that an agent's acp_route_ids all point at the agent's runtime service. It is optional; when nil the consistency check is skipped (the manager still enforces service_id uniqueness).

type ACPRuntime ¶

type ACPRuntime struct {
	ServiceID string `json:"service_id"`
}

ACPRuntime holds only the binding to an ACP service. ACP operational config (permission_mode, allowed_roots, default_cwd) is owned by the ACP service under /admin/acp/services, not duplicated here.

type Agent ¶

type Agent struct {
	ID          string    `json:"id"`
	Name        string    `json:"name"`
	Description string    `json:"description,omitempty"`
	Runtime     Runtime   `json:"runtime"`
	Routes      Routes    `json:"routes"`
	Resources   Resources `json:"resources"`
	Policy      Policy    `json:"policy"`
	Disabled    bool      `json:"disabled"`
	// OwnsService records that this agent auto-created its backing ACP service
	// (provenance). It distinguishes "agent owns this service" from "agent
	// references a pre-existing shared service" for deletion/cascade decisions.
	OwnsService bool      `json:"owns_service,omitempty"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
}

Agent is a first-class management object representing an operator-facing agent identity, not a protocol-specific service.

func (a Agent) ACPServiceID() string

func (a *Agent) Normalize()

func (a *Agent) NormalizeTimestamps(now time.Time)

func (a Agent) Validate() error

type Budget ¶

type Budget struct {
	MaxTurnsPerDay  int `json:"max_turns_per_day,omitempty"`
	MaxTokensPerDay int `json:"max_tokens_per_day,omitempty"`
}

type HTTPRuntime ¶

type HTTPRuntime struct {
	Endpoint string `json:"endpoint"`
	AuthRef  string `json:"auth_ref,omitempty"`
}

HTTPRuntime carries the agent-level endpoint and callback auth for an agent that owns its own lifecycle.

type Manager ¶

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

Manager owns agent CRUD plus the in-memory route/service -> agent index used for write-time attribution. The index is rebuilt on every mutation and never read from the config store on the hot path.

func NewManager(store configstore.ConfigStore) *Manager

func (m *Manager) Create(ctx context.Context, a Agent) error

func (m *Manager) Delete(ctx context.Context, id string) error

func (m *Manager) Get(ctx context.Context, id string) (Agent, error)

func (m *Manager) List(ctx context.Context) ([]Agent, error)

func (m *Manager) Refresh(ctx context.Context) error

func (m *Manager) ResolveAgentID(routeID, serviceID, sessionID string) (string, bool)

func (m *Manager) SetRouteLookup(lookup ACPRouteServiceLookup)

func (m *Manager) Update(ctx context.Context, id string, a Agent) error

type Policy ¶

type Policy struct {
	MaxAgentDepth int     `json:"max_agent_depth,omitempty"`
	Budget        *Budget `json:"budget,omitempty"`
}

Policy holds runtime-agnostic governance only. Runtime-specific config belongs under runtime.<type> or on the backing service.

type Resources ¶

type Resources struct {
	ProviderIDs   []string `json:"provider_ids,omitempty"`
	MCPServiceIDs []string `json:"mcp_service_ids,omitempty"`
	VirtualKeyIDs []string `json:"virtual_key_ids,omitempty"`
}

Resources is a management view of what the agent is allowed to use. It is not enforced inline on the data-plane request path in P0/P1.

type Routes ¶

type Routes struct {
	ACPRouteIDs []string `json:"acp_route_ids,omitempty"`
	LLMRouteIDs []string `json:"llm_route_ids,omitempty"`
	MCPRouteIDs []string `json:"mcp_route_ids,omitempty"`
}

Routes are management/display references used to surface matching ingress routes and to drive attribution; they do not select the execution backend.

type Runtime ¶

type Runtime struct {
	Type string       `json:"type"`
	ACP  *ACPRuntime  `json:"acp,omitempty"`
	HTTP *HTTPRuntime `json:"http,omitempty"`
}

Runtime is authoritative for execution. It binds the agent to exactly one runtime backend instance, selected by Type.