Versions in this module Expand all Collapse all v1 v1.4.0 Oct 20, 2026 Changes in this version + func NewHandler(taskStore TaskStore, agentVersions AgentVersionStore, approvals ApprovalStore, ...) http.Handler + type AgentVersionStore interface + CreateAgentVersion func(context.Context, store.CreateAgentVersionInput) (store.CreateAgentVersionResult, error) + GetAgentVersion func(context.Context, string, uuid.UUID) (store.AgentVersion, error) + type ApprovalStore interface + DecideToolApproval func(context.Context, store.DecideToolApprovalInput) (store.ToolApproval, error) + GetToolApproval func(context.Context, string, uuid.UUID) (store.ToolApproval, error) + ListToolDescriptors func(context.Context, string) ([]store.ToolDescriptor, error) + type AuditStore interface + ExportAuditChain func(context.Context, string) ([]store.AuditEvent, error) + ListAudit func(context.Context, store.ListAuditInput) ([]store.AuditEvent, error) + VerifyAuditChain func(context.Context, string) (store.AuditVerification, error) + type Handler struct + type MemoryAPI interface + Get func(context.Context, string, uuid.UUID) (store.MemoryRecord, error) + Put func(context.Context, memory.PutInput) (store.MemoryRecord, bool, error) + Search func(context.Context, memory.SearchInput) ([]store.MemoryRecord, error) + Tombstone func(context.Context, string, uuid.UUID, int64) (store.MemoryRecord, error) + type MetricsStore interface + AggregateMetrics func(context.Context, string, time.Time) (*observability.Metrics, error) + type Option func(*Handler) + func WithAuditSigningKey(keyID string, key ed25519.PrivateKey) Option + func WithAuditStore(audit AuditStore) Option + func WithMaxSSESubscribers(limit int) Option + func WithMetricsStore(metrics MetricsStore) Option + func WithNamespaceStore(store namespace.Store) Option + func WithPackageAdmission(registry *agentpkg.Registry) Option + func WithReadiness(probe func(context.Context) error) Option + func WithRequestTimeouts(readTimeout, writeTimeout time.Duration) Option + func WithRuntimePoolOperatorStore(runtimePools RuntimePoolOperatorStore) Option + func WithSupervisor(sup *supervisor.Supervisor, store supervisor.Store) Option + func WithTenantQuotaStore(quotas TenantQuotaStore) Option + func WithWorkflowStore(workflows WorkflowStore) Option + type RuntimePoolOperatorStore interface + UpdateRuntimePoolStatus func(context.Context, store.UpdateRuntimePoolStatusInput) (store.RuntimePoolState, error) + type TaskStore interface + CreateTask func(context.Context, store.CreateTaskInput) (store.CreateTaskResult, error) + GetTask func(context.Context, string, uuid.UUID) (store.Task, error) + GetTaskBudget func(context.Context, string, uuid.UUID) (store.TaskBudgetStatus, error) + RequestTaskCancellation func(context.Context, string, uuid.UUID, int64) (store.Task, error) + type TenantQuotaStore interface + DeleteTenantQuota func(context.Context, string) error + GetTenantQuota func(context.Context, string) (store.TenantQuota, error) + GetTenantQuotaUsage func(context.Context, string, time.Time) (store.TenantWindowUsage, error) + SetTenantQuota func(context.Context, store.SetTenantQuotaInput) (store.TenantQuota, error) + type WorkflowStore interface + CreateWorkflow func(context.Context, store.CreateWorkflowInput) (store.CreateWorkflowResult, error) + DecideWorkflowStepApproval func(context.Context, store.DecideWorkflowStepApprovalInput) (store.WorkflowStep, error) + GetWorkflow func(context.Context, string, uuid.UUID) (store.Workflow, error) + ListWorkflowSteps func(context.Context, string, uuid.UUID) ([]store.WorkflowStep, error) + RequestWorkflowCancellation func(context.Context, string, uuid.UUID, int64) (store.Workflow, error)
Go to main page