core

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 29, 2026 License: MIT Imports: 66 Imported by: 0

Documentation

Overview

Package core provides the shared transport-facing API layer used by HTTP and UDS bindings.

Index

Constants

View Source 
const (
	// WebhookTimestampHeader is the required HTTP header that carries the
	// signed webhook timestamp.
	WebhookTimestampHeader = "X-AGH-Webhook-Timestamp"
	// WebhookSignatureHeader is the required HTTP header that carries the HMAC
	// signature for webhook delivery.
	WebhookSignatureHeader = "X-AGH-Webhook-Signature"
	// WebhookDeliveryIDHeader identifies one webhook delivery so replayed
	// requests can be rejected inside the trigger engine.
	WebhookDeliveryIDHeader = "X-AGH-Webhook-Delivery-ID"
)

Variables

View Source 
var (
	// ErrMemoryRejected marks controller rejections that should surface as 422.
	ErrMemoryRejected = errors.New("memory rejected")
	// ErrMemoryUnsupported marks registered Slice 1 routes whose backing runtime
	// service is intentionally not wired yet.
	ErrMemoryUnsupported = errors.New("memory operation unsupported")
)
View Source 
var ErrAutomationValidation = errors.New("automation validation error")

ErrAutomationValidation is the sentinel for automation request validation failures.

View Source 
var ErrModelCatalogUnavailable = errors.New("model catalog service unavailable")

ErrModelCatalogUnavailable reports that the daemon model catalog surface is not configured.

View Source 
var ErrModelCatalogValidation = errors.New("model catalog validation error")

ErrModelCatalogValidation is the sentinel for malformed model catalog requests.

View Source 
var ErrNetworkValidation = errors.New("network validation error")

ErrNetworkValidation is the sentinel for malformed network control-plane requests.

View Source 
var ErrRequestBodyTooLarge = errors.New("request body too large")

ErrRequestBodyTooLarge is the shared transport sentinel for request bodies rejected by HTTP MaxBytesReader enforcement.

View Source 
var ErrSettingsConflict = errors.New("settings conflict")

ErrSettingsConflict is the sentinel for conflicting settings mutations or scope combinations.

View Source 
var ErrSettingsForbidden = errors.New("settings forbidden")

ErrSettingsForbidden is the sentinel for settings operations rejected by transport policy.

View Source 
var ErrSettingsNotFound = errors.New("settings not found")

ErrSettingsNotFound is the sentinel for missing settings resources.

View Source 
var ErrSettingsValidation = errors.New("settings validation error")

ErrSettingsValidation is the sentinel for settings request validation failures.

View Source 
var ErrSkillNotFound = errors.New("skill not found")

ErrSkillNotFound is the sentinel for a missing skill.

View Source 
var ErrSkillUnprocessable = errors.New("skill unprocessable")

ErrSkillUnprocessable is the sentinel for semantically invalid skill layers.

View Source 
var ErrSkillValidation = errors.New("skill validation error")

ErrSkillValidation is the sentinel for skill request validation failures.

Functions

func ACPCapsPayloadFromInfo 

func ACPCapsPayloadFromInfo(caps acp.Caps) *contract.ACPCapsPayload

ACPCapsPayloadFromInfo converts ACP capability info into the shared payload.

func AcceptedPromptStreamTurnID 

func AcceptedPromptStreamTurnID(result session.SendPromptResult) (string, error)

func AgentEventPayloadFromEvent 

func AgentEventPayloadFromEvent(event acp.AgentEvent) contract.AgentEventPayload

AgentEventPayloadFromEvent converts an agent event into the shared raw-stream payload.

func AgentPayloadFromDef 

func AgentPayloadFromDef(agent aghconfig.AgentDef) contract.AgentPayload

AgentPayloadFromDef converts an agent definition into the shared payload.

func AgentPayloadFromDiagnostic 

func AgentPayloadFromDiagnostic(diagnostic workspacepkg.AgentDiagnostic) contract.AgentPayload

AgentPayloadFromDiagnostic converts a malformed workspace agent diagnostic into a payload row.

func AgentPayloadsFromDefs 

func AgentPayloadsFromDefs(agents []aghconfig.AgentDef) []contract.AgentPayload

AgentPayloadsFromDefs converts a list of agent definitions into response payloads.

func AgentProbeHealthPayloadsFromACP 

func AgentProbeHealthPayloadsFromACP(probes []acp.ProbeResult) []contract.AgentProbeHealthPayload

AgentProbeHealthPayloadsFromACP converts downstream ACP probe results into the shared health payload.

func AgentTaskClaimPayloadFromResult 

func AgentTaskClaimPayloadFromResult(result *taskpkg.ClaimResult) contract.AgentTaskClaimPayload

AgentTaskClaimPayloadFromResult builds the public, redacted claim payload.

func AgentTaskLeasePayloadFromRun 

func AgentTaskLeasePayloadFromRun(
	run *taskpkg.Run,
	channel *contract.CoordinationChannelPayload,
) contract.TaskRunLeaseSummaryPayload

AgentTaskLeasePayloadFromRun builds the public, redacted lease payload.

func ApplyAutomationJobPatch 

func ApplyAutomationJobPatch(current automationpkg.Job, req contract.UpdateJobRequest) automationpkg.Job

ApplyAutomationJobPatch applies the shared patch payload to an automation job model.

func ApplyAutomationTriggerPatch 

func ApplyAutomationTriggerPatch(
	current automationpkg.Trigger,
	req contract.UpdateTriggerRequest,
) automationpkg.Trigger

ApplyAutomationTriggerPatch applies the shared patch payload to an automation trigger model.

func AutomationHealthPayloadFromStatus 

func AutomationHealthPayloadFromStatus(
	enabled bool,
	status automationpkg.ManagerStatus,
) contract.AutomationHealthPayload

AutomationHealthPayloadFromStatus converts manager status into the shared additive automation health block.

func AutomationJobFromCreateRequest 

func AutomationJobFromCreateRequest(req contract.CreateJobRequest) automationpkg.Job

AutomationJobFromCreateRequest converts the shared create payload into the canonical automation job model.

func AutomationSchedulerStatePayloadFromState 

func AutomationSchedulerStatePayloadFromState(
	state automationpkg.ScheduledJobState,
) contract.AutomationSchedulerStatePayload

AutomationSchedulerStatePayloadFromState converts durable scheduler metadata into the shared response payload.

func AutomationSchedulerStatePayloadsFromStates 

func AutomationSchedulerStatePayloadsFromStates(
	states []automationpkg.ScheduledJobState,
) []contract.AutomationSchedulerStatePayload

AutomationSchedulerStatePayloadsFromStates converts scheduler states into response payloads.

func AutomationTriggerFromCreateRequest 

func AutomationTriggerFromCreateRequest(req contract.CreateTriggerRequest) automationpkg.Trigger

AutomationTriggerFromCreateRequest converts the shared create payload into the canonical automation trigger model.

func BridgeAggregateHealthPayloadFromObserve 

func BridgeAggregateHealthPayloadFromObserve(
	summary observepkg.BridgeAggregateHealth,
) contract.BridgeAggregateHealthPayload

BridgeAggregateHealthPayloadFromObserve converts the observer bridge summary into the shared payload.

func BridgeHealthPayloadFromObserve 

func BridgeHealthPayloadFromObserve(health observepkg.BridgeInstanceHealth) contract.BridgeHealthPayload

BridgeHealthPayloadFromObserve converts the observer per-instance bridge health snapshot into the shared payload.

func BridgePayloadFromBridgeInstance 

func BridgePayloadFromBridgeInstance(instance bridgepkg.BridgeInstance) contract.BridgePayload

BridgePayloadFromBridgeInstance converts the daemon-owned bridge record into the shared bridge-management payload exposed by transports and OpenAPI.

func BridgeProviderPayloadFromBridgeProvider 

func BridgeProviderPayloadFromBridgeProvider(provider bridgepkg.BridgeProvider) contract.BridgeProviderPayload

BridgeProviderPayloadFromBridgeProvider converts installed provider metadata into the shared bridge-management provider catalog payload.

func BulkForceTaskRunResponseFromResult 

func BulkForceTaskRunResponseFromResult(
	result taskpkg.BulkForceRunResult,
	maskInternalErrors bool,
) contract.BulkForceTaskRunResponse

BulkForceTaskRunResponseFromResult converts per-row bulk force outcomes into shared payloads.

func BundleActivationPayload 

func BundleActivationPayload(item bundlepkg.ActivationPreview) contract.BundleActivationPayload

func BundleCatalogPayloads 

func BundleCatalogPayloads(items []bundlepkg.CatalogEntry) []contract.BundleCatalogPayload

func ConfigApplyRecordsResponseFromRecords 

func ConfigApplyRecordsResponseFromRecords(
	records []settingspkg.ApplyRecord,
) contract.ConfigApplyRecordsResponse

ConfigApplyRecordsResponseFromRecords converts apply history rows into the public payload.

func CoordinatorConfigPayloadFromConfig 

func CoordinatorConfigPayloadFromConfig(
	cfg aghconfig.CoordinatorConfig,
	source contract.CoordinatorConfigSource,
	workspaceID string,
) contract.CoordinatorConfigPayload

CoordinatorConfigPayloadFromConfig converts resolved coordinator config into a safe read model.

func CreateAgentFromRequest 

func CreateAgentFromRequest(
	ctx context.Context,
	req contract.CreateAgentRequest,
	homePaths aghconfig.HomePaths,
	workspaces WorkspaceService,
	transportName string,
) (aghconfig.AgentDef, error)

CreateAgentFromRequest validates and persists one AGENT.md definition from a shared create-agent request. It is the single authoring path reused by the HTTP handler and the agh__agent_create native tool.

func DeclaredNetworkChannelPayloads 

func DeclaredNetworkChannelPayloads(items []bundlepkg.DeclaredChannel) []contract.DeclaredNetworkChannelPayload

func ErrorPayloadForError 

func ErrorPayloadForError(err error) contract.ErrorPayload

ErrorPayloadForError builds a redacted error payload for stream frames and other non-status envelopes.

func ErrorPayloadForStatus 

func ErrorPayloadForStatus(status int, err error, maskInternalErrors bool) contract.ErrorPayload

ErrorPayloadForStatus builds a redacted HTTP/UDS error payload for status.

func ExtensionStatusCode 

func ExtensionStatusCode(err error) int

ExtensionStatusCode maps extension-domain errors onto transport status codes.

func HookCatalogPayloadsFromEntries 

func HookCatalogPayloadsFromEntries(entries []hookspkg.CatalogEntry) []contract.HookCatalogPayload

HookCatalogPayloadsFromEntries converts resolved hook catalog entries into transport DTOs.

func HookEventPayloadsFromDescriptors 

func HookEventPayloadsFromDescriptors(events []hookspkg.EventDescriptor) []contract.HookEventPayload

HookEventPayloadsFromDescriptors converts hook taxonomy descriptors into transport DTOs.

func HookRunPayloadsFromRecords 

func HookRunPayloadsFromRecords(records []hookspkg.HookRunRecord) []contract.HookRunPayload

HookRunPayloadsFromRecords converts persisted hook audit records into transport DTOs.

func JobPayloadFromJob 

func JobPayloadFromJob(
	job automationpkg.Job,
	nextRun *time.Time,
	schedulerState *contract.AutomationSchedulerStatePayload,
) contract.JobPayload

JobPayloadFromJob converts an automation job into the shared response payload, optionally enriching it with scheduler next-run metadata.

func JobPayloadsFromJobs 

func JobPayloadsFromJobs(
	jobs []automationpkg.Job,
	schedulerStateByID map[string]contract.AutomationSchedulerStatePayload,
) []contract.JobPayload

JobPayloadsFromJobs converts a slice of jobs into response payloads using the supplied next-run map.

func LogEventAfterCursor 

func LogEventAfterCursor(event store.EventSummary, cursor LogsCursor) bool

LogEventAfterCursor reports whether a log event should be emitted after the cursor.

func LogEventID 

func LogEventID(event store.EventSummary) string

LogEventID builds a stable Last-Event-ID value for logs streaming.

func LogEventPayloadFromSummary 

func LogEventPayloadFromSummary(event store.EventSummary) contract.LogEventPayload

LogEventPayloadFromSummary converts an event summary into the shared logs payload.

func MemoryDecisionPayload 

func MemoryDecisionPayload(
	decision memcontract.Decision,
	appliedAt *time.Time,
) contract.MemoryDecisionPayload

MemoryDecisionPayload converts a controller decision into its redaction-safe public form.

func MemoryDecisionRecordPayload 

func MemoryDecisionRecordPayload(record memory.DecisionRecord) contract.MemoryDecisionPayload

func MemoryOperationHistoryPayloads 

func MemoryOperationHistoryPayloads(records []memcontract.OperationRecord) []contract.MemoryOperationHistoryPayload

MemoryOperationHistoryPayloads converts domain operation records into Memory v2 DTOs.

func MemoryOperationPayloads 

func MemoryOperationPayloads(records []memcontract.OperationRecord) []contract.MemoryOperationPayload

MemoryOperationPayloads converts domain operation records into API DTOs.

func NetworkChannelPayloads 

func NetworkChannelPayloads(
	ctx context.Context,
	service NetworkService,
	sessionsManager SessionManager,
	networkStore NetworkStore,
	workspaceID string,
) ([]contract.NetworkChannelPayload, error)

NetworkChannelPayloads builds the shared runtime channel projection used by transports and tools.

func NetworkChannelPayloadsFromInfos 

func NetworkChannelPayloadsFromInfos(channels []network.ChannelInfo) []contract.NetworkChannelPayload

NetworkChannelPayloadsFromInfos converts active channel summaries into shared payloads.

func NetworkConversationMessagePayloadFromEntry 

func NetworkConversationMessagePayloadFromEntry(
	entry store.NetworkMessageEntry,
	sessionsByID map[string]*session.Info,
	peersByID map[string]network.PeerInfo,
) contract.NetworkConversationMessagePayload

NetworkConversationMessagePayloadFromEntry converts one persisted timeline row into the shared payload.

func NetworkConversationMessagePayloadFromStore 

func NetworkConversationMessagePayloadFromStore(
	message store.NetworkConversationMessage,
) contract.NetworkConversationMessagePayload

NetworkConversationMessagePayloadFromStore converts one stored message into a public payload.

func NetworkConversationMessagePayloadFromView 

func NetworkConversationMessagePayloadFromView(
	view networkTimelineMessageView,
	sessionsByID map[string]*session.Info,
	peersByID map[string]network.PeerInfo,
) contract.NetworkConversationMessagePayload

func NetworkConversationMessagePayloadsFromStore 

func NetworkConversationMessagePayloadsFromStore(
	messages []store.NetworkConversationMessage,
) []contract.NetworkConversationMessagePayload

NetworkConversationMessagePayloadsFromStore converts stored messages into public payloads.

func NetworkDirectRoomPayloadFromStore 

func NetworkDirectRoomPayloadFromStore(direct store.NetworkDirectRoomSummary) contract.NetworkDirectRoomPayload

NetworkDirectRoomPayloadFromStore converts one stored direct-room summary into a public payload.

func NetworkDirectRoomPayloadsFromStore 

func NetworkDirectRoomPayloadsFromStore(
	directs []store.NetworkDirectRoomSummary,
) []contract.NetworkDirectRoomPayload

NetworkDirectRoomPayloadsFromStore converts stored direct rooms into public payloads.

func NetworkEnvelopePayloadFromEnvelope 

func NetworkEnvelopePayloadFromEnvelope(envelope network.Envelope) contract.NetworkEnvelopePayload

NetworkEnvelopePayloadFromEnvelope converts one surfaced envelope into the shared payload.

func NetworkEnvelopePayloadsFromEnvelopes 

func NetworkEnvelopePayloadsFromEnvelopes(envelopes []network.Envelope) []contract.NetworkEnvelopePayload

NetworkEnvelopePayloadsFromEnvelopes converts surfaced envelopes into shared payloads.

func NetworkPeerDetailPayloadFromInfo 

func NetworkPeerDetailPayloadFromInfo(
	peer network.PeerInfo,
	sessionsByID map[string]*session.Info,
	metrics contract.NetworkPeerMetricsPayload,
) contract.NetworkPeerDetailPayload

NetworkPeerDetailPayloadFromInfo converts one peer info plus metrics into the shared detail payload.

func NetworkPeerPayloadFromInfo 

func NetworkPeerPayloadFromInfo(peer network.PeerInfo) contract.NetworkPeerPayload

NetworkPeerPayloadFromInfo converts one visible peer snapshot into the shared payload.

func NetworkPeerPayloadsFromInfos 

func NetworkPeerPayloadsFromInfos(peers []network.PeerInfo) []contract.NetworkPeerPayload

NetworkPeerPayloadsFromInfos converts the visible peer snapshot into shared payloads.

func NetworkSendPayloadFromRequest 

func NetworkSendPayloadFromRequest(id string, req contract.NetworkSendRequest) contract.NetworkSendPayload

NetworkSendPayloadFromRequest builds the shared send response payload from the original request plus the assigned message id.

func NetworkSendRequestFromPayload 

func NetworkSendRequestFromPayload(req contract.NetworkSendRequest) (network.SendRequest, error)

NetworkSendRequestFromPayload validates and converts one shared send payload into the runtime request.

func NetworkStatusPayloadFromStatus 

func NetworkStatusPayloadFromStatus(status *network.Status) *contract.NetworkStatusPayload

NetworkStatusPayloadFromStatus converts the runtime network status snapshot into the shared payload.

func NetworkThreadSummaryPayloadFromStore 

func NetworkThreadSummaryPayloadFromStore(thread store.NetworkThreadSummary) contract.NetworkThreadSummaryPayload

NetworkThreadSummaryPayloadFromStore converts one stored thread summary into a public payload.

func NetworkThreadSummaryPayloadsFromStore 

func NetworkThreadSummaryPayloadsFromStore(
	threads []store.NetworkThreadSummary,
) []contract.NetworkThreadSummaryPayload

NetworkThreadSummaryPayloadsFromStore converts stored thread summaries into public payloads.

func NetworkWorkPayloadFromStore 

func NetworkWorkPayloadFromStore(work store.NetworkWorkEntry) contract.NetworkWorkPayload

NetworkWorkPayloadFromStore converts one network work row into a public payload.

func NewAutomationValidationError 

func NewAutomationValidationError(err error) error

NewAutomationValidationError wraps an automation validation failure with the shared sentinel.

func NewMemoryValidationError 

func NewMemoryValidationError(err error) error

NewMemoryValidationError wraps a memory validation failure with the shared sentinel.

func NewModelCatalogValidationError 

func NewModelCatalogValidationError(err error) error

NewModelCatalogValidationError wraps a model catalog request validation failure.

func NewNetworkValidationError 

func NewNetworkValidationError(err error) error

NewNetworkValidationError wraps a network request validation failure with the shared sentinel.

func NewSettingsConflictError 

func NewSettingsConflictError(err error) error

NewSettingsConflictError wraps a settings conflict with the shared sentinel.

func NewSettingsForbiddenError 

func NewSettingsForbiddenError(err error) error

NewSettingsForbiddenError wraps a settings forbidden failure with the shared sentinel.

func NewSettingsNotFoundError 

func NewSettingsNotFoundError(err error) error

NewSettingsNotFoundError wraps a missing settings resource failure with the shared sentinel.

func NewSettingsValidationError 

func NewSettingsValidationError(err error) error

NewSettingsValidationError wraps a settings validation failure with the shared sentinel.

func NewTaskValidationError 

func NewTaskValidationError(err error) error

NewTaskValidationError wraps a task validation failure with the shared sentinel.

func ObserveFailureHealthPayloadFromHealth 

func ObserveFailureHealthPayloadFromHealth(
	health observepkg.FailureHealth,
) contract.ObserveFailureHealthPayload

ObserveFailureHealthPayloadFromHealth converts lifecycle failure health into the shared payload.

func ObserveHealthPayloadFromHealth 

func ObserveHealthPayloadFromHealth(health *observepkg.Health) contract.ObserveHealthPayload

ObserveHealthPayloadFromHealth converts the observer health snapshot into the shared payload.

func ObservePersistenceHealthPayloadFromHealth 

func ObservePersistenceHealthPayloadFromHealth(
	health observepkg.PersistenceHealth,
) contract.ObservePersistenceHealthPayload

ObservePersistenceHealthPayloadFromHealth converts persistence health into the shared payload.

func ObserveRetentionHealthPayloadFromHealth 

func ObserveRetentionHealthPayloadFromHealth(
	health observepkg.RetentionHealth,
) contract.ObserveRetentionHealthPayload

ObserveRetentionHealthPayloadFromHealth converts retention health into the shared payload.

func OpenAIModelListPayloadFromModels 

func OpenAIModelListPayloadFromModels(models []modelcatalog.Model) contract.OpenAIModelListResponse

func OpenAIModelPayloadFromModel 

func OpenAIModelPayloadFromModel(model modelcatalog.Model) contract.OpenAIModelPayload

func ParseAutomationJobListQuery 

func ParseAutomationJobListQuery(c *gin.Context) (automationpkg.JobListQuery, error)

ParseAutomationJobListQuery parses the shared automation job list filters.

func ParseAutomationRunQuery 

func ParseAutomationRunQuery(c *gin.Context) (automationpkg.RunQuery, error)

ParseAutomationRunQuery parses the shared automation run list filters.

func ParseAutomationTriggerListQuery 

func ParseAutomationTriggerListQuery(c *gin.Context) (automationpkg.TriggerListQuery, error)

ParseAutomationTriggerListQuery parses the shared automation trigger list filters.

func ParseHookCatalogFilter 

func ParseHookCatalogFilter(c *gin.Context) (hookspkg.CatalogFilter, error)

ParseHookCatalogFilter parses the shared hook catalog query parameters.

func ParseHookEventFilter 

func ParseHookEventFilter(c *gin.Context) (hookspkg.EventFilter, error)

ParseHookEventFilter parses the shared hook taxonomy query parameters.

func ParseHookRunsQuery 

func ParseHookRunsQuery(c *gin.Context) (store.HookRunQuery, error)

ParseHookRunsQuery parses the shared hook execution history query parameters.

func ParseLogsQuery 

func ParseLogsQuery(c *gin.Context) (store.EventSummaryQuery, error)

ParseLogsQuery parses the shared logs query parameters.

func ParseOptionalBool 

func ParseOptionalBool(raw string) (bool, error)

ParseOptionalBool parses an optional boolean query value.

func ParseOptionalInt 

func ParseOptionalInt(raw string) (int, error)

ParseOptionalInt parses an optional integer query value.

func ParseOptionalInt64 

func ParseOptionalInt64(raw string) (int64, error)

ParseOptionalInt64 parses an optional 64-bit integer query value.

func ParseOptionalMemoryScope 

func ParseOptionalMemoryScope(raw string) (memcontract.Scope, error)

ParseOptionalMemoryScope validates an optional memory scope value.

func ParseOptionalTime 

func ParseOptionalTime(raw string) (time.Time, error)

ParseOptionalTime parses an optional RFC3339 or RFC3339Nano timestamp.

func ParseResourceFilter 

func ParseResourceFilter(c *gin.Context) (resources.ResourceFilter, error)

ParseResourceFilter parses the shared `/api/resources` list filters.

func ParseSessionEventQuery 

func ParseSessionEventQuery(c *gin.Context) (store.EventQuery, error)

ParseSessionEventQuery parses the shared session event query parameters.

func ParseTaskDashboardQuery 

func ParseTaskDashboardQuery(c *gin.Context) (contract.TaskDashboardQuery, error)

ParseTaskDashboardQuery parses the shared task dashboard query parameters.

func ParseTaskInboxQuery 

func ParseTaskInboxQuery(c *gin.Context) (contract.TaskInboxQuery, error)

ParseTaskInboxQuery parses the shared task inbox query parameters.

func ParseTaskListQuery 

func ParseTaskListQuery(c *gin.Context) (contract.TaskListQuery, error)

ParseTaskListQuery parses the shared task-list query parameters.

func ParseTaskRunListQuery 

func ParseTaskRunListQuery(c *gin.Context) (contract.TaskRunListQuery, error)

ParseTaskRunListQuery parses the shared task-run list query parameters.

func ParseTaskStreamQuery 

func ParseTaskStreamQuery(c *gin.Context) (contract.TaskStreamQuery, error)

ParseTaskStreamQuery parses the shared task stream query parameters.

func ParseTaskTimelineQuery 

func ParseTaskTimelineQuery(c *gin.Context) (contract.TaskTimelineQuery, error)

ParseTaskTimelineQuery parses the shared task timeline query parameters.

func PayloadJSON 

func PayloadJSON(raw string) json.RawMessage

PayloadJSON coerces raw strings into valid JSON response bodies.

func PromptResultPayloadFromSession 

func PromptResultPayloadFromSession(result session.SendPromptResult) contract.SendPromptResultPayload

PromptResultPayloadFromSession converts runtime prompt admission state into the shared DTO.

func ProviderModelListPayloadFromModels 

func ProviderModelListPayloadFromModels(models []modelcatalog.Model) contract.ProviderModelListResponse

func ProviderModelPayloadFromModel 

func ProviderModelPayloadFromModel(model modelcatalog.Model) contract.ProviderModelPayload

func ResolveMemoryWorkspace 

func ResolveMemoryWorkspace(raw string) (string, error)

ResolveMemoryWorkspace validates and canonicalizes a workspace memory location.

func ResolveMemoryWriteScope 

func ResolveMemoryWriteScope(req contract.MemoryWriteRequest) (memcontract.Scope, string, error)

ResolveMemoryWriteScope validates a write request and infers its target scope.

func ResourceRecordPayloadFromRaw 

func ResourceRecordPayloadFromRaw(record resources.RawRecord) contract.ResourceRecordPayload

ResourceRecordPayloadFromRaw converts one raw resource record into a shared transport DTO.

func ResourceRecordPayloadsFromRaw 

func ResourceRecordPayloadsFromRaw(records []resources.RawRecord) []contract.ResourceRecordPayload

ResourceRecordPayloadsFromRaw converts raw resource records into shared transport DTOs.

func RespondError 

func RespondError(c *gin.Context, status int, err error, maskInternalErrors bool)

RespondError writes a transport error response, optionally masking internal error details.

func RespondOpenAIError 

func RespondOpenAIError(c *gin.Context, status int, err error, maskInternalErrors bool)

RespondOpenAIError writes an OpenAI-compatible error response envelope.

func RetryTaskRunResponseFromResult 

func RetryTaskRunResponseFromResult(result *taskpkg.RetryRunResult) contract.RetryTaskRunResponse

RetryTaskRunResponseFromResult converts one retry result into the shared payload.

func RunPayloadFromRun 

func RunPayloadFromRun(run automationpkg.Run) contract.RunPayload

RunPayloadFromRun converts an automation run into the shared response payload.

func RunPayloadsFromRuns 

func RunPayloadsFromRuns(runs []automationpkg.Run) []contract.RunPayload

RunPayloadsFromRuns converts a slice of runs into response payloads.

func RuntimeActivityPayloadFromSessionMeta 

func RuntimeActivityPayloadFromSessionMeta(
	liveness *store.SessionLivenessMeta,
	now time.Time,
) *contract.RuntimeActivityPayload

RuntimeActivityPayloadFromSessionMeta converts persisted session activity metadata into the shared payload.

func SchedulerBacklogPayloadFromDomain 

func SchedulerBacklogPayloadFromDomain(backlog taskpkg.SchedulerBacklog) contract.SchedulerBacklogPayload

SchedulerBacklogPayloadFromDomain exposes effective pause state without leaking store rows.

func SchedulerDrainResponseFromDomain 

func SchedulerDrainResponseFromDomain(result taskpkg.SchedulerDrainResult) contract.SchedulerDrainResponse

SchedulerDrainResponseFromDomain preserves drain result semantics across HTTP and UDS.

func SchedulerStatusPayloadFromDomain 

func SchedulerStatusPayloadFromDomain(status taskpkg.SchedulerStatus) contract.SchedulerStatusPayload

SchedulerStatusPayloadFromDomain keeps transports on one scheduler DTO shape.

func SessionActivityHealthPayloadsFromObserve 

func SessionActivityHealthPayloadsFromObserve(
	activities []observepkg.SessionActivityHealth,
) []contract.SessionActivityHealthPayload

SessionActivityHealthPayloadsFromObserve converts observer activity health rows into the shared health response payload.

func SessionConfigOptionPayloadsFromInfo 

func SessionConfigOptionPayloadsFromInfo(options []acp.SessionConfigOption) []contract.SessionConfigOptionPayload

SessionConfigOptionPayloadsFromInfo converts active ACP config options into the shared payload.

func SessionEventPayloadFromEvent 

func SessionEventPayloadFromEvent(event store.SessionEvent, info *session.Info) contract.SessionEventPayload

SessionEventPayloadFromEvent converts a session event into the shared payload.

func SessionFailurePayloadFromStore 

func SessionFailurePayloadFromStore(failure *store.SessionFailure) *contract.SessionFailurePayload

SessionFailurePayloadFromStore converts a stored failure diagnostic into the shared API payload.

func SessionPayloadFromInfo 

func SessionPayloadFromInfo(info *session.Info) contract.SessionPayload

SessionPayloadFromInfo converts a session info snapshot into the shared session payload.

func SessionPayloadFromStoreInfo 

func SessionPayloadFromStoreInfo(info store.SessionInfo) contract.SessionPayload

SessionPayloadFromStoreInfo converts the persisted session index row into the shared payload.

func SessionPayloadsForWorkspace 

func SessionPayloadsForWorkspace(infos []*session.Info, workspaceID string) []contract.SessionPayload

SessionPayloadsForWorkspace filters and converts sessions for one workspace.

func SessionPayloadsFromInfos 

func SessionPayloadsFromInfos(infos []*session.Info) []contract.SessionPayload

SessionPayloadsFromInfos converts a session list into response payloads.

func SessionProviderOptionPayloadsFromConfig 

func SessionProviderOptionPayloadsFromConfig(cfg *aghconfig.Config) []contract.SessionProviderOptionPayload

SessionProviderOptionPayloadsFromConfig converts the merged workspace config into a stable, UI-ready list of visible provider options.

func SessionRepairPayloadFromResult 

func SessionRepairPayloadFromResult(result *session.RepairResult) contract.SessionRepairPayload

SessionRepairPayloadFromResult converts a session repair report into the shared payload.

func SessionSandboxPayloadFromMeta 

func SessionSandboxPayloadFromMeta(meta *store.SessionSandboxMeta) *contract.SessionSandboxPayload

SessionSandboxPayloadFromMeta converts session sandbox metadata into the shared payload.

func SettingsApplyResponseFromResult 

func SettingsApplyResponseFromResult(result settingspkg.ApplyResult) contract.SettingsApplyResponse

SettingsApplyResponseFromResult converts one settings apply result into the public payload.

func SettingsCollectionMutationResultPayloadFromResult 

func SettingsCollectionMutationResultPayloadFromResult(result settingspkg.MutationResult) (any, error)

SettingsCollectionMutationResultPayloadFromResult converts one settings collection mutation result into the shared payload.

func SettingsCollectionResponseFromEnvelope 

func SettingsCollectionResponseFromEnvelope(envelope settingspkg.CollectionEnvelope) (any, error)

SettingsCollectionResponseFromEnvelope converts one settings collection envelope into the shared response payload.

func SettingsRestartActionResponseFromOperation 

func SettingsRestartActionResponseFromOperation(operation SettingsRestartOperation) contract.RestartActionResponse

SettingsRestartActionResponseFromOperation converts one daemon restart operation into the action response payload.

func SettingsRestartActionStatusFromOperation 

func SettingsRestartActionStatusFromOperation(operation SettingsRestartOperation) contract.RestartActionStatus

SettingsRestartActionStatusFromOperation converts one daemon restart operation into the polling payload.

func SettingsSectionMutationResultPayloadFromResult 

func SettingsSectionMutationResultPayloadFromResult(result settingspkg.MutationResult) (any, error)

SettingsSectionMutationResultPayloadFromResult converts one settings section mutation result into the shared payload.

func SettingsSectionResponseFromEnvelope 

func SettingsSectionResponseFromEnvelope(envelope settingspkg.SectionEnvelope) (any, error)

SettingsSectionResponseFromEnvelope converts one settings section envelope into the shared response payload.

func SettingsUpdateResponseFromStatus 

func SettingsUpdateResponseFromStatus(status SettingsUpdateStatus) contract.SettingsUpdateResponse

SettingsUpdateResponseFromStatus converts the daemon-owned update snapshot into the transport payload.

func SkillDiagnosticPayloadsFromDiagnostics 

func SkillDiagnosticPayloadsFromDiagnostics(
	diagnostics []skills.SkillDiagnostic,
) []contract.SkillDiagnosticPayload

SkillDiagnosticPayloadsFromDiagnostics converts skill registry diagnostics for API payloads.

func SkillMarketplaceDetailPayloadFromDetail 

func SkillMarketplaceDetailPayloadFromDetail(
	detail *registrypkg.Detail,
) contract.SkillMarketplaceDetailPayload

SkillMarketplaceDetailPayloadFromDetail converts a remote detail into the shared payload.

func SkillMarketplaceInstallPayloadFromResult 

func SkillMarketplaceInstallPayloadFromResult(
	result skillmarketplace.InstallResult,
) contract.SkillMarketplaceInstallPayload

SkillMarketplaceInstallPayloadFromResult converts an install result into the shared payload.

func SkillMarketplaceListingPayloadFromListing 

func SkillMarketplaceListingPayloadFromListing(
	listing registrypkg.Listing,
) contract.SkillMarketplaceListingPayload

SkillMarketplaceListingPayloadFromListing converts a remote listing into the shared payload.

func SkillMarketplaceListingPayloadsFromListings 

func SkillMarketplaceListingPayloadsFromListings(
	listings []registrypkg.Listing,
) []contract.SkillMarketplaceListingPayload

SkillMarketplaceListingPayloadsFromListings converts remote listings into shared payloads.

func SkillMarketplaceRemovePayloadFromResult 

func SkillMarketplaceRemovePayloadFromResult(
	result skillmarketplace.RemoveResult,
) contract.SkillMarketplaceRemovePayload

SkillMarketplaceRemovePayloadFromResult converts a removal result into the shared payload.

func SkillMarketplaceUpdatePayloadsFromResults 

func SkillMarketplaceUpdatePayloadsFromResults(
	results []skillmarketplace.UpdateResult,
) []contract.SkillMarketplaceUpdatePayload

SkillMarketplaceUpdatePayloadsFromResults converts update results into shared payloads.

func SkillPayloadFromSkill 

func SkillPayloadFromSkill(skill *skills.Skill) contract.SkillPayload

SkillPayloadFromSkill converts a skills.Skill into the shared HTTP payload.

func SkillPayloadsFromSkills 

func SkillPayloadsFromSkills(skillList []*skills.Skill) []contract.SkillPayload

SkillPayloadsFromSkills converts a slice of skills into response payloads.

func SkillShadowEntryPayloadFromDomain 

func SkillShadowEntryPayloadFromDomain(entry skills.ShadowEntry) contract.SkillShadowEntryPayload

func SkillShadowEntryPayloadsFromDomain 

func SkillShadowEntryPayloadsFromDomain(entries []skills.ShadowEntry) []contract.SkillShadowEntryPayload

func SkillShadowEntryPayloadsFromRefs 

func SkillShadowEntryPayloadsFromRefs(refs []skills.SkillDefinitionRef) []contract.SkillShadowEntryPayload

func SkillShadowsResponseFromDomain 

func SkillShadowsResponseFromDomain(snapshot skills.SkillShadows) contract.SkillShadowsResponse

SkillShadowsResponseFromDomain converts one resolver shadow snapshot into the shared API payload.

func SourceRefPayloadsFromRefs 

func SourceRefPayloadsFromRefs(refs []modelcatalog.SourceRef) []contract.ModelCatalogSourceRefPayload

func SourceStatusPayloadsFromStatuses 

func SourceStatusPayloadsFromStatuses(
	statuses []modelcatalog.SourceStatus,
) []contract.ModelCatalogSourceStatusPayload

func StatusForAgentIdentityError 

func StatusForAgentIdentityError(err error) int

StatusForAgentIdentityError maps agent identity failures to transport statuses.

func StatusForAutomationError 

func StatusForAutomationError(err error) int

StatusForAutomationError maps automation-domain failures to transport statuses.

func StatusForBridgeError 

func StatusForBridgeError(err error) int

StatusForBridgeError maps bridge-domain and workspace-domain errors to transport statuses.

func StatusForBundleError 

func StatusForBundleError(err error) int

func StatusForHeartbeatError 

func StatusForHeartbeatError(err error) int

StatusForHeartbeatError maps Heartbeat authoring/status failures to deterministic transport statuses.

func StatusForMemoryError 

func StatusForMemoryError(err error) int

StatusForMemoryError maps memory-domain errors to transport statuses.

func StatusForModelCatalogError 

func StatusForModelCatalogError(err error) int

StatusForModelCatalogError maps model catalog failures to transport statuses.

func StatusForNetworkError 

func StatusForNetworkError(err error) int

StatusForNetworkError maps network-domain errors to transport statuses.

func StatusForNotificationPresetError 

func StatusForNotificationPresetError(err error) int

StatusForNotificationPresetError maps notification preset failures to transport statuses.

func StatusForResourceError 

func StatusForResourceError(err error) int

StatusForResourceError maps desired-state resource failures to transport statuses.

func StatusForSessionError 

func StatusForSessionError(err error) int

StatusForSessionError maps session and workspace-domain errors to transport statuses.

func StatusForSettingsError 

func StatusForSettingsError(err error) int

StatusForSettingsError maps settings-domain failures to transport statuses.

func StatusForSkillError 

func StatusForSkillError(err error) int

StatusForSkillError maps skill-domain errors to transport statuses.

func StatusForSkillMarketplaceError 

func StatusForSkillMarketplaceError(err error) int

StatusForSkillMarketplaceError maps skill marketplace lifecycle failures to transport statuses.

func StatusForSoulError 

func StatusForSoulError(err error) int

StatusForSoulError maps Soul/session authoring failures to deterministic transport statuses.

func StatusForTaskError 

func StatusForTaskError(err error) int

StatusForTaskError maps task-domain, workspace, and session failures to transport statuses.

func StatusForToolError 

func StatusForToolError(err error) int

StatusForToolError maps registry failures to stable transport statuses.

func StatusForVaultError 

func StatusForVaultError(err error) int

StatusForVaultError maps vault-domain failures to transport statuses.

func StatusForWorkspaceError 

func StatusForWorkspaceError(err error) int

StatusForWorkspaceError maps workspace-domain errors to transport statuses.

func StuckTaskRunPayloadsFromObserve 

func StuckTaskRunPayloadsFromObserve(rows []observepkg.StuckTaskRun) []contract.StuckTaskRunPayload

StuckTaskRunPayloadsFromObserve converts stuck task-run diagnostics.

func SupportBundleManifestPayloadFromManifest 

func SupportBundleManifestPayloadFromManifest(
	manifest support.Manifest,
) *contract.SupportBundleManifestPayload

func SupportBundleOperationPayloadFromOperation 

func SupportBundleOperationPayloadFromOperation(op support.Operation) contract.SupportBundleOperationPayload

func SupportBundleOperationResponseFromOperation 

func SupportBundleOperationResponseFromOperation(
	op support.Operation,
) contract.SupportBundleOperationResponse

func TaskBridgeNotificationCursorPayloadFromCursor 

func TaskBridgeNotificationCursorPayloadFromCursor(
	cursor notifications.Cursor,
) contract.TaskBridgeNotificationCursorPayload

TaskBridgeNotificationCursorPayloadFromCursor converts persisted cursor diagnostics into the transport payload used by HTTP, UDS, CLI, and web.

func TaskBridgeNotificationCursorPayloadFromKey 

func TaskBridgeNotificationCursorPayloadFromKey(
	key notifications.CursorKey,
) contract.TaskBridgeNotificationCursorPayload

TaskBridgeNotificationCursorPayloadFromKey converts a durable cursor identity into the transport diagnostics shape before any delivery has been persisted.

func TaskBridgeNotificationSubscriptionPayloadFromSubscription 

func TaskBridgeNotificationSubscriptionPayloadFromSubscription(
	subscription bridgepkg.BridgeTaskSubscription,
) contract.TaskBridgeNotificationSubscriptionPayload

TaskBridgeNotificationSubscriptionPayloadFromSubscription converts one bridge task subscription into the shared task-scoped transport payload.

func TaskBridgeNotificationSubscriptionPayloadFromSubscriptionAndCursor 

func TaskBridgeNotificationSubscriptionPayloadFromSubscriptionAndCursor(
	subscription bridgepkg.BridgeTaskSubscription,
	cursor notifications.Cursor,
) contract.TaskBridgeNotificationSubscriptionPayload

TaskBridgeNotificationSubscriptionPayloadFromSubscriptionAndCursor converts one bridge task subscription with its persisted cursor diagnostics.

func TaskBridgeNotificationSubscriptionPayloadsFromSubscriptions 

func TaskBridgeNotificationSubscriptionPayloadsFromSubscriptions(
	subscriptions []bridgepkg.BridgeTaskSubscription,
) []contract.TaskBridgeNotificationSubscriptionPayload

TaskBridgeNotificationSubscriptionPayloadsFromSubscriptions converts bridge task subscriptions into shared task-scoped transport payloads.

func TaskDashboardPayloadFromView 

func TaskDashboardPayloadFromView(view *observepkg.TaskDashboardView) contract.TaskDashboardPayload

TaskDashboardPayloadFromView converts one observer-backed dashboard view into the shared payload.

func TaskDependencyPayloadsFromDependencies 

func TaskDependencyPayloadsFromDependencies(dependencies []taskpkg.Dependency) []contract.TaskDependencyPayload

TaskDependencyPayloadsFromDependencies converts dependency records into shared payloads.

func TaskDependencyReferencePayloadsFromReferences 

func TaskDependencyReferencePayloadsFromReferences(
	dependencies []taskpkg.DependencyReference,
) []contract.TaskDependencyReferencePayload

TaskDependencyReferencePayloadsFromReferences converts enriched dependency references into shared payloads.

func TaskDetailPayloadFromView 

func TaskDetailPayloadFromView(view *taskpkg.View) contract.TaskDetailPayload

TaskDetailPayloadFromView converts one expanded task view into the shared payload.

func TaskEventPayloadsFromEvents 

func TaskEventPayloadsFromEvents(events []taskpkg.Event) []contract.TaskEventPayload

TaskEventPayloadsFromEvents converts task events into shared payloads.

func TaskExecutionResponseFromExecution 

func TaskExecutionResponseFromExecution(execution *taskpkg.Execution) contract.TaskExecutionResponse

TaskExecutionResponseFromExecution converts one task execution-boundary result.

func TaskHealthPayloadFromObserve 

func TaskHealthPayloadFromObserve(health observepkg.TaskHealth) contract.TaskHealthPayload

TaskHealthPayloadFromObserve converts observer task health into the shared status payload.

func TaskInboxPayloadFromView 

func TaskInboxPayloadFromView(view observepkg.TaskInboxView) contract.TaskInboxPayload

TaskInboxPayloadFromView converts one observer-backed inbox view into the shared payload.

func TaskInspectEventPayloadsFromSummaries 

func TaskInspectEventPayloadsFromSummaries(
	summaries []taskpkg.InspectEventSummary,
) []contract.TaskInspectEventPayload

TaskInspectEventPayloadsFromSummaries converts inspect event summaries into shared payloads.

func TaskInspectPayloadFromView 

func TaskInspectPayloadFromView(view *taskpkg.InspectView) contract.TaskInspectPayload

TaskInspectPayloadFromView converts one inspect view into the shared payload.

func TaskInspectRunPayloadFromSummary 

func TaskInspectRunPayloadFromSummary(summary *taskpkg.InspectRunSummary) *contract.TaskInspectRunPayload

TaskInspectRunPayloadFromSummary converts an inspect run summary into the shared payload.

func TaskInspectRunPayloadsFromSummaries 

func TaskInspectRunPayloadsFromSummaries(
	summaries []taskpkg.InspectRunSummary,
) []contract.TaskInspectRunPayload

TaskInspectRunPayloadsFromSummaries converts inspect run summaries into shared payloads.

func TaskInspectSchedulerPayloadFromState 

func TaskInspectSchedulerPayloadFromState(state taskpkg.InspectSchedulerState) contract.TaskInspectSchedulerPayload

TaskInspectSchedulerPayloadFromState converts scheduler state into the shared payload.

func TaskInspectSessionPayloadFromSummary 

func TaskInspectSessionPayloadFromSummary(
	summary *taskpkg.InspectSessionSummary,
) *contract.TaskInspectSessionPayload

TaskInspectSessionPayloadFromSummary converts an inspect session summary into the shared payload.

func TaskOwnerTotalPayloadsFromObserve 

func TaskOwnerTotalPayloadsFromObserve(rows []observepkg.TaskOwnerTotal) []contract.TaskOwnerTotalPayload

TaskOwnerTotalPayloadsFromObserve converts task ownership buckets.

func TaskPayloadFromTask 

func TaskPayloadFromTask(record *taskpkg.Task) contract.TaskPayload

TaskPayloadFromTask converts one task record into the shared payload.

func TaskQueueDepthPayloadsFromObserve 

func TaskQueueDepthPayloadsFromObserve(rows []observepkg.TaskQueueDepth) []contract.TaskQueueDepthPayload

TaskQueueDepthPayloadsFromObserve converts task queue-depth rows.

func TaskReferencePayloadFromReference 

func TaskReferencePayloadFromReference(record taskpkg.Reference) contract.TaskReferencePayload

TaskReferencePayloadFromReference converts one task reference into the shared payload.

func TaskRunDetailPayloadFromView 

func TaskRunDetailPayloadFromView(view *taskpkg.RunDetailView) contract.TaskRunDetailPayload

TaskRunDetailPayloadFromView converts one run-detail view into the shared payload.

func TaskRunOperationalSummaryPayloadFromSummary 

func TaskRunOperationalSummaryPayloadFromSummary(
	summary taskpkg.RunOperationalSummary,
) contract.TaskRunOperationalSummaryPayload

TaskRunOperationalSummaryPayloadFromSummary converts run-detail operational metrics into the shared payload.

func TaskRunPayloadFromRun 

func TaskRunPayloadFromRun(run *taskpkg.Run) contract.TaskRunPayload

TaskRunPayloadFromRun converts one task run into the shared payload.

func TaskRunPayloadsFromRuns 

func TaskRunPayloadsFromRuns(runs []taskpkg.Run) []contract.TaskRunPayload

TaskRunPayloadsFromRuns converts task runs into shared payloads.

func TaskRunReviewPayloadsFromReviews 

func TaskRunReviewPayloadsFromReviews(reviews []taskpkg.RunReview) []contract.TaskRunReviewPayload

TaskRunReviewPayloadsFromReviews converts review records into shared payloads.

func TaskRunReviewVerdictResponseFromResult 

func TaskRunReviewVerdictResponseFromResult(result *taskpkg.RunReviewResult) contract.TaskRunReviewVerdictResponse

TaskRunReviewVerdictResponseFromResult converts one verdict result into a shared payload.

func TaskRunSessionPayloadFromSession 

func TaskRunSessionPayloadFromSession(session *taskpkg.RunSessionRef) *contract.TaskRunSessionPayload

TaskRunSessionPayloadFromSession converts one task run session link into the shared payload.

func TaskRunSummaryPayloadFromSummary 

func TaskRunSummaryPayloadFromSummary(summary *taskpkg.RunSummary) *contract.TaskRunSummaryPayload

TaskRunSummaryPayloadFromSummary converts one operator-facing run summary into the shared payload.

func TaskRunTotalPayloadsFromObserve 

func TaskRunTotalPayloadsFromObserve(rows []observepkg.TaskRunTotal) []contract.TaskRunTotalPayload

TaskRunTotalPayloadsFromObserve converts task-run status buckets.

func TaskStatusTotalPayloadsFromObserve 

func TaskStatusTotalPayloadsFromObserve(rows []observepkg.TaskStatusTotal) []contract.TaskStatusTotalPayload

TaskStatusTotalPayloadsFromObserve converts task status buckets.

func TaskStreamEventPayloadFromEvent 

func TaskStreamEventPayloadFromEvent(event taskpkg.StreamEvent) contract.TaskStreamEventPayload

TaskStreamEventPayloadFromEvent converts one task live-stream event into the shared payload.

func TaskSummaryPayloadFromSummary 

func TaskSummaryPayloadFromSummary(record taskpkg.Summary) contract.TaskSummaryPayload

TaskSummaryPayloadFromSummary converts one task summary into the shared payload.

func TaskSummaryPayloadFromTask 

func TaskSummaryPayloadFromTask(record *taskpkg.Task) contract.TaskSummaryPayload

TaskSummaryPayloadFromTask provides the compact task shape used by list and backlog surfaces.

func TaskSummaryPayloadsFromSummaries 

func TaskSummaryPayloadsFromSummaries(tasks []taskpkg.Summary) []contract.TaskSummaryPayload

TaskSummaryPayloadsFromSummaries converts task summaries into shared payloads.

func TaskTimelineItemPayloadFromItem 

func TaskTimelineItemPayloadFromItem(item taskpkg.TimelineItem) contract.TaskTimelineItemPayload

TaskTimelineItemPayloadFromItem converts one task timeline item into the shared payload.

func TaskTimelineItemPayloadsFromItems 

func TaskTimelineItemPayloadsFromItems(items []taskpkg.TimelineItem) []contract.TaskTimelineItemPayload

TaskTimelineItemPayloadsFromItems converts task timeline items into shared payloads.

func TaskTreeNodePayloadFromNode 

func TaskTreeNodePayloadFromNode(node taskpkg.TreeNode) contract.TaskTreeNodePayload

TaskTreeNodePayloadFromNode converts one task tree node into the shared payload.

func TaskTreePayloadFromView 

func TaskTreePayloadFromView(view *taskpkg.TreeView) contract.TaskTreePayload

TaskTreePayloadFromView converts one task tree snapshot into the shared payload.

func TaskTriageStatePayloadFromState 

func TaskTriageStatePayloadFromState(state taskpkg.TriageState) contract.TaskTriageStatePayload

TaskTriageStatePayloadFromState converts one triage-state record into the shared payload.

func TokenUsagePayloadFromUsage 

func TokenUsagePayloadFromUsage(usage *acp.TokenUsage) *contract.TokenUsagePayload

TokenUsagePayloadFromUsage converts token usage info into the shared payload.

func ToolPayloadFromView 

func ToolPayloadFromView(view *toolspkg.ToolView) contract.ToolPayload

ToolPayloadFromView converts one registry view into a public DTO.

func ToolPayloadsFromViews 

func ToolPayloadsFromViews(views []toolspkg.ToolView) []contract.ToolPayload

ToolPayloadsFromViews converts registry views into public DTOs.

func ToolsetPayloadFromView 

func ToolsetPayloadFromView(view toolspkg.ToolsetView) contract.ToolsetPayload

ToolsetPayloadFromView converts one toolset projection into a public DTO.

func ToolsetPayloadsFromViews 

func ToolsetPayloadsFromViews(views []toolspkg.ToolsetView) []contract.ToolsetPayload

ToolsetPayloadsFromViews converts toolset projections into public DTOs.

func TriggerPayloadFromTrigger 

func TriggerPayloadFromTrigger(trigger automationpkg.Trigger) contract.TriggerPayload

TriggerPayloadFromTrigger converts an automation trigger into the shared response payload.

func TriggerPayloadsFromTriggers 

func TriggerPayloadsFromTriggers(triggers []automationpkg.Trigger) []contract.TriggerPayload

TriggerPayloadsFromTriggers converts a slice of triggers into response payloads.

func ValidateAutomationConfigJobUpdate 

func ValidateAutomationConfigJobUpdate(req contract.UpdateJobRequest) error

ValidateAutomationConfigJobUpdate enforces the config-backed job mutation policy.

func ValidateAutomationConfigTriggerUpdate 

func ValidateAutomationConfigTriggerUpdate(req contract.UpdateTriggerRequest) error

ValidateAutomationConfigTriggerUpdate enforces the config-backed trigger mutation policy.

func VaultSecretPayloadFromMetadata 

func VaultSecretPayloadFromMetadata(row vault.Metadata) (contract.VaultSecretPayload, error)

VaultSecretPayloadFromMetadata converts redacted vault metadata into the shared contract payload.

func VaultSecretPayloadsFromMetadata 

func VaultSecretPayloadsFromMetadata(rows []vault.Metadata) ([]contract.VaultSecretPayload, error)

VaultSecretPayloadsFromMetadata converts a metadata list into public payloads.

func WebhookDeliveryPayloadFromResult 

func WebhookDeliveryPayloadFromResult(result automationpkg.TriggerResult) contract.WebhookDeliveryPayload

WebhookDeliveryPayloadFromResult converts a webhook trigger dispatch result into the shared response payload.

func WorkspacePayloadFromWorkspace 

func WorkspacePayloadFromWorkspace(workspace workspacepkg.Workspace) contract.WorkspacePayload

WorkspacePayloadFromWorkspace converts a workspace into the shared payload.

func WorkspaceSkillPayloads 

func WorkspaceSkillPayloads(skills []workspacepkg.SkillPath) []contract.WorkspaceSkillPayload

WorkspaceSkillPayloads converts workspace skill paths into response payloads.

func WriteSSE 

func WriteSSE(writer FlushWriter, msg SSEMessage) error

WriteSSE writes one SSE message with JSON-encoded data.

func WriteSSERaw 

func WriteSSERaw(writer FlushWriter, id string, raw string, names ...string) error

WriteSSERaw writes one SSE message using a pre-encoded payload.

func WriteTaskStreamEvent 

func WriteTaskStreamEvent(writer FlushWriter, event taskpkg.StreamEvent) error

WriteTaskStreamEvent writes one task-native live event through the shared SSE helper path.

Types

type AgentCatalog 

type AgentCatalog interface {
	ListAgents(ctx context.Context) ([]aghconfig.AgentDef, error)
	GetAgent(ctx context.Context, name string) (aghconfig.AgentDef, error)
}

AgentCatalog exposes projected resource-backed agent definitions.

type AgentContextService 

type AgentContextService interface {
	ContextForSession(ctx context.Context, info *session.Info) (contract.AgentContextPayload, error)
}

AgentContextService assembles the bounded situation payload for a validated agent session.

type AgentLoader 

type AgentLoader func(name string, homePaths aghconfig.HomePaths) (aghconfig.AgentDef, error)

AgentLoader loads one parsed AGENT.md definition.

type AutomationManager 

type AutomationManager interface {
	ListJobs(ctx context.Context, query automationpkg.JobListQuery) ([]automationpkg.Job, error)
	Jobs(ctx context.Context) ([]automationpkg.Job, error)
	GetJob(ctx context.Context, id string) (automationpkg.Job, error)
	CreateJob(ctx context.Context, job automationpkg.Job) (automationpkg.Job, error)
	UpdateJob(ctx context.Context, job automationpkg.Job) (automationpkg.Job, error)
	DeleteJob(ctx context.Context, id string) error
	TriggerJob(ctx context.Context, id string) (automationpkg.Run, error)
	ListTriggers(ctx context.Context, query automationpkg.TriggerListQuery) ([]automationpkg.Trigger, error)
	Triggers(ctx context.Context) ([]automationpkg.Trigger, error)
	GetTrigger(ctx context.Context, id string) (automationpkg.Trigger, error)
	CreateTrigger(
		ctx context.Context,
		trigger automationpkg.Trigger,
		webhookSecret automationpkg.WebhookSecretWrite,
	) (automationpkg.Trigger, error)
	UpdateTrigger(
		ctx context.Context,
		trigger automationpkg.Trigger,
		webhookSecret *automationpkg.WebhookSecretWrite,
	) (automationpkg.Trigger, error)
	DeleteTrigger(ctx context.Context, id string) error
	ListRuns(ctx context.Context, query automationpkg.RunQuery) ([]automationpkg.Run, error)
	Runs(ctx context.Context, query automationpkg.RunQuery) ([]automationpkg.Run, error)
	GetRun(ctx context.Context, id string) (automationpkg.Run, error)
	Status(ctx context.Context) (automationpkg.ManagerStatus, error)
	SetJobEnabled(ctx context.Context, id string, enabled bool) (automationpkg.Job, error)
	SetTriggerEnabled(ctx context.Context, id string, enabled bool) (automationpkg.Trigger, error)
	HandleWebhook(ctx context.Context, request automationpkg.WebhookRequest) (automationpkg.TriggerResult, error)
}

AutomationManager exposes automation state and control surfaces to the API layer.

type BaseHandlerConfig 

type BaseHandlerConfig struct {
	TransportName                string
	MaskInternalErrors           bool
	IncludeSessionWorkspaceInSSE bool
	Sessions                     SessionManager
	SessionCatalog               SessionCatalog
	Network                      NetworkService
	NetworkStore                 NetworkStore
	Observer                     Observer
	Resources                    ResourceService
	Extensions                   ExtensionService
	Tools                        ToolRegistry
	Toolsets                     ToolsetRegistry
	ToolApprovals                ToolApprovalIssuer
	Automation                   AutomationManager
	Tasks                        TaskService
	Bridges                      BridgeService
	Notifications                NotificationPresetService
	Bundles                      BundleService
	SupportBundles               SupportBundleService
	Settings                     SettingsService
	SettingsRestart              SettingsRestartController
	SettingsUpdate               SettingsUpdateController
	Vault                        VaultService
	Workspaces                   WorkspaceService
	Onboarding                   OnboardingStore
	AgentCatalog                 AgentCatalog
	ModelCatalog                 ModelCatalogService
	ProviderAuthRunner           authproviders.ProviderAuthCommandRunner
	AgentContextService          AgentContextService
	SoulAuthoring                SoulAuthoringService
	SoulRefresher                SoulRefresher
	HeartbeatAuthoring           HeartbeatAuthoringService
	HeartbeatStatus              HeartbeatStatusService
	HeartbeatWake                HeartbeatWakeService
	SessionHealth                SessionHealthReader
	HeartbeatWakeEvents          HeartbeatWakeEventReader
	CoordinatorConfig            CoordinatorConfigResolver
	SkillsRegistry               SkillsRegistry
	SkillMarketplace             SkillMarketplaceService
	TaskActorContextResolver     TaskActorContextResolver
	MemoryStore                  *memory.Store
	DreamTrigger                 DreamTrigger
	MemoryExtractor              MemoryExtractorService
	MemoryProviders              MemoryProviderService
	MemorySessionLedger          MemorySessionLedgerService
	HomePaths                    aghconfig.HomePaths
	Config                       aghconfig.Config
	Logger                       *slog.Logger
	StartedAt                    time.Time
	Now                          func() time.Time
	PollInterval                 time.Duration
	AgentLoader                  AgentLoader
	StreamDone                   <-chan struct{}
	HTTPPort                     int
	PID                          func() int
}

BaseHandlerConfig configures a shared handler set for one transport.

type BaseHandlers 

type BaseHandlers struct {
	TransportName                string
	MaskInternalErrors           bool
	IncludeSessionWorkspaceInSSE bool
	Sessions                     SessionManager
	SessionCatalog               SessionCatalog
	Network                      NetworkService
	NetworkStore                 NetworkStore
	Observer                     Observer
	Resources                    ResourceService
	Extensions                   ExtensionService
	Tools                        ToolRegistry
	Toolsets                     ToolsetRegistry
	ToolApprovals                ToolApprovalIssuer
	Automation                   AutomationManager
	Tasks                        TaskService
	Bridges                      BridgeService
	Notifications                NotificationPresetService
	Bundles                      BundleService
	SupportBundles               SupportBundleService
	Settings                     SettingsService
	SettingsRestart              SettingsRestartController
	SettingsUpdate               SettingsUpdateController
	Vault                        VaultService
	Workspaces                   WorkspaceService
	Onboarding                   OnboardingStore
	AgentCatalog                 AgentCatalog
	ModelCatalog                 ModelCatalogService
	ProviderAuthRunner           authproviders.ProviderAuthCommandRunner
	AgentContextService          AgentContextService
	SoulAuthoring                SoulAuthoringService
	SoulRefresher                SoulRefresher
	HeartbeatAuthoring           HeartbeatAuthoringService
	HeartbeatStatus              HeartbeatStatusService
	HeartbeatWake                HeartbeatWakeService
	SessionHealth                SessionHealthReader
	HeartbeatWakeEvents          HeartbeatWakeEventReader
	CoordinatorConfig            CoordinatorConfigResolver
	SkillsRegistry               SkillsRegistry
	SkillMarketplace             SkillMarketplaceService
	TaskActorContextResolver     TaskActorContextResolver
	MemoryStore                  *memory.Store
	DreamTrigger                 DreamTrigger
	MemoryExtractor              MemoryExtractorService
	MemoryProviders              MemoryProviderService
	MemorySessionLedger          MemorySessionLedgerService
	HomePaths                    aghconfig.HomePaths
	Config                       aghconfig.Config
	Logger                       *slog.Logger
	StartedAt                    time.Time
	Now                          func() time.Time
	PollInterval                 time.Duration
	AgentLoader                  AgentLoader
	PID                          func() int
	// contains filtered or unexported fields
}

BaseHandlers contains the shared transport-independent API handler logic.

func NewBaseHandlers 

func NewBaseHandlers(cfg *BaseHandlerConfig) *BaseHandlers

NewBaseHandlers builds a shared handler set with transport-specific defaults applied.

func (*BaseHandlers) ActivateBundle 

func (h *BaseHandlers) ActivateBundle(c *gin.Context)

func (*BaseHandlers) AddTaskDependency 

func (h *BaseHandlers) AddTaskDependency(c *gin.Context)

AddTaskDependency adds one blocking dependency edge.

func (*BaseHandlers) AgentChannelRecv 

func (h *BaseHandlers) AgentChannelRecv(c *gin.Context)

AgentChannelRecv returns queued channel messages for the validated caller, optionally waiting.

func (*BaseHandlers) AgentChannelReply 

func (h *BaseHandlers) AgentChannelReply(c *gin.Context)

AgentChannelReply replies to one queued or persisted message using the validated caller identity.

func (*BaseHandlers) AgentChannelSend 

func (h *BaseHandlers) AgentChannelSend(c *gin.Context)

AgentChannelSend sends one coordination message using the validated caller identity.

func (*BaseHandlers) AgentChannels 

func (h *BaseHandlers) AgentChannels(c *gin.Context)

AgentChannels lists discoverable coordination channels for the validated caller.

func (*BaseHandlers) AgentContext 

func (h *BaseHandlers) AgentContext(c *gin.Context)

AgentContext returns the bounded situation payload for the validated caller session.

func (*BaseHandlers) AgentCoordinatorConfig 

func (h *BaseHandlers) AgentCoordinatorConfig(c *gin.Context)

AgentCoordinatorConfig returns the resolved coordinator policy for the caller workspace.

func (*BaseHandlers) AgentMe 

func (h *BaseHandlers) AgentMe(c *gin.Context)

AgentMe returns the daemon-validated caller identity for agent-facing UDS operations.

func (*BaseHandlers) AgentSoul 

func (h *BaseHandlers) AgentSoul(c *gin.Context)

AgentSoul returns the caller's resolved full Soul read model.

func (*BaseHandlers) AgentSpawn 

func (h *BaseHandlers) AgentSpawn(c *gin.Context)

AgentSpawn creates a bounded child session for the validated agent caller.

func (*BaseHandlers) AgentTaskClaimNext 

func (h *BaseHandlers) AgentTaskClaimNext(c *gin.Context)

AgentTaskClaimNext claims the next eligible task run for the validated caller.

func (*BaseHandlers) AgentTaskComplete 

func (h *BaseHandlers) AgentTaskComplete(c *gin.Context)

AgentTaskComplete completes one claimed task run after token verification.

func (*BaseHandlers) AgentTaskFail 

func (h *BaseHandlers) AgentTaskFail(c *gin.Context)

AgentTaskFail fails one claimed task run after token verification.

func (*BaseHandlers) AgentTaskHeartbeat 

func (h *BaseHandlers) AgentTaskHeartbeat(c *gin.Context)

AgentTaskHeartbeat extends the current lease for one claimed task run.

func (*BaseHandlers) AgentTaskRelease 

func (h *BaseHandlers) AgentTaskRelease(c *gin.Context)

AgentTaskRelease releases one claimed task run back to the queue.

func (*BaseHandlers) ApproveTask 

func (h *BaseHandlers) ApproveTask(c *gin.Context)

ApproveTask records one approval decision for an approval-gated task.

func (*BaseHandlers) ArchiveTask 

func (h *BaseHandlers) ArchiveTask(c *gin.Context)

ArchiveTask archives one task triage record for the current actor.

func (*BaseHandlers) AttachSession 

func (h *BaseHandlers) AttachSession(c *gin.Context)

AttachSession acquires a short-lived attach lease without starting a new runtime authority.

func (*BaseHandlers) AttachTaskRunSession 

func (h *BaseHandlers) AttachTaskRunSession(c *gin.Context)

AttachTaskRunSession binds one existing session to a run.

func (*BaseHandlers) AutomationJobRuns 

func (h *BaseHandlers) AutomationJobRuns(c *gin.Context)

AutomationJobRuns returns run history for one automation job.

func (*BaseHandlers) AutomationTriggerRuns 

func (h *BaseHandlers) AutomationTriggerRuns(c *gin.Context)

AutomationTriggerRuns returns run history for one automation trigger.

func (*BaseHandlers) BrowseDirectory 

func (h *BaseHandlers) BrowseDirectory(c *gin.Context)

BrowseDirectory lists immediate directory entries so the onboarding workspace picker can navigate the local filesystem. It is read-only and operator-scoped: the daemon already runs with the operator's filesystem access.

func (*BaseHandlers) BulkForceFailTaskRuns 

func (h *BaseHandlers) BulkForceFailTaskRuns(c *gin.Context)

BulkForceFailTaskRuns force fails a bounded set of runs.

func (*BaseHandlers) BulkForceReleaseTaskRuns 

func (h *BaseHandlers) BulkForceReleaseTaskRuns(c *gin.Context)

BulkForceReleaseTaskRuns force releases a bounded set of runs.

func (*BaseHandlers) BundleNetworkSettings 

func (h *BaseHandlers) BundleNetworkSettings(c *gin.Context)

func (*BaseHandlers) CancelTask 

func (h *BaseHandlers) CancelTask(c *gin.Context)

CancelTask requests cancellation for one task tree.

func (*BaseHandlers) CancelTaskRun 

func (h *BaseHandlers) CancelTaskRun(c *gin.Context)

CancelTaskRun cancels one non-terminal run.

func (*BaseHandlers) ClaimTaskRun 

func (h *BaseHandlers) ClaimTaskRun(c *gin.Context)

ClaimTaskRun claims one queued run.

func (*BaseHandlers) ClearSessionConversation 

func (h *BaseHandlers) ClearSessionConversation(c *gin.Context)

ClearSessionConversation clears persisted conversation history and restarts the session with a fresh ACP conversation context while preserving the same id.

func (*BaseHandlers) CompleteOnboarding 

func (h *BaseHandlers) CompleteOnboarding(c *gin.Context)

CompleteOnboarding marks first-run onboarding as completed and returns the new status.

func (*BaseHandlers) CompleteTaskRun 

func (h *BaseHandlers) CompleteTaskRun(c *gin.Context)

CompleteTaskRun marks one running run as completed.

func (*BaseHandlers) ConfigApplyRecordsSnapshot 

func (h *BaseHandlers) ConfigApplyRecordsSnapshot(
	ctx context.Context,
) (contract.ConfigApplyRecordsResponse, error)

ConfigApplyRecordsSnapshot returns recent config apply records for support bundles.

func (*BaseHandlers) CreateAgent 

func (h *BaseHandlers) CreateAgent(c *gin.Context)

CreateAgent writes a new global or workspace-local AGENT.md definition.

func (*BaseHandlers) CreateAutomationJob 

func (h *BaseHandlers) CreateAutomationJob(c *gin.Context)

CreateAutomationJob stores a new dynamic automation job.

func (*BaseHandlers) CreateAutomationTrigger 

func (h *BaseHandlers) CreateAutomationTrigger(c *gin.Context)

CreateAutomationTrigger stores a new dynamic automation trigger definition.

func (*BaseHandlers) CreateBridge 

func (h *BaseHandlers) CreateBridge(c *gin.Context)

CreateBridge persists a new bridge instance.

func (*BaseHandlers) CreateChildTask 

func (h *BaseHandlers) CreateChildTask(c *gin.Context)

CreateChildTask creates one child task beneath the supplied parent.

func (*BaseHandlers) CreateMemoryAdhocNote 

func (h *BaseHandlers) CreateMemoryAdhocNote(c *gin.Context)

func (*BaseHandlers) CreateNetworkChannel 

func (h *BaseHandlers) CreateNetworkChannel(c *gin.Context)

CreateNetworkChannel validates and creates one new channel by starting a new session per selected agent.

func (*BaseHandlers) CreateNotificationPreset 

func (h *BaseHandlers) CreateNotificationPreset(c *gin.Context)

CreateNotificationPreset creates one preset.

func (*BaseHandlers) CreateSession 

func (h *BaseHandlers) CreateSession(c *gin.Context)

CreateSession creates a new runtime session.

func (*BaseHandlers) CreateSupportBundle 

func (h *BaseHandlers) CreateSupportBundle(c *gin.Context)

CreateSupportBundle starts an asynchronous daemon-owned support bundle operation.

func (*BaseHandlers) CreateTask 

func (h *BaseHandlers) CreateTask(c *gin.Context)

CreateTask creates one new task.

func (*BaseHandlers) CreateTaskBridgeNotificationSubscription 

func (h *BaseHandlers) CreateTaskBridgeNotificationSubscription(c *gin.Context)

CreateTaskBridgeNotificationSubscription persists one task-scoped terminal bridge notification target.

func (*BaseHandlers) CreateToolApproval 

func (h *BaseHandlers) CreateToolApproval(c *gin.Context)

CreateToolApproval mints one daemon-memory approval reference for a concrete invocation.

func (*BaseHandlers) CreateWorkspace 

func (h *BaseHandlers) CreateWorkspace(c *gin.Context)

CreateWorkspace registers a workspace.

func (*BaseHandlers) DeleteAgentHeartbeat 

func (h *BaseHandlers) DeleteAgentHeartbeat(c *gin.Context)

DeleteAgentHeartbeat removes HEARTBEAT.md through the managed authoring service.

func (*BaseHandlers) DeleteAgentSoul 

func (h *BaseHandlers) DeleteAgentSoul(c *gin.Context)

DeleteAgentSoul removes SOUL.md through the managed authoring service.

func (*BaseHandlers) DeleteAutomationJob 

func (h *BaseHandlers) DeleteAutomationJob(c *gin.Context)

DeleteAutomationJob removes one dynamic automation job definition.

func (*BaseHandlers) DeleteAutomationTrigger 

func (h *BaseHandlers) DeleteAutomationTrigger(c *gin.Context)

DeleteAutomationTrigger removes one dynamic automation trigger definition.

func (*BaseHandlers) DeleteBridgeSecretBinding 

func (h *BaseHandlers) DeleteBridgeSecretBinding(c *gin.Context)

DeleteBridgeSecretBinding removes one bridge secret binding row.

func (*BaseHandlers) DeleteBundleActivation 

func (h *BaseHandlers) DeleteBundleActivation(c *gin.Context)

func (*BaseHandlers) DeleteMemory 

func (h *BaseHandlers) DeleteMemory(c *gin.Context)

DeleteMemory deletes one memory document.

func (*BaseHandlers) DeleteNotificationPreset 

func (h *BaseHandlers) DeleteNotificationPreset(c *gin.Context)

DeleteNotificationPreset removes one preset.

func (*BaseHandlers) DeleteResource 

func (h *BaseHandlers) DeleteResource(c *gin.Context)

DeleteResource deletes one desired-state resource by optimistic version.

func (*BaseHandlers) DeleteSession 

func (h *BaseHandlers) DeleteSession(c *gin.Context)

DeleteSession removes one session from the runtime catalog and persisted history.

func (*BaseHandlers) DeleteSettingsHook 

func (h *BaseHandlers) DeleteSettingsHook(c *gin.Context)

DeleteSettingsHook deletes one hook settings item.

func (*BaseHandlers) DeleteSettingsMCPServer 

func (h *BaseHandlers) DeleteSettingsMCPServer(c *gin.Context)

DeleteSettingsMCPServer deletes one MCP server settings item.

func (*BaseHandlers) DeleteSettingsProvider 

func (h *BaseHandlers) DeleteSettingsProvider(c *gin.Context)

DeleteSettingsProvider deletes one provider settings item.

func (*BaseHandlers) DeleteSettingsSandbox 

func (h *BaseHandlers) DeleteSettingsSandbox(c *gin.Context)

DeleteSettingsSandbox deletes one sandbox settings item.

func (*BaseHandlers) DeleteTask 

func (h *BaseHandlers) DeleteTask(c *gin.Context)

DeleteTask removes one task record and any cascade-owned child rows.

func (*BaseHandlers) DeleteTaskBridgeNotificationSubscription 

func (h *BaseHandlers) DeleteTaskBridgeNotificationSubscription(c *gin.Context)

DeleteTaskBridgeNotificationSubscription removes one task-scoped terminal bridge notification target.

func (*BaseHandlers) DeleteTaskExecutionProfile 

func (h *BaseHandlers) DeleteTaskExecutionProfile(c *gin.Context)

DeleteTaskExecutionProfile removes one persisted task-owned execution profile.

func (*BaseHandlers) DeleteVaultSecret 

func (h *BaseHandlers) DeleteVaultSecret(c *gin.Context)

DeleteVaultSecret removes one vault-backed secret.

func (*BaseHandlers) DeleteWorkspace 

func (h *BaseHandlers) DeleteWorkspace(c *gin.Context)

DeleteWorkspace unregisters a workspace.

func (*BaseHandlers) DeliverGlobalWebhook 

func (h *BaseHandlers) DeliverGlobalWebhook(c *gin.Context)

DeliverGlobalWebhook handles external webhook delivery for global triggers.

func (*BaseHandlers) DeliverWorkspaceWebhook 

func (h *BaseHandlers) DeliverWorkspaceWebhook(c *gin.Context)

DeliverWorkspaceWebhook handles external webhook delivery for workspace-scoped triggers.

func (*BaseHandlers) DisableBridge 

func (h *BaseHandlers) DisableBridge(c *gin.Context)

DisableBridge moves one bridge instance into the disabled lifecycle state.

func (*BaseHandlers) DisableExtension 

func (h *BaseHandlers) DisableExtension(c *gin.Context)

DisableExtension disables one installed extension.

func (*BaseHandlers) DisableMemoryProvider 

func (h *BaseHandlers) DisableMemoryProvider(c *gin.Context)

func (*BaseHandlers) DisableSkill 

func (h *BaseHandlers) DisableSkill(c *gin.Context)

DisableSkill disables a skill by name.

func (*BaseHandlers) DismissTask 

func (h *BaseHandlers) DismissTask(c *gin.Context)

DismissTask dismisses one task triage record for the current actor.

func (*BaseHandlers) DoctorSnapshot 

func (h *BaseHandlers) DoctorSnapshot(ctx context.Context) (contract.DoctorPayload, error)

DoctorSnapshot returns the same diagnostic payload used by /api/doctor with all probes enabled.

func (*BaseHandlers) DownloadSupportBundle 

func (h *BaseHandlers) DownloadSupportBundle(c *gin.Context)

DownloadSupportBundle streams a completed support bundle archive.

func (*BaseHandlers) DrainMemoryExtractor 

func (h *BaseHandlers) DrainMemoryExtractor(c *gin.Context)

func (*BaseHandlers) DrainScheduler 

func (h *BaseHandlers) DrainScheduler(c *gin.Context)

DrainScheduler lets the task service own drain policy while the API only maps request overrides.

func (*BaseHandlers) EditMemory 

func (h *BaseHandlers) EditMemory(c *gin.Context)

EditMemory edits one memory document through the controller.

func (*BaseHandlers) EnableBridge 

func (h *BaseHandlers) EnableBridge(c *gin.Context)

EnableBridge moves one bridge instance into the starting lifecycle state.

func (*BaseHandlers) EnableExtension 

func (h *BaseHandlers) EnableExtension(c *gin.Context)

EnableExtension enables one installed extension.

func (*BaseHandlers) EnableMemoryProvider 

func (h *BaseHandlers) EnableMemoryProvider(c *gin.Context)

func (*BaseHandlers) EnableSkill 

func (h *BaseHandlers) EnableSkill(c *gin.Context)

EnableSkill enables a skill by name.

func (*BaseHandlers) EnqueueTaskRun 

func (h *BaseHandlers) EnqueueTaskRun(c *gin.Context)

EnqueueTaskRun creates one new queue-first run for the supplied task.

func (*BaseHandlers) EventSummariesSnapshot 

func (h *BaseHandlers) EventSummariesSnapshot(ctx context.Context) (contract.LogsListResponse, error)

EventSummariesSnapshot returns recent event summaries for support bundles.

func (*BaseHandlers) ExtensionProvenance 

func (h *BaseHandlers) ExtensionProvenance(c *gin.Context)

ExtensionProvenance returns one installed extension's persisted trust report.

func (*BaseHandlers) ExtensionStatus 

func (h *BaseHandlers) ExtensionStatus(c *gin.Context)

ExtensionStatus returns one installed extension's runtime status.

func (*BaseHandlers) FailTaskRun 

func (h *BaseHandlers) FailTaskRun(c *gin.Context)

FailTaskRun marks one run as failed.

func (*BaseHandlers) ForceFailTaskRun 

func (h *BaseHandlers) ForceFailTaskRun(c *gin.Context)

ForceFailTaskRun force fails one queued or claimed run without requiring the raw claim token.

func (*BaseHandlers) ForceReleaseTaskRun 

func (h *BaseHandlers) ForceReleaseTaskRun(c *gin.Context)

ForceReleaseTaskRun force releases one claimed run without requiring the raw claim token.

func (*BaseHandlers) GetAgent 

func (h *BaseHandlers) GetAgent(c *gin.Context)

GetAgent returns one agent definition by name.

func (*BaseHandlers) GetAgentHeartbeat 

func (h *BaseHandlers) GetAgentHeartbeat(c *gin.Context)

GetAgentHeartbeat returns the resolved Heartbeat policy for one workspace-visible agent.

func (*BaseHandlers) GetAgentHeartbeatStatus 

func (h *BaseHandlers) GetAgentHeartbeatStatus(c *gin.Context)

GetAgentHeartbeatStatus returns policy, wake state, and optional session health.

func (*BaseHandlers) GetAgentSoul 

func (h *BaseHandlers) GetAgentSoul(c *gin.Context)

GetAgentSoul returns the resolved full Soul read model for one workspace-visible agent.

func (*BaseHandlers) GetAutomationJob 

func (h *BaseHandlers) GetAutomationJob(c *gin.Context)

GetAutomationJob returns one automation job by id.

func (*BaseHandlers) GetAutomationRun 

func (h *BaseHandlers) GetAutomationRun(c *gin.Context)

GetAutomationRun returns one automation run by id.

func (*BaseHandlers) GetAutomationTrigger 

func (h *BaseHandlers) GetAutomationTrigger(c *gin.Context)

GetAutomationTrigger returns one automation trigger by id.

func (*BaseHandlers) GetBridge 

func (h *BaseHandlers) GetBridge(c *gin.Context)

GetBridge returns one persisted bridge instance.

func (*BaseHandlers) GetBundleActivation 

func (h *BaseHandlers) GetBundleActivation(c *gin.Context)

func (*BaseHandlers) GetDoctor 

func (h *BaseHandlers) GetDoctor(c *gin.Context)

GetDoctor returns the hard-cut diagnostic probe payload shared by HTTP and UDS.

func (*BaseHandlers) GetMemoryDecision 

func (h *BaseHandlers) GetMemoryDecision(c *gin.Context)

func (*BaseHandlers) GetMemoryDream 

func (h *BaseHandlers) GetMemoryDream(c *gin.Context)

func (*BaseHandlers) GetMemoryDreamStatus 

func (h *BaseHandlers) GetMemoryDreamStatus(c *gin.Context)

GetMemoryDreamStatus returns a truthful empty status until daemon wiring provides live dreaming runtime state.

func (*BaseHandlers) GetMemoryExtractorStatus 

func (h *BaseHandlers) GetMemoryExtractorStatus(c *gin.Context)

func (*BaseHandlers) GetMemoryProvider 

func (h *BaseHandlers) GetMemoryProvider(c *gin.Context)

func (*BaseHandlers) GetMemoryRecallTrace 

func (h *BaseHandlers) GetMemoryRecallTrace(c *gin.Context)

func (*BaseHandlers) GetMemorySessionLedger 

func (h *BaseHandlers) GetMemorySessionLedger(c *gin.Context)

func (*BaseHandlers) GetNotificationPreset 

func (h *BaseHandlers) GetNotificationPreset(c *gin.Context)

GetNotificationPreset returns one notification preset.

func (*BaseHandlers) GetOnboardingStatus 

func (h *BaseHandlers) GetOnboardingStatus(c *gin.Context)

GetOnboardingStatus reports whether first-run onboarding has been completed.

func (*BaseHandlers) GetProvider 

func (h *BaseHandlers) GetProvider(c *gin.Context)

GetProvider returns one canonical provider summary.

func (*BaseHandlers) GetResource 

func (h *BaseHandlers) GetResource(c *gin.Context)

GetResource returns one desired-state resource by kind and id.

func (*BaseHandlers) GetScheduler 

func (h *BaseHandlers) GetScheduler(c *gin.Context)

GetScheduler exposes service-owned scheduler state without deriving queue pressure in the API.

func (*BaseHandlers) GetSchedulerBacklog 

func (h *BaseHandlers) GetSchedulerBacklog(c *gin.Context)

GetSchedulerBacklog keeps pause-aware backlog projection behind the task service boundary.

func (*BaseHandlers) GetSession 

func (h *BaseHandlers) GetSession(c *gin.Context)

GetSession returns one session snapshot.

func (*BaseHandlers) GetSessionHealth 

func (h *BaseHandlers) GetSessionHealth(c *gin.Context)

GetSessionHealth returns metadata-only session health and wake eligibility.

func (*BaseHandlers) GetSessionStatus 

func (h *BaseHandlers) GetSessionStatus(c *gin.Context)

GetSessionStatus returns compact session health with wake state when available.

func (*BaseHandlers) GetSettingsAutomation 

func (h *BaseHandlers) GetSettingsAutomation(c *gin.Context)

GetSettingsAutomation returns the automation settings section.

func (*BaseHandlers) GetSettingsGeneral 

func (h *BaseHandlers) GetSettingsGeneral(c *gin.Context)

GetSettingsGeneral returns the general settings section.

func (*BaseHandlers) GetSettingsHooksExtensions 

func (h *BaseHandlers) GetSettingsHooksExtensions(c *gin.Context)

GetSettingsHooksExtensions returns the hooks and extensions settings section.

func (*BaseHandlers) GetSettingsMemory 

func (h *BaseHandlers) GetSettingsMemory(c *gin.Context)

GetSettingsMemory returns the memory settings section.

func (*BaseHandlers) GetSettingsNetwork 

func (h *BaseHandlers) GetSettingsNetwork(c *gin.Context)

GetSettingsNetwork returns the network settings section.

func (*BaseHandlers) GetSettingsObservability 

func (h *BaseHandlers) GetSettingsObservability(c *gin.Context)

GetSettingsObservability returns the observability settings section.

func (*BaseHandlers) GetSettingsProvider 

func (h *BaseHandlers) GetSettingsProvider(c *gin.Context)

GetSettingsProvider returns one provider settings item.

func (*BaseHandlers) GetSettingsRestartStatus 

func (h *BaseHandlers) GetSettingsRestartStatus(c *gin.Context)

GetSettingsRestartStatus returns the persisted restart operation payload.

func (*BaseHandlers) GetSettingsSandbox 

func (h *BaseHandlers) GetSettingsSandbox(c *gin.Context)

GetSettingsSandbox returns one sandbox settings item.

func (*BaseHandlers) GetSettingsSkills 

func (h *BaseHandlers) GetSettingsSkills(c *gin.Context)

GetSettingsSkills returns the skills settings section.

func (*BaseHandlers) GetSettingsUpdate 

func (h *BaseHandlers) GetSettingsUpdate(c *gin.Context)

GetSettingsUpdate returns the current software update status snapshot.

func (*BaseHandlers) GetSkill 

func (h *BaseHandlers) GetSkill(c *gin.Context)

GetSkill returns one skill by name.

func (*BaseHandlers) GetSkillContent 

func (h *BaseHandlers) GetSkillContent(c *gin.Context)

GetSkillContent returns the explicit body for one skill.

func (*BaseHandlers) GetSkillMarketplaceInfo 

func (h *BaseHandlers) GetSkillMarketplaceInfo(c *gin.Context)

GetSkillMarketplaceInfo returns remote marketplace metadata for one skill slug.

func (*BaseHandlers) GetSkillShadows 

func (h *BaseHandlers) GetSkillShadows(c *gin.Context)

GetSkillShadows returns every declaration involved in resolving one skill.

func (*BaseHandlers) GetStatus 

func (h *BaseHandlers) GetStatus(c *gin.Context)

GetStatus returns the hard-cut runtime status payload shared by HTTP and UDS.

func (*BaseHandlers) GetSupportBundle 

func (h *BaseHandlers) GetSupportBundle(c *gin.Context)

GetSupportBundle returns the current status for one support bundle operation.

func (*BaseHandlers) GetTask 

func (h *BaseHandlers) GetTask(c *gin.Context)

GetTask returns one expanded task view.

func (*BaseHandlers) GetTaskBridgeNotificationSubscription 

func (h *BaseHandlers) GetTaskBridgeNotificationSubscription(c *gin.Context)

GetTaskBridgeNotificationSubscription returns one task-scoped terminal bridge notification target.

func (*BaseHandlers) GetTaskExecutionProfile 

func (h *BaseHandlers) GetTaskExecutionProfile(c *gin.Context)

GetTaskExecutionProfile returns one task-owned execution profile.

func (*BaseHandlers) GetTaskRun 

func (h *BaseHandlers) GetTaskRun(c *gin.Context)

GetTaskRun returns one run-detail view.

func (*BaseHandlers) GetTaskRunReview 

func (h *BaseHandlers) GetTaskRunReview(c *gin.Context)

GetTaskRunReview returns one task-run review.

func (*BaseHandlers) GetTool 

func (h *BaseHandlers) GetTool(c *gin.Context)

GetTool returns one operator-visible tool projection.

func (*BaseHandlers) GetToolset 

func (h *BaseHandlers) GetToolset(c *gin.Context)

GetToolset returns one named toolset with expansion diagnostics.

func (*BaseHandlers) GetVaultSecretMetadata 

func (h *BaseHandlers) GetVaultSecretMetadata(c *gin.Context)

GetVaultSecretMetadata returns redacted metadata for one vault-backed secret.

func (*BaseHandlers) GetWorkspace 

func (h *BaseHandlers) GetWorkspace(c *gin.Context)

GetWorkspace returns one resolved workspace with related sessions, agents, and skills.

func (*BaseHandlers) HTTPPortValue 

func (h *BaseHandlers) HTTPPortValue() int

HTTPPortValue returns the configured HTTP port in a concurrency-safe way.

func (*BaseHandlers) HookCatalog 

func (h *BaseHandlers) HookCatalog(c *gin.Context)

HookCatalog returns the resolved hook catalog for the supplied workspace and agent view.

func (*BaseHandlers) HookEvents 

func (h *BaseHandlers) HookEvents(c *gin.Context)

HookEvents returns the supported hook taxonomy metadata.

func (*BaseHandlers) HookRuns 

func (h *BaseHandlers) HookRuns(c *gin.Context)

HookRuns returns persisted hook execution history for a session.

func (*BaseHandlers) InspectRun 

func (h *BaseHandlers) InspectRun(c *gin.Context)

InspectRun returns a diagnostic snapshot rooted at one run.

func (*BaseHandlers) InspectSession 

func (h *BaseHandlers) InspectSession(c *gin.Context)

InspectSession returns detailed health, wake audit, and policy correlation metadata.

func (*BaseHandlers) InspectTask 

func (h *BaseHandlers) InspectTask(c *gin.Context)

InspectTask returns a diagnostic snapshot for one task.

func (*BaseHandlers) InstallExtension 

func (h *BaseHandlers) InstallExtension(c *gin.Context)

InstallExtension installs either a local path or a marketplace slug via the daemon.

func (*BaseHandlers) InstallSkillMarketplace 

func (h *BaseHandlers) InstallSkillMarketplace(c *gin.Context)

InstallSkillMarketplace installs one remote marketplace skill.

func (*BaseHandlers) InvokeTool 

func (h *BaseHandlers) InvokeTool(c *gin.Context)

InvokeTool dispatches a concrete tool invocation through the registry.

func (*BaseHandlers) ListAgentHeartbeatHistory 

func (h *BaseHandlers) ListAgentHeartbeatHistory(c *gin.Context)

ListAgentHeartbeatHistory lists HEARTBEAT.md managed authoring revisions.

func (*BaseHandlers) ListAgentSoulHistory 

func (h *BaseHandlers) ListAgentSoulHistory(c *gin.Context)

ListAgentSoulHistory lists SOUL.md managed authoring revisions.

func (*BaseHandlers) ListAgents 

func (h *BaseHandlers) ListAgents(c *gin.Context)

ListAgents returns all readable agent definitions in home paths.

func (*BaseHandlers) ListAutomationJobs 

func (h *BaseHandlers) ListAutomationJobs(c *gin.Context)

ListAutomationJobs returns the filtered automation job list.

func (*BaseHandlers) ListAutomationRuns 

func (h *BaseHandlers) ListAutomationRuns(c *gin.Context)

ListAutomationRuns returns filtered automation run history.

func (*BaseHandlers) ListAutomationTriggers 

func (h *BaseHandlers) ListAutomationTriggers(c *gin.Context)

ListAutomationTriggers returns the filtered automation trigger list.

func (*BaseHandlers) ListBridgeProviders 

func (h *BaseHandlers) ListBridgeProviders(c *gin.Context)

ListBridgeProviders returns installed bridge-capable providers.

func (*BaseHandlers) ListBridgeRoutes 

func (h *BaseHandlers) ListBridgeRoutes(c *gin.Context)

ListBridgeRoutes returns the persisted routes owned by one bridge instance.

func (*BaseHandlers) ListBridgeSecretBindings 

func (h *BaseHandlers) ListBridgeSecretBindings(c *gin.Context)

ListBridgeSecretBindings returns the persisted secret bindings for one bridge instance.

func (*BaseHandlers) ListBridgeTargets 

func (h *BaseHandlers) ListBridgeTargets(c *gin.Context)

ListBridgeTargets returns the daemon-owned target directory for one bridge instance.

func (*BaseHandlers) ListBridges 

func (h *BaseHandlers) ListBridges(c *gin.Context)

ListBridges returns all persisted bridge instances.

func (*BaseHandlers) ListBundleActivations 

func (h *BaseHandlers) ListBundleActivations(c *gin.Context)

func (*BaseHandlers) ListBundleCatalog 

func (h *BaseHandlers) ListBundleCatalog(c *gin.Context)

func (*BaseHandlers) ListExtensions 

func (h *BaseHandlers) ListExtensions(c *gin.Context)

ListExtensions returns daemon-owned installed extension state.

func (*BaseHandlers) ListLogs 

func (h *BaseHandlers) ListLogs(c *gin.Context)

ListLogs returns the filtered runtime log list.

func (*BaseHandlers) ListMemory 

func (h *BaseHandlers) ListMemory(c *gin.Context)

ListMemory lists memory headers for the requested scope.

func (*BaseHandlers) ListMemoryDailyLogs 

func (h *BaseHandlers) ListMemoryDailyLogs(c *gin.Context)

func (*BaseHandlers) ListMemoryDecisions 

func (h *BaseHandlers) ListMemoryDecisions(c *gin.Context)

func (*BaseHandlers) ListMemoryDreams 

func (h *BaseHandlers) ListMemoryDreams(c *gin.Context)

func (*BaseHandlers) ListMemoryExtractorFailures 

func (h *BaseHandlers) ListMemoryExtractorFailures(c *gin.Context)

func (*BaseHandlers) ListMemoryProviders 

func (h *BaseHandlers) ListMemoryProviders(c *gin.Context)

func (*BaseHandlers) ListNotificationPresets 

func (h *BaseHandlers) ListNotificationPresets(c *gin.Context)

ListNotificationPresets returns all persisted notification presets.

func (*BaseHandlers) ListProviders 

func (h *BaseHandlers) ListProviders(c *gin.Context)

ListProviders returns the canonical provider inventory and declared auth readiness.

func (*BaseHandlers) ListResources 

func (h *BaseHandlers) ListResources(c *gin.Context)

ListResources lists desired-state resources under the shared operator service.

func (*BaseHandlers) ListSessionTools 

func (h *BaseHandlers) ListSessionTools(c *gin.Context)

ListSessionTools returns the session/model-callable projection.

func (*BaseHandlers) ListSessions 

func (h *BaseHandlers) ListSessions(c *gin.Context)

ListSessions returns the visible session list.

func (*BaseHandlers) ListSettingsApplyRecords 

func (h *BaseHandlers) ListSettingsApplyRecords(c *gin.Context)

ListSettingsApplyRecords returns persisted config apply history.

func (*BaseHandlers) ListSettingsHooks 

func (h *BaseHandlers) ListSettingsHooks(c *gin.Context)

ListSettingsHooks returns the hook settings collection.

func (*BaseHandlers) ListSettingsMCPServers 

func (h *BaseHandlers) ListSettingsMCPServers(c *gin.Context)

ListSettingsMCPServers returns the MCP server settings collection.

func (*BaseHandlers) ListSettingsProviders 

func (h *BaseHandlers) ListSettingsProviders(c *gin.Context)

ListSettingsProviders returns the provider settings collection.

func (*BaseHandlers) ListSettingsSandboxes 

func (h *BaseHandlers) ListSettingsSandboxes(c *gin.Context)

ListSettingsSandboxes returns the sandbox settings collection.

func (*BaseHandlers) ListSkills 

func (h *BaseHandlers) ListSkills(c *gin.Context)

ListSkills returns skills for the selected workspace or global scope.

func (*BaseHandlers) ListTaskBridgeNotificationSubscriptions 

func (h *BaseHandlers) ListTaskBridgeNotificationSubscriptions(c *gin.Context)

ListTaskBridgeNotificationSubscriptions returns task-scoped terminal bridge notification targets.

func (*BaseHandlers) ListTaskReviews 

func (h *BaseHandlers) ListTaskReviews(c *gin.Context)

ListTaskReviews lists reviews scoped to one task.

func (*BaseHandlers) ListTaskRunReviews 

func (h *BaseHandlers) ListTaskRunReviews(c *gin.Context)

ListTaskRunReviews lists reviews scoped to one task run.

func (*BaseHandlers) ListTaskRuns 

func (h *BaseHandlers) ListTaskRuns(c *gin.Context)

ListTaskRuns returns the filtered run list for one task.

func (*BaseHandlers) ListTasks 

func (h *BaseHandlers) ListTasks(c *gin.Context)

ListTasks returns the filtered task list.

func (*BaseHandlers) ListTools 

func (h *BaseHandlers) ListTools(c *gin.Context)

ListTools returns the operator-visible registry projection.

func (*BaseHandlers) ListToolsets 

func (h *BaseHandlers) ListToolsets(c *gin.Context)

ListToolsets returns named toolsets with expansion diagnostics.

func (*BaseHandlers) ListVaultSecrets 

func (h *BaseHandlers) ListVaultSecrets(c *gin.Context)

ListVaultSecrets returns redacted metadata for vault-backed secrets.

func (*BaseHandlers) ListWorkspaces 

func (h *BaseHandlers) ListWorkspaces(c *gin.Context)

ListWorkspaces returns all registered workspaces.

func (*BaseHandlers) MarkTaskRead 

func (h *BaseHandlers) MarkTaskRead(c *gin.Context)

MarkTaskRead marks one task triage record as read for the current actor.

func (*BaseHandlers) MemoryConfigMetadata 

func (h *BaseHandlers) MemoryConfigMetadata(c *gin.Context)

MemoryConfigMetadata returns settings/config metadata that is safe for agents.

func (*BaseHandlers) MemoryHealth 

func (h *BaseHandlers) MemoryHealth(c *gin.Context)

MemoryHealth returns the memory-specific health snapshot.

func (*BaseHandlers) MemoryHealthWorkspaces 

func (h *BaseHandlers) MemoryHealthWorkspaces(ctx context.Context, rawWorkspace string) ([]string, error)

MemoryHealthWorkspaces returns the workspaces considered for memory health checks.

func (*BaseHandlers) MemoryHistory 

func (h *BaseHandlers) MemoryHistory(c *gin.Context)

MemoryHistory returns bounded, redacted memory operation history.

func (*BaseHandlers) MemoryScopeShow 

func (h *BaseHandlers) MemoryScopeShow(c *gin.Context)

MemoryScopeShow reports the effective selector and precedence chain.

func (*BaseHandlers) ModelCatalogRoute 

func (h *BaseHandlers) ModelCatalogRoute(c *gin.Context)

ModelCatalogRoute dispatches the native provider model catalog route family.

func (*BaseHandlers) NetworkChannel 

func (h *BaseHandlers) NetworkChannel(c *gin.Context)

NetworkChannel returns one network channel detail payload.

func (*BaseHandlers) NetworkChannelMessages 

func (h *BaseHandlers) NetworkChannelMessages(c *gin.Context)

NetworkChannelMessages returns the read-only message timeline for one network channel.

func (*BaseHandlers) NetworkChannels 

func (h *BaseHandlers) NetworkChannels(c *gin.Context)

NetworkChannels returns the active runtime channels.

func (*BaseHandlers) NetworkDirectRoom 

func (h *BaseHandlers) NetworkDirectRoom(c *gin.Context)

NetworkDirectRoom returns one direct-room summary.

func (*BaseHandlers) NetworkDirectRoomMessages 

func (h *BaseHandlers) NetworkDirectRoomMessages(c *gin.Context)

NetworkDirectRoomMessages returns messages isolated to one direct room.

func (*BaseHandlers) NetworkDirectRooms 

func (h *BaseHandlers) NetworkDirectRooms(c *gin.Context)

NetworkDirectRooms returns direct-room summaries for one channel.

func (*BaseHandlers) NetworkInbox 

func (h *BaseHandlers) NetworkInbox(c *gin.Context)

NetworkInbox returns the queued inbound envelopes for one local session.

func (*BaseHandlers) NetworkPeer 

func (h *BaseHandlers) NetworkPeer(c *gin.Context)

NetworkPeer returns one selected peer detail payload.

func (*BaseHandlers) NetworkPeerMessages 

func (h *BaseHandlers) NetworkPeerMessages(c *gin.Context)

NetworkPeerMessages returns the directed message timeline for one network peer.

func (*BaseHandlers) NetworkPeers 

func (h *BaseHandlers) NetworkPeers(c *gin.Context)

NetworkPeers returns the current visible peers, optionally filtered by channel.

func (*BaseHandlers) NetworkSend 

func (h *BaseHandlers) NetworkSend(c *gin.Context)

NetworkSend validates and forwards one outbound network send request.

func (*BaseHandlers) NetworkStatus 

func (h *BaseHandlers) NetworkStatus(c *gin.Context)

NetworkStatus returns the current daemon-owned network runtime status.

func (*BaseHandlers) NetworkThread 

func (h *BaseHandlers) NetworkThread(c *gin.Context)

NetworkThread returns one public-thread summary.

func (*BaseHandlers) NetworkThreadMessages 

func (h *BaseHandlers) NetworkThreadMessages(c *gin.Context)

NetworkThreadMessages returns messages isolated to one public thread.

func (*BaseHandlers) NetworkThreads 

func (h *BaseHandlers) NetworkThreads(c *gin.Context)

NetworkThreads returns public-thread summaries for one channel.

func (*BaseHandlers) NetworkWork 

func (h *BaseHandlers) NetworkWork(c *gin.Context)

NetworkWork returns one network work row by work_id.

func (*BaseHandlers) OpenAIModels 

func (h *BaseHandlers) OpenAIModels(c *gin.Context)

OpenAIModels lists catalog models using the OpenAI-compatible shape.

func (*BaseHandlers) PauseScheduler 

func (h *BaseHandlers) PauseScheduler(c *gin.Context)

PauseScheduler delegates global pause state to the task service's transactional controls.

func (*BaseHandlers) PauseTask 

func (h *BaseHandlers) PauseTask(c *gin.Context)

PauseTask routes task pauses through the service so claim eligibility remains centralized.

func (*BaseHandlers) PreviewBundleActivation 

func (h *BaseHandlers) PreviewBundleActivation(c *gin.Context)

func (*BaseHandlers) ProbeProviderAuth 

func (h *BaseHandlers) ProbeProviderAuth(c *gin.Context)

ProbeProviderAuth runs a live provider auth status command.

func (*BaseHandlers) PromoteMemory 

func (h *BaseHandlers) PromoteMemory(c *gin.Context)

func (*BaseHandlers) ProviderListSnapshot 

func (h *BaseHandlers) ProviderListSnapshot(ctx context.Context) (contract.ProviderListResponse, error)

ProviderListSnapshot returns the same provider inventory payload used by /api/providers.

func (*BaseHandlers) PruneMemorySessions 

func (h *BaseHandlers) PruneMemorySessions(c *gin.Context)

func (*BaseHandlers) PublishTask 

func (h *BaseHandlers) PublishTask(c *gin.Context)

PublishTask publishes one draft task into the canonical runnable lifecycle.

func (*BaseHandlers) PutAgentHeartbeat 

func (h *BaseHandlers) PutAgentHeartbeat(c *gin.Context)

PutAgentHeartbeat creates or replaces HEARTBEAT.md through the managed authoring service.

func (*BaseHandlers) PutAgentSoul 

func (h *BaseHandlers) PutAgentSoul(c *gin.Context)

PutAgentSoul creates or replaces SOUL.md through the managed authoring service.

func (*BaseHandlers) PutBridgeSecretBinding 

func (h *BaseHandlers) PutBridgeSecretBinding(c *gin.Context)

PutBridgeSecretBinding creates or updates one bridge secret binding.

func (*BaseHandlers) PutResource 

func (h *BaseHandlers) PutResource(c *gin.Context)

PutResource creates or updates one desired-state resource.

func (*BaseHandlers) PutSettingsHook 

func (h *BaseHandlers) PutSettingsHook(c *gin.Context)

PutSettingsHook upserts one hook settings item.

func (*BaseHandlers) PutSettingsMCPServer 

func (h *BaseHandlers) PutSettingsMCPServer(c *gin.Context)

PutSettingsMCPServer upserts one MCP server settings item.

func (*BaseHandlers) PutSettingsProvider 

func (h *BaseHandlers) PutSettingsProvider(c *gin.Context)

PutSettingsProvider upserts one provider settings item.

func (*BaseHandlers) PutSettingsSandbox 

func (h *BaseHandlers) PutSettingsSandbox(c *gin.Context)

PutSettingsSandbox upserts one sandbox settings item.

func (*BaseHandlers) PutVaultSecret 

func (h *BaseHandlers) PutVaultSecret(c *gin.Context)

PutVaultSecret stores one write-only vault secret and returns redacted metadata.

func (*BaseHandlers) ReadMemory 

func (h *BaseHandlers) ReadMemory(c *gin.Context)

ReadMemory returns one memory document.

func (*BaseHandlers) RecoverTaskRun added in v0.0.5 

func (h *BaseHandlers) RecoverTaskRun(c *gin.Context)

RecoverTaskRun terminalizes one needs_attention run and queues a fresh child to resume work.

func (*BaseHandlers) RefreshSessionSoul 

func (h *BaseHandlers) RefreshSessionSoul(c *gin.Context)

RefreshSessionSoul refreshes an idle session's Soul snapshot through body-level CAS.

func (*BaseHandlers) ReindexMemory 

func (h *BaseHandlers) ReindexMemory(c *gin.Context)

ReindexMemory rebuilds the derived memory catalog from Markdown memory files.

func (*BaseHandlers) RejectTask 

func (h *BaseHandlers) RejectTask(c *gin.Context)

RejectTask records one rejection decision for an approval-gated task.

func (*BaseHandlers) ReloadMemory 

func (h *BaseHandlers) ReloadMemory(c *gin.Context)

func (*BaseHandlers) ReloadSettings 

func (h *BaseHandlers) ReloadSettings(c *gin.Context)

ReloadSettings reconciles desired config.toml with the daemon active generation.

func (*BaseHandlers) RemoveExtension 

func (h *BaseHandlers) RemoveExtension(c *gin.Context)

RemoveExtension removes one managed extension via the daemon.

func (*BaseHandlers) RemoveSkillMarketplace 

func (h *BaseHandlers) RemoveSkillMarketplace(c *gin.Context)

RemoveSkillMarketplace removes one installed marketplace skill.

func (*BaseHandlers) RemoveTaskDependency 

func (h *BaseHandlers) RemoveTaskDependency(c *gin.Context)

RemoveTaskDependency removes one blocking dependency edge.

func (*BaseHandlers) RepairMemorySessions 

func (h *BaseHandlers) RepairMemorySessions(c *gin.Context)

func (*BaseHandlers) RepairSession 

func (h *BaseHandlers) RepairSession(c *gin.Context)

RepairSession inspects and optionally repairs an interrupted persisted session transcript.

func (*BaseHandlers) ReplayMemorySession 

func (h *BaseHandlers) ReplayMemorySession(c *gin.Context)

func (*BaseHandlers) RequestTaskRunReview 

func (h *BaseHandlers) RequestTaskRunReview(c *gin.Context)

RequestTaskRunReview creates or replays one authoritative review request for a task run.

func (*BaseHandlers) RequireRouteSessionInWorkspace 

func (h *BaseHandlers) RequireRouteSessionInWorkspace(c *gin.Context) (string, bool)

RequireRouteSessionInWorkspace validates that the route session id belongs to the workspace route scope before transport-specific handlers open the session.

func (*BaseHandlers) ResetMemory 

func (h *BaseHandlers) ResetMemory(c *gin.Context)

func (*BaseHandlers) ResetOnboarding 

func (h *BaseHandlers) ResetOnboarding(c *gin.Context)

ResetOnboarding clears the onboarding completion flag so the wizard runs again.

func (*BaseHandlers) ResolveBridgeTarget 

func (h *BaseHandlers) ResolveBridgeTarget(c *gin.Context)

ResolveBridgeTarget resolves a friendly bridge target name without sending.

func (*BaseHandlers) ResolveMemoryLocation 

func (h *BaseHandlers) ResolveMemoryLocation(
	filename string,
	rawScope string,
	rawWorkspace string,
) (MemoryLocation, error)

ResolveMemoryLocation resolves the storage location for a memory document.

func (*BaseHandlers) ResolveNetworkDirectRoom 

func (h *BaseHandlers) ResolveNetworkDirectRoom(c *gin.Context)

ResolveNetworkDirectRoom creates or returns a deterministic two-party direct room.

func (*BaseHandlers) ResolveWorkspace 

func (h *BaseHandlers) ResolveWorkspace(c *gin.Context)

ResolveWorkspace resolves or registers a workspace from a path.

func (*BaseHandlers) RestartBridge 

func (h *BaseHandlers) RestartBridge(c *gin.Context)

RestartBridge restarts one bridge instance while preserving route ownership.

func (*BaseHandlers) ResumeScheduler 

func (h *BaseHandlers) ResumeScheduler(c *gin.Context)

ResumeScheduler clears global pause state through the same control store that claims read.

func (*BaseHandlers) ResumeSession 

func (h *BaseHandlers) ResumeSession(c *gin.Context)

ResumeSession attaches a caller to an eligible live session.

func (*BaseHandlers) ResumeTask 

func (h *BaseHandlers) ResumeTask(c *gin.Context)

ResumeTask keeps pause recovery on the same service path that owns claim eligibility.

func (*BaseHandlers) RetryMemoryDream 

func (h *BaseHandlers) RetryMemoryDream(c *gin.Context)

func (*BaseHandlers) RetryMemoryExtractor 

func (h *BaseHandlers) RetryMemoryExtractor(c *gin.Context)

func (*BaseHandlers) RetryTaskRun 

func (h *BaseHandlers) RetryTaskRun(c *gin.Context)

RetryTaskRun enqueues a new run linked to one failed source run.

func (*BaseHandlers) RevertMemoryDecision 

func (h *BaseHandlers) RevertMemoryDecision(c *gin.Context)

func (*BaseHandlers) RollbackAgentHeartbeat 

func (h *BaseHandlers) RollbackAgentHeartbeat(c *gin.Context)

RollbackAgentHeartbeat rolls HEARTBEAT.md back to a prior revision or snapshot digest.

func (*BaseHandlers) RollbackAgentSoul 

func (h *BaseHandlers) RollbackAgentSoul(c *gin.Context)

RollbackAgentSoul rolls SOUL.md back to a prior managed revision.

func (*BaseHandlers) SearchExtensionMarketplace 

func (h *BaseHandlers) SearchExtensionMarketplace(c *gin.Context)

SearchExtensionMarketplace returns daemon-owned marketplace search results.

func (*BaseHandlers) SearchMemory 

func (h *BaseHandlers) SearchMemory(c *gin.Context)

SearchMemory returns ranked durable memory matches.

func (*BaseHandlers) SearchSessionTools 

func (h *BaseHandlers) SearchSessionTools(c *gin.Context)

SearchSessionTools searches only within the session/model-callable projection.

func (*BaseHandlers) SearchSkillMarketplace 

func (h *BaseHandlers) SearchSkillMarketplace(c *gin.Context)

SearchSkillMarketplace searches the configured remote marketplace for skills.

func (*BaseHandlers) SearchTools 

func (h *BaseHandlers) SearchTools(c *gin.Context)

SearchTools searches the operator-visible registry projection.

func (*BaseHandlers) SelectMemoryProvider 

func (h *BaseHandlers) SelectMemoryProvider(c *gin.Context)

func (*BaseHandlers) SessionEvents 

func (h *BaseHandlers) SessionEvents(c *gin.Context)

SessionEvents returns the filtered session event list.

func (*BaseHandlers) SessionHistory 

func (h *BaseHandlers) SessionHistory(c *gin.Context)

SessionHistory returns the grouped turn history for a session.

func (*BaseHandlers) SessionRecap 

func (h *BaseHandlers) SessionRecap(c *gin.Context)

SessionRecap returns a deterministic recap composed from persisted session state.

func (*BaseHandlers) SessionTranscript 

func (h *BaseHandlers) SessionTranscript(c *gin.Context)

SessionTranscript returns the stored transcript for a session.

func (*BaseHandlers) SessionsSnapshot 

func (h *BaseHandlers) SessionsSnapshot(ctx context.Context) (contract.SessionsResponse, error)

SessionsSnapshot returns all known session payloads for support bundles.

func (*BaseHandlers) SetHTTPPort 

func (h *BaseHandlers) SetHTTPPort(port int)

SetHTTPPort overrides the reported HTTP port for daemon status responses.

func (*BaseHandlers) SetStreamDone 

func (h *BaseHandlers) SetStreamDone(done <-chan struct{})

SetStreamDone updates the transport shutdown bridge used by streaming handlers.

func (*BaseHandlers) SetTaskExecutionProfile 

func (h *BaseHandlers) SetTaskExecutionProfile(c *gin.Context)

SetTaskExecutionProfile replaces one task-owned execution profile.

func (*BaseHandlers) StartTask 

func (h *BaseHandlers) StartTask(c *gin.Context)

StartTask explicitly enqueues one executable run for an existing task.

func (*BaseHandlers) StartTaskRun 

func (h *BaseHandlers) StartTaskRun(c *gin.Context)

StartTaskRun starts one claimed run.

func (*BaseHandlers) StatusSnapshot 

func (h *BaseHandlers) StatusSnapshot(ctx context.Context) (contract.StatusPayload, error)

StatusSnapshot returns the same runtime status payload used by /api/status.

func (*BaseHandlers) StopSession 

func (h *BaseHandlers) StopSession(c *gin.Context)

StopSession stops a running session without deleting persisted history.

func (*BaseHandlers) StreamBridgeHealth 

func (h *BaseHandlers) StreamBridgeHealth(c *gin.Context)

StreamBridgeHealth streams bridge health snapshots over SSE.

func (*BaseHandlers) StreamDoneChannel 

func (h *BaseHandlers) StreamDoneChannel() <-chan struct{}

StreamDoneChannel returns the transport shutdown channel in a concurrency-safe way.

func (*BaseHandlers) StreamLogs 

func (h *BaseHandlers) StreamLogs(c *gin.Context)

StreamLogs streams runtime logs over SSE.

func (*BaseHandlers) StreamSession 

func (h *BaseHandlers) StreamSession(c *gin.Context)

StreamSession streams session events over SSE.

func (*BaseHandlers) StreamSettingsObservabilityLogTail 

func (h *BaseHandlers) StreamSettingsObservabilityLogTail(c *gin.Context)

StreamSettingsObservabilityLogTail streams daemon log lines over SSE.

func (*BaseHandlers) StreamTask 

func (h *BaseHandlers) StreamTask(c *gin.Context)

StreamTask streams task-native live events over SSE.

func (*BaseHandlers) SubmitTaskRunReviewVerdict 

func (h *BaseHandlers) SubmitTaskRunReviewVerdict(c *gin.Context)

SubmitTaskRunReviewVerdict records one reviewer verdict for a review request.

func (*BaseHandlers) TaskDashboard 

func (h *BaseHandlers) TaskDashboard(c *gin.Context)

TaskDashboard returns the observer-backed task dashboard view.

func (*BaseHandlers) TaskInbox 

func (h *BaseHandlers) TaskInbox(c *gin.Context)

TaskInbox returns the observer-backed task inbox view.

func (*BaseHandlers) TaskTimeline 

func (h *BaseHandlers) TaskTimeline(c *gin.Context)

TaskTimeline returns the task-native live timeline for one task.

func (*BaseHandlers) TaskTree 

func (h *BaseHandlers) TaskTree(c *gin.Context)

TaskTree returns one task-tree live view.

func (*BaseHandlers) TestBridgeDelivery 

func (h *BaseHandlers) TestBridgeDelivery(c *gin.Context)

TestBridgeDelivery resolves the typed outbound delivery target for one bridge instance without requiring a live platform adapter.

func (*BaseHandlers) TriggerAutomationJob 

func (h *BaseHandlers) TriggerAutomationJob(c *gin.Context)

TriggerAutomationJob forces one immediate manual automation run.

func (*BaseHandlers) TriggerMemoryDream 

func (h *BaseHandlers) TriggerMemoryDream(c *gin.Context)

TriggerMemoryDream triggers dream consolidation when enabled.

func (*BaseHandlers) TriggerSettingsRestart 

func (h *BaseHandlers) TriggerSettingsRestart(c *gin.Context)

TriggerSettingsRestart starts the asynchronous daemon restart flow.

func (*BaseHandlers) UpdateAutomationJob 

func (h *BaseHandlers) UpdateAutomationJob(c *gin.Context)

UpdateAutomationJob patches one automation job definition.

func (*BaseHandlers) UpdateAutomationTrigger 

func (h *BaseHandlers) UpdateAutomationTrigger(c *gin.Context)

UpdateAutomationTrigger patches one automation trigger definition.

func (*BaseHandlers) UpdateBridge 

func (h *BaseHandlers) UpdateBridge(c *gin.Context)

UpdateBridge patches the mutable configuration fields of one bridge instance.

func (*BaseHandlers) UpdateBundleActivation 

func (h *BaseHandlers) UpdateBundleActivation(c *gin.Context)

func (*BaseHandlers) UpdateExtension 

func (h *BaseHandlers) UpdateExtension(c *gin.Context)

UpdateExtension updates one marketplace-installed extension via the daemon.

func (*BaseHandlers) UpdateNotificationPreset 

func (h *BaseHandlers) UpdateNotificationPreset(c *gin.Context)

UpdateNotificationPreset mutates one preset.

func (*BaseHandlers) UpdateSettingsAutomation 

func (h *BaseHandlers) UpdateSettingsAutomation(c *gin.Context)

UpdateSettingsAutomation persists the automation settings section.

func (*BaseHandlers) UpdateSettingsGeneral 

func (h *BaseHandlers) UpdateSettingsGeneral(c *gin.Context)

UpdateSettingsGeneral persists the general settings section.

func (*BaseHandlers) UpdateSettingsHooksExtensions 

func (h *BaseHandlers) UpdateSettingsHooksExtensions(c *gin.Context)

UpdateSettingsHooksExtensions persists the hooks and extensions settings section.

func (*BaseHandlers) UpdateSettingsMemory 

func (h *BaseHandlers) UpdateSettingsMemory(c *gin.Context)

UpdateSettingsMemory persists the memory settings section.

func (*BaseHandlers) UpdateSettingsNetwork 

func (h *BaseHandlers) UpdateSettingsNetwork(c *gin.Context)

UpdateSettingsNetwork persists the network settings section.

func (*BaseHandlers) UpdateSettingsObservability 

func (h *BaseHandlers) UpdateSettingsObservability(c *gin.Context)

UpdateSettingsObservability persists the observability settings section.

func (*BaseHandlers) UpdateSettingsSkills 

func (h *BaseHandlers) UpdateSettingsSkills(c *gin.Context)

UpdateSettingsSkills persists the skills settings section.

func (*BaseHandlers) UpdateSkillMarketplace 

func (h *BaseHandlers) UpdateSkillMarketplace(c *gin.Context)

UpdateSkillMarketplace checks or applies updates for marketplace skills.

func (*BaseHandlers) UpdateTask 

func (h *BaseHandlers) UpdateTask(c *gin.Context)

UpdateTask patches one mutable task surface.

func (*BaseHandlers) UpdateWorkspace 

func (h *BaseHandlers) UpdateWorkspace(c *gin.Context)

UpdateWorkspace updates a registered workspace.

func (*BaseHandlers) ValidateAgentHeartbeat 

func (h *BaseHandlers) ValidateAgentHeartbeat(c *gin.Context)

ValidateAgentHeartbeat validates a proposed HEARTBEAT.md body.

func (*BaseHandlers) ValidateAgentSoul 

func (h *BaseHandlers) ValidateAgentSoul(c *gin.Context)

ValidateAgentSoul validates a proposed SOUL.md body for the caller's agent.

func (*BaseHandlers) ValidateAgentSoulDefinition 

func (h *BaseHandlers) ValidateAgentSoulDefinition(c *gin.Context)

ValidateAgentSoulDefinition validates a proposed SOUL.md body for one workspace-visible agent.

func (*BaseHandlers) WakeAgentHeartbeat 

func (h *BaseHandlers) WakeAgentHeartbeat(c *gin.Context)

WakeAgentHeartbeat requests one manual advisory Heartbeat wake decision.

func (*BaseHandlers) WriteMemory 

func (h *BaseHandlers) WriteMemory(c *gin.Context)

WriteMemory creates or proposes one Memory v2 entry.

type BridgeService 

type BridgeService interface {
	bridgepkg.Registry
	bridgepkg.TargetDirectory
	bridgepkg.BridgeTaskSubscriptionStore
	bridgepkg.TargetResolver
	ListProviders(ctx context.Context) ([]bridgepkg.BridgeProvider, error)
	ListSecretBindings(ctx context.Context, bridgeInstanceID string) ([]bridgepkg.BridgeSecretBinding, error)
	PutSecretBinding(ctx context.Context, binding bridgepkg.BridgeSecretBinding, secretValue *string) error
	DeleteSecretBinding(ctx context.Context, bridgeInstanceID string, bindingName string) error
	StartInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)
	StopInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)
	RestartInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)
}

BridgeService is the daemon-owned bridge runtime surface exposed by API transports.

type BundleService 

type BundleService interface {
	Catalog(ctx context.Context) ([]bundlepkg.CatalogEntry, error)
	PreviewActivation(ctx context.Context, req bundlepkg.ActivateRequest) (bundlepkg.ActivationPreview, error)
	Activate(ctx context.Context, req bundlepkg.ActivateRequest) (bundlepkg.ActivationPreview, error)
	ListActivations(ctx context.Context) ([]bundlepkg.ActivationPreview, error)
	GetActivation(ctx context.Context, id string) (bundlepkg.ActivationPreview, error)
	UpdateActivation(ctx context.Context, req bundlepkg.UpdateActivationRequest) (bundlepkg.ActivationPreview, error)
	Deactivate(ctx context.Context, id string) error
	NetworkSettings(ctx context.Context) (bundlepkg.NetworkSettings, error)
}

BundleService exposes extension bundle catalog, activation, and effective network-default state to API transports.

type CoordinatorConfigResolver 

type CoordinatorConfigResolver interface {
	ResolveCoordinatorConfig(ctx context.Context, workspaceID string) (aghconfig.CoordinatorConfig, error)
}

CoordinatorConfigResolver resolves safe coordinator policy for agent-facing reads.

type DreamTrigger 

type DreamTrigger interface {
	Trigger(ctx context.Context, workspace string) (bool, string, error)
	LastConsolidatedAt() (time.Time, error)
	Enabled() bool
}

DreamTrigger exposes consolidation controls and state to the API layer.

type ExtensionService 

type ExtensionService interface {
	List(ctx context.Context) ([]contract.ExtensionPayload, error)
	SearchMarketplace(
		ctx context.Context,
		query string,
		source string,
		limit int,
	) ([]contract.ExtensionMarketplaceEntry, error)
	Install(
		ctx context.Context,
		req contract.InstallExtensionRequest,
		actor taskpkg.ActorContext,
	) (contract.ExtensionPayload, error)
	Update(
		ctx context.Context,
		name string,
		req contract.UpdateExtensionRequest,
		actor taskpkg.ActorContext,
	) (contract.ManagedExtensionUpdatePayload, error)
	Remove(ctx context.Context, name string, actor taskpkg.ActorContext) (contract.ManagedExtensionRemovePayload, error)
	Enable(ctx context.Context, name string, actor taskpkg.ActorContext) (contract.ExtensionPayload, error)
	Disable(ctx context.Context, name string, actor taskpkg.ActorContext) (contract.ExtensionPayload, error)
	Status(ctx context.Context, name string) (contract.ExtensionPayload, error)
	Provenance(ctx context.Context, name string) (contract.ExtensionProvenancePayload, error)
}

ExtensionService exposes daemon-backed extension management to API transports.

type FlushWriter 

type FlushWriter interface {
	io.Writer
	Flush()
}

FlushWriter is an SSE writer that can flush streamed content.

func PrepareSSE 

func PrepareSSE(c *gin.Context) (FlushWriter, error)

PrepareSSE configures a Gin response for SSE streaming.

type HeartbeatAuthoringService 

type HeartbeatAuthoringService interface {
	heartbeat.AuthoringService
}

HeartbeatAuthoringService exposes managed HEARTBEAT.md authoring to API handlers.

type HeartbeatStatusService 

type HeartbeatStatusService interface {
	heartbeat.StatusService
}

HeartbeatStatusService composes read-only Heartbeat policy, wake state, and health.

type HeartbeatWakeEventReader 

type HeartbeatWakeEventReader interface {
	ListHeartbeatWakeEvents(ctx context.Context, query heartbeat.WakeEventListQuery) ([]heartbeat.WakeEvent, error)
}

HeartbeatWakeEventReader lists retained Heartbeat wake audit rows.

type HeartbeatWakeService 

type HeartbeatWakeService interface {
	Wake(ctx context.Context, req heartbeat.WakeRequest) (heartbeat.WakeDecision, error)
}

HeartbeatWakeService evaluates one advisory manual Heartbeat wake.

type LogsCursor 

type LogsCursor struct {
	Timestamp time.Time
	Sequence  int64
	ID        string
}

LogsCursor is the shared cursor used for logs streaming.

func EmitLogs 

func EmitLogs(writer FlushWriter, events []store.EventSummary, cursor LogsCursor) LogsCursor

EmitLogs writes log events newer than the supplied cursor.

func ParseLogsCursor 

func ParseLogsCursor(raw string) (LogsCursor, error)

ParseLogsCursor parses a Last-Event-ID cursor for logs streaming.

type MemoryExtractorService 

type MemoryExtractorService interface {
	Status(ctx context.Context) (contract.MemoryExtractorStatusPayload, error)
	ListFailures(ctx context.Context) ([]contract.MemoryExtractorFailurePayload, error)
	Retry(ctx context.Context, req contract.MemoryExtractorRetryRequest) (contract.MemoryExtractorRetryResponse, error)
	Drain(ctx context.Context) (contract.MemoryExtractorDrainResponse, error)
}

MemoryExtractorService exposes the daemon-owned Memory v2 extractor runtime.

type MemoryLocation 

type MemoryLocation struct {
	Scope       memcontract.Scope
	Workspace   string
	WorkspaceID string
	AgentName   string
	AgentTier   memcontract.AgentTier
	Filename    string
}

MemoryLocation identifies the storage location for a memory document.

type MemoryProviderService 

type MemoryProviderService interface {
	List(ctx context.Context, workspaceID string) ([]contract.MemoryProviderPayload, error)
	Get(ctx context.Context, workspaceID string, name string) (contract.MemoryProviderPayload, error)
	Select(ctx context.Context, workspaceID string, name string) (contract.MemoryProviderPayload, error)
	Enable(
		ctx context.Context,
		workspaceID string,
		name string,
		reason string,
	) (contract.MemoryProviderLifecycleResponse, error)
	Disable(
		ctx context.Context,
		workspaceID string,
		name string,
		reason string,
	) (contract.MemoryProviderLifecycleResponse, error)
}

MemoryProviderService exposes the active MemoryProvider registry.

type MemorySessionLedgerService 

type MemorySessionLedgerService interface {
	Get(ctx context.Context, sessionID string) (contract.MemorySessionLedgerResponse, error)
	Replay(
		ctx context.Context,
		sessionID string,
		req contract.MemorySessionReplayRequest,
	) (contract.MemorySessionReplayResponse, error)
	Prune(ctx context.Context, req contract.MemorySessionsPruneRequest) (contract.MemorySessionsPruneResponse, error)
	Repair(ctx context.Context) (contract.MemorySessionsRepairResponse, error)
}

MemorySessionLedgerService exposes materialized session ledgers and replay.

type ModelCatalogService 

type ModelCatalogService interface {
	modelcatalog.Service
}

ModelCatalogService exposes daemon-owned provider model catalog reads and refreshes.

type NetworkService 

type NetworkService interface {
	Send(ctx context.Context, req network.SendRequest) (string, error)
	ListPeers(ctx context.Context, workspaceID string, channel string) ([]network.PeerInfo, error)
	ListChannels(ctx context.Context, workspaceID string) ([]network.ChannelInfo, error)
	Status(ctx context.Context) (*network.Status, error)
	Inbox(ctx context.Context, sessionID string) ([]network.Envelope, error)
	WaitInbox(ctx context.Context, sessionID string, channel string) ([]network.Envelope, error)
}

NetworkService is the runtime network surface exposed to daemon transports.

type NetworkStore 

type NetworkStore interface {
	store.NetworkConversationStore
	ListNetworkAudit(ctx context.Context, query store.NetworkAuditQuery) ([]store.NetworkAuditEntry, error)
	GetNetworkChannel(ctx context.Context, ref store.NetworkChannelRef) (store.NetworkChannelEntry, error)
	ListNetworkChannels(ctx context.Context, query store.NetworkChannelQuery) ([]store.NetworkChannelEntry, error)
	WriteNetworkChannel(ctx context.Context, entry store.NetworkChannelEntry) error
	DeleteNetworkChannel(ctx context.Context, ref store.NetworkChannelRef) error
	ListNetworkMessages(ctx context.Context, query store.NetworkMessageQuery) ([]store.NetworkMessageEntry, error)
}

NetworkStore exposes persisted network audit, channel metadata CRUD, and timeline queries to the API layer.

type NotificationPresetService 

type NotificationPresetService interface {
	List(ctx context.Context, query presetspkg.Query) ([]presetspkg.Preset, error)
	Get(ctx context.Context, name string) (presetspkg.Preset, error)
	Create(ctx context.Context, req presetspkg.CreateRequest) (presetspkg.Preset, error)
	Update(ctx context.Context, name string, req presetspkg.UpdateRequest) (presetspkg.Preset, error)
	Delete(ctx context.Context, name string) error
}

NotificationPresetService is the daemon-owned notification preset runtime.

type Observer 

type Observer interface {
	QueryEvents(ctx context.Context, query store.EventSummaryQuery) ([]store.EventSummary, error)
	QueryHookCatalog(ctx context.Context, filter hookspkg.CatalogFilter) ([]hookspkg.CatalogEntry, error)
	QueryHookRuns(ctx context.Context, query store.HookRunQuery) ([]hookspkg.HookRunRecord, error)
	QueryHookEvents(ctx context.Context, filter hookspkg.EventFilter) ([]hookspkg.EventDescriptor, error)
	QueryBridgeHealth(ctx context.Context) ([]observe.BridgeInstanceHealth, error)
	Health(ctx context.Context) (observe.Health, error)
	QueryTaskDashboard(ctx context.Context, query observe.TaskDashboardQuery) (observe.TaskDashboardView, error)
	QueryTaskInbox(
		ctx context.Context,
		query observe.TaskInboxQuery,
		actor taskpkg.ActorIdentity,
	) (observe.TaskInboxView, error)
}

Observer is the observability surface exposed by API transports.

type OnboardingStore 

type OnboardingStore interface {
	store.OnboardingStore
}

OnboardingStore persists the global first-run onboarding completion flag.

type PromptStreamEncoder 

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

PromptStreamEncoder converts raw ACP agent events into the typed public prompt stream envelope used by HTTP, UDS, and CLI streaming surfaces.

func NewPromptStreamEncoder 

func NewPromptStreamEncoder(now func() time.Time) *PromptStreamEncoder

NewPromptStreamEncoder constructs a prompt-stream encoder with deterministic timestamps for generated IDs when provided.

func (*PromptStreamEncoder) Emit 

func (e *PromptStreamEncoder) Emit(writer FlushWriter, event acp.AgentEvent) error

Emit writes one public prompt-stream frame for the supplied raw agent event.

func (*PromptStreamEncoder) Finish 

func (e *PromptStreamEncoder) Finish(writer FlushWriter, event acp.AgentEvent) error

Finish closes any open blocks and emits the terminal finish frame followed by the `[DONE]` sentinel exactly once.

func (*PromptStreamEncoder) Start 

func (e *PromptStreamEncoder) Start(writer FlushWriter, messageID string) error

Start emits the public prompt stream start frame as soon as the daemon has accepted a durable turn. Later event frames reuse the same message id.

type ResourceService 

type ResourceService interface {
	List(ctx context.Context, filter resources.ResourceFilter) ([]resources.RawRecord, error)
	Get(ctx context.Context, kind resources.ResourceKind, id string) (resources.RawRecord, error)
	Put(ctx context.Context, draft resources.RawDraft) (resources.RawRecord, error)
	Delete(ctx context.Context, kind resources.ResourceKind, id string, expectedVersion int64) error
}

ResourceService exposes the operator-facing desired-state CRUD surface to API transports.

func NewOperatorResourceService 

func NewOperatorResourceService(cfg *ResourceServiceConfig) (ResourceService, error)

NewOperatorResourceService constructs the shared desired-state CRUD service used by HTTP and UDS handlers. Resource writes validate against registered codecs when available and otherwise fall back to the raw kernel semantics so the generic control plane remains usable before family codecs land.

type ResourceServiceConfig 

type ResourceServiceConfig struct {
	RawStore      resources.RawStore
	CodecRegistry *resources.CodecRegistry
	Actor         resources.MutationActor
	Trigger       func(context.Context, resources.ResourceKind, resources.ReconcileReason) error
}

ResourceServiceConfig configures the shared operator-facing resource service.

type SSEMessage 

type SSEMessage struct {
	ID   string
	Name string
	Data any
}

SSEMessage is the shared SSE envelope.

type SessionCatalog 

type SessionCatalog interface {
	ListSessions(ctx context.Context, query store.SessionListQuery) ([]store.SessionInfo, error)
	AttachSession(ctx context.Context, req store.SessionAttachRequest) (store.SessionAttach, error)
}

SessionCatalog exposes daemon-owned session catalog operations that must not create a second live session authority.

type SessionHealthReader 

type SessionHealthReader interface {
	GetSessionHealth(ctx context.Context, sessionID string) (heartbeat.SessionHealth, error)
}

SessionHealthReader reads metadata-only session health rows.

type SessionManager 

type SessionManager interface {
	Create(ctx context.Context, opts session.CreateOpts) (*session.Session, error)
	List() []*session.Info
	ListAll(ctx context.Context) ([]*session.Info, error)
	Status(ctx context.Context, id string) (*session.Info, error)
	Events(ctx context.Context, id string, query store.EventQuery) ([]store.SessionEvent, error)
	History(ctx context.Context, id string, query store.EventQuery) ([]store.TurnHistory, error)
	Transcript(ctx context.Context, id string) ([]transcript.UIMessage, error)
	RepairSession(ctx context.Context, opts session.RepairOpts) (*session.RepairResult, error)
	Delete(ctx context.Context, id string) error
	Stop(ctx context.Context, id string) error
	StopWithCause(ctx context.Context, id string, cause session.StopCause, detail string) error
	Resume(ctx context.Context, id string) (*session.Session, error)
	ClearConversation(ctx context.Context, id string) (*session.Session, error)
	Prompt(ctx context.Context, id string, msg string) (<-chan acp.AgentEvent, error)
	SendPrompt(ctx context.Context, id string, opts session.SendPromptOpts) (session.SendPromptResult, error)
	InterruptPrompt(ctx context.Context, id string) (session.SendPromptResult, error)
	SteerPrompt(ctx context.Context, id string, msg string) (session.SendPromptResult, error)
	CancelQueuedPrompt(ctx context.Context, id string, queueEntryID string) (session.SendPromptResult, error)
	CancelPrompt(ctx context.Context, id string) error
	ApprovePermission(ctx context.Context, id string, req acp.ApproveRequest) error
	InputQueueSummary(ctx context.Context, id string) (session.InputQueueSummary, error)
}

SessionManager is the runtime session surface exposed by API transports. List returns the current in-memory session snapshot without performing I/O. ListAll may perform I/O to return the authoritative session set, so it accepts a context.

type SettingsLogTailEventPayload 

type SettingsLogTailEventPayload struct {
	Line string `json:"line"`
}

SettingsLogTailEventPayload is the shared SSE payload for daemon log tailing.

type SettingsRestartController 

type SettingsRestartController interface {
	RequestRestart(ctx context.Context) (SettingsRestartOperation, error)
	GetRestartOperation(ctx context.Context, operationID string) (SettingsRestartOperation, error)
}

SettingsRestartController exposes the daemon-owned restart action and persisted status surface.

type SettingsRestartOperation 

type SettingsRestartOperation struct {
	OperationID        string
	Status             string
	OldPID             int
	OldStartedAt       time.Time
	OldSocketPath      string
	NewPID             int
	ActiveSessionCount int
	FailureReason      string
	StartedAt          time.Time
	UpdatedAt          time.Time
	CompletedAt        *time.Time
}

SettingsRestartOperation is the daemon-owned restart record exposed to settings transports.

type SettingsService 

type SettingsService interface {
	GetSection(ctx context.Context, req settingspkg.SectionRequest) (settingspkg.SectionEnvelope, error)
	UpdateSection(ctx context.Context, req settingspkg.SectionUpdateRequest) (settingspkg.MutationResult, error)
	ApplySection(ctx context.Context, req settingspkg.SectionUpdateRequest) (settingspkg.ApplyResult, error)
	ListCollection(ctx context.Context, req settingspkg.CollectionRequest) (settingspkg.CollectionEnvelope, error)
	PutCollectionItem(ctx context.Context, req settingspkg.CollectionItemPutRequest) (settingspkg.MutationResult, error)
	ApplyCollectionItem(
		ctx context.Context,
		req settingspkg.CollectionItemPutRequest,
	) (settingspkg.ApplyResult, error)
	DeleteCollectionItem(
		ctx context.Context,
		req settingspkg.CollectionItemDeleteRequest,
	) (
		settingspkg.MutationResult,
		error,
	)
	ApplyCollectionDelete(
		ctx context.Context,
		req settingspkg.CollectionItemDeleteRequest,
	) (settingspkg.ApplyResult, error)
	Reload(ctx context.Context) (settingspkg.ApplyResult, error)
	ListApplyRecords(ctx context.Context, filter settingspkg.ApplyRecordFilter) ([]settingspkg.ApplyRecord, error)
}

SettingsService exposes the daemon-owned settings read and mutation surface to API transports.

type SettingsUpdateController 

type SettingsUpdateController interface {
	GetUpdate(ctx context.Context) (SettingsUpdateStatus, error)
}

SettingsUpdateController exposes the daemon-owned update status surface to settings transports.

type SettingsUpdateStatus 

type SettingsUpdateStatus struct {
	Supported      bool
	Managed        bool
	InstallMethod  string
	CurrentVersion string
	LatestVersion  string
	Available      bool
	Status         string
	Recommendation string
	ReleaseURL     string
	CheckedAt      *time.Time
	LastError      string
}

SettingsUpdateStatus is the daemon-owned software-update snapshot exposed to settings transports.

type SkillMarketplaceService 

type SkillMarketplaceService interface {
	Search(ctx context.Context, query string, limit int) ([]registrypkg.Listing, error)
	Info(ctx context.Context, slug string) (*registrypkg.Detail, error)
	Install(ctx context.Context, slug string, version string) (skillmarketplace.InstallResult, error)
	Update(ctx context.Context, req skillmarketplace.UpdateRequest) ([]skillmarketplace.UpdateResult, error)
	Remove(ctx context.Context, name string) (skillmarketplace.RemoveResult, error)
}

SkillMarketplaceService exposes remote skill marketplace lifecycle operations.

type SkillsRegistry 

type SkillsRegistry interface {
	Get(name string) (*skills.Skill, bool)
	List() []*skills.Skill
	ForWorkspace(ctx context.Context, resolved *workspacepkg.ResolvedWorkspace) ([]*skills.Skill, error)
	ForAgent(ctx context.Context, resolved *workspacepkg.ResolvedWorkspace, agentName string) ([]*skills.Skill, error)
	LoadContent(ctx context.Context, skill *skills.Skill) (string, error)
	LoadResource(ctx context.Context, skill *skills.Skill, relativePath string) (string, error)
	SetEnabled(name string, resolved *workspacepkg.ResolvedWorkspace, enabled bool) error
	SetEnabledForAgent(name string, resolved *workspacepkg.ResolvedWorkspace, agentName string, enabled bool) error
}

SkillsRegistry exposes the daemon-owned skill catalog.

type SkillsRegistryRefresher 

type SkillsRegistryRefresher interface {
	RefreshGlobal(ctx context.Context) error
}

SkillsRegistryRefresher refreshes the daemon global skill catalog after on-disk mutations.

type SoulAuthoringService 

type SoulAuthoringService interface {
	soul.AuthoringService
}

SoulAuthoringService exposes managed SOUL.md authoring and read validation to API handlers.

type SoulRefresher 

type SoulRefresher interface {
	RefreshSoulWithExpectedDigest(
		ctx context.Context,
		id string,
		expectedDigest string,
	) (session.SoulRefreshResult, error)
}

SoulRefresher refreshes a session's resolved Soul snapshot through service-owned CAS.

type SupportBundleService 

type SupportBundleService interface {
	Create(ctx context.Context, req support.CreateRequest) (support.Operation, error)
	Get(ctx context.Context, operationID string) (support.Operation, error)
	DownloadPath(ctx context.Context, operationID string) (support.Operation, string, error)
}

SupportBundleService exposes daemon-owned support bundle operations to transports.

type TaskActorContextResolver 

type TaskActorContextResolver func(c *gin.Context, action string) (taskpkg.ActorContext, error)

TaskActorContextResolver derives the trusted task-domain actor envelope for one API request.

type TaskService 

type TaskService interface {
	taskpkg.Manager
}

TaskService exposes task-domain state and lifecycle surfaces to the API layer.

type ToolApprovalIssuer 

type ToolApprovalIssuer interface {
	CreateToolApproval(
		ctx context.Context,
		scope toolspkg.Scope,
		req toolspkg.ApprovalRequest,
	) (toolspkg.ApprovalGrant, error)
}

ToolApprovalIssuer mints local one-shot approval references for operator transports.

type ToolRegistry 

type ToolRegistry interface {
	List(ctx context.Context, scope toolspkg.Scope) ([]toolspkg.ToolView, error)
	Search(ctx context.Context, scope toolspkg.Scope, q toolspkg.SearchQuery) ([]toolspkg.ToolView, error)
	Get(ctx context.Context, scope toolspkg.Scope, id toolspkg.ToolID) (toolspkg.ToolView, error)
	Call(ctx context.Context, scope toolspkg.Scope, req toolspkg.CallRequest) (toolspkg.ToolResult, error)
}

ToolRegistry exposes registry projection and dispatch without binding API handlers to backend packages.

type ToolsetRegistry 

type ToolsetRegistry interface {
	ListToolsets(ctx context.Context, scope toolspkg.Scope) ([]toolspkg.ToolsetView, error)
	GetToolset(ctx context.Context, scope toolspkg.Scope, id toolspkg.ToolsetID) (toolspkg.ToolsetView, error)
}

ToolsetRegistry exposes named toolset projections.

type VaultService 

type VaultService interface {
	GetMetadata(ctx context.Context, ref string) (vault.Metadata, error)
	ListMetadata(ctx context.Context, prefix string) ([]vault.Metadata, error)
	PutSecret(ctx context.Context, ref string, kind string, plaintext string) (vault.Metadata, error)
	DeleteSecret(ctx context.Context, ref string) error
}

VaultService exposes redacted secret metadata and write-only mutations to API transports.

type WorkspaceGetter 

type WorkspaceGetter interface {
	Get(ctx context.Context, ref string) (workspacepkg.Workspace, error)
}

WorkspaceGetter resolves registered workspaces by reference.

type WorkspaceService 

type WorkspaceService interface {
	Register(ctx context.Context, opts workspacepkg.RegisterOptions) (workspacepkg.Workspace, error)
	Unregister(ctx context.Context, id string) error
	Update(ctx context.Context, id string, opts workspacepkg.UpdateOptions) error
	List(ctx context.Context) ([]workspacepkg.Workspace, error)
	Get(ctx context.Context, idOrNameOrPath string) (workspacepkg.Workspace, error)
	Resolve(ctx context.Context, idOrNameOrPath string) (workspacepkg.ResolvedWorkspace, error)
	ResolveOrRegister(ctx context.Context, path string) (workspacepkg.ResolvedWorkspace, error)
}

WorkspaceService exposes workspace registration and resolution to the API layer.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.