testutil

package

Go to main page

Versions in this module

v0

v0.0.7

Jun 4, 2026

v0.0.6

Jun 3, 2026

Changes in this version

type StubSessionManager

+ PromptSyntheticFn func(context.Context, string, session.SyntheticPromptOpts) (<-chan acp.AgentEvent, error)

+ func (s StubSessionManager) PromptSynthetic(ctx context.Context, id string, opts session.SyntheticPromptOpts) (<-chan acp.AgentEvent, error)

v0.0.5

May 29, 2026

Changes in this version

type StubTaskManager

+ RecoverRunFn recoverRunFunc

+ func (s StubTaskManager) RecoverRun(ctx context.Context, runID string, req taskpkg.RecoverRunRequest, ...) (*taskpkg.RetryRunResult, error)

v0.0.4

May 27, 2026

v0.0.3

May 27, 2026

v0.0.2

May 27, 2026

v0.0.1

May 26, 2026

retracted

Changes in this version

+ var ErrStubNetworkServiceWaitInboxNotImplemented = errors.New("stub network service WaitInbox not implemented")

+ var ErrStubWorkspaceServiceNotImplemented = errors.New("stub workspace service method not implemented")

+ func AssertMemoryV2RouteParity(t testing.TB, got []string)

+ func ConfigWithDisabledNetwork(homePaths aghconfig.HomePaths) aghconfig.Config

+ func DecodeJSONResponse(t *testing.T, recorder *httptest.ResponseRecorder, dest any)

+ func DecodeSSEData(t *testing.T, record SSERecord, dest any)

+ func DiscardLogger() *slog.Logger

+ func ExpectedMemoryV2RouteKeys() []string

+ func MemoryV2RouteKeysFromGin(routes gin.RoutesInfo) []string

+ func MustJSONBody(t *testing.T, value any) []byte

+ func NewDisabledNetworkHomeConfig(t *testing.T) (aghconfig.HomePaths, aghconfig.Config)

+ func NewSession(id string) *session.Session

+ func NewSessionInfo(id string) *session.Info

+ func NewTestHomePaths(t *testing.T) aghconfig.HomePaths

+ func PerformRequest(t *testing.T, engine http.Handler, method, path string, body []byte) *httptest.ResponseRecorder

+ func PerformRequestWithHeaders(t *testing.T, engine http.Handler, method, path string, body []byte, ...) *httptest.ResponseRecorder

+ func WriteAgentDef(t *testing.T, homePaths aghconfig.HomePaths, name string)

+ type SSERecord struct

+ Data []byte

+ Event string

+ ID string

+ func ParseSSE(t *testing.T, body string) []SSERecord

+ type StubAutomationManager struct

+ CreateJobFn func(context.Context, automationpkg.Job) (automationpkg.Job, error)

+ CreateTriggerFn func(context.Context, automationpkg.Trigger, automationpkg.WebhookSecretWrite) (automationpkg.Trigger, error)

+ DeleteJobFn func(context.Context, string) error

+ DeleteTriggerFn func(context.Context, string) error

+ GetJobFn func(context.Context, string) (automationpkg.Job, error)

+ GetRunFn func(context.Context, string) (automationpkg.Run, error)

+ GetTriggerFn func(context.Context, string) (automationpkg.Trigger, error)

+ HandleWebhookFn func(context.Context, automationpkg.WebhookRequest) (automationpkg.TriggerResult, error)

+ JobsFn func(context.Context) ([]automationpkg.Job, error)

+ ListJobsFn func(context.Context, automationpkg.JobListQuery) ([]automationpkg.Job, error)

+ ListRunsFn func(context.Context, automationpkg.RunQuery) ([]automationpkg.Run, error)

+ ListTriggersFn func(context.Context, automationpkg.TriggerListQuery) ([]automationpkg.Trigger, error)

+ RunsFn func(context.Context, automationpkg.RunQuery) ([]automationpkg.Run, error)

+ SetJobEnabledFn func(context.Context, string, bool) (automationpkg.Job, error)

+ SetTriggerEnabledFn func(context.Context, string, bool) (automationpkg.Trigger, error)

+ StatusFn func(context.Context) (automationpkg.ManagerStatus, error)

+ TriggerJobFn func(context.Context, string) (automationpkg.Run, error)

+ TriggersFn func(context.Context) ([]automationpkg.Trigger, error)

+ UpdateJobFn func(context.Context, automationpkg.Job) (automationpkg.Job, error)

+ UpdateTriggerFn func(context.Context, automationpkg.Trigger, *automationpkg.WebhookSecretWrite) (automationpkg.Trigger, error)

+ func (s StubAutomationManager) CreateJob(ctx context.Context, job automationpkg.Job) (automationpkg.Job, error)

+ func (s StubAutomationManager) CreateTrigger(ctx context.Context, trigger automationpkg.Trigger, ...) (automationpkg.Trigger, error)

+ func (s StubAutomationManager) DeleteJob(ctx context.Context, id string) error

+ func (s StubAutomationManager) DeleteTrigger(ctx context.Context, id string) error

+ func (s StubAutomationManager) GetJob(ctx context.Context, id string) (automationpkg.Job, error)

+ func (s StubAutomationManager) GetRun(ctx context.Context, id string) (automationpkg.Run, error)

+ func (s StubAutomationManager) GetTrigger(ctx context.Context, id string) (automationpkg.Trigger, error)

+ func (s StubAutomationManager) HandleWebhook(ctx context.Context, request automationpkg.WebhookRequest) (automationpkg.TriggerResult, error)

+ func (s StubAutomationManager) Jobs(ctx context.Context) ([]automationpkg.Job, error)

+ func (s StubAutomationManager) ListJobs(ctx context.Context, query automationpkg.JobListQuery) ([]automationpkg.Job, error)

+ func (s StubAutomationManager) ListRuns(ctx context.Context, query automationpkg.RunQuery) ([]automationpkg.Run, error)

+ func (s StubAutomationManager) ListTriggers(ctx context.Context, query automationpkg.TriggerListQuery) ([]automationpkg.Trigger, error)

+ func (s StubAutomationManager) Runs(ctx context.Context, query automationpkg.RunQuery) ([]automationpkg.Run, error)

+ func (s StubAutomationManager) SetJobEnabled(ctx context.Context, id string, enabled bool) (automationpkg.Job, error)

+ func (s StubAutomationManager) SetTriggerEnabled(ctx context.Context, id string, enabled bool) (automationpkg.Trigger, error)

+ func (s StubAutomationManager) Status(ctx context.Context) (automationpkg.ManagerStatus, error)

+ func (s StubAutomationManager) TriggerJob(ctx context.Context, id string) (automationpkg.Run, error)

+ func (s StubAutomationManager) Triggers(ctx context.Context) ([]automationpkg.Trigger, error)

+ func (s StubAutomationManager) UpdateJob(ctx context.Context, job automationpkg.Job) (automationpkg.Job, error)

+ func (s StubAutomationManager) UpdateTrigger(ctx context.Context, trigger automationpkg.Trigger, ...) (automationpkg.Trigger, error)

+ type StubBridgeService struct

+ BuildRoutingKeyFn func(context.Context, bridgepkg.RoutingKey) (bridgepkg.RoutingKey, error)

+ CreateInstanceFn func(context.Context, bridgepkg.CreateInstanceRequest) (*bridgepkg.BridgeInstance, error)

+ DeleteSecretBindingFn func(context.Context, string, string) error

+ DeleteTaskSubscriptionFn func(context.Context, string) error

+ GetCursorFn func(context.Context, notifications.CursorKey) (notifications.Cursor, error)

+ GetInstanceFn func(context.Context, string) (*bridgepkg.BridgeInstance, error)

+ GetTaskSubscriptionFn func(context.Context, string) (bridgepkg.BridgeTaskSubscription, error)

+ ListBridgeTargetsFn func(context.Context, bridgepkg.BridgeTargetQuery) (bridgepkg.BridgeTargetsResult, error)

+ ListInstancesFn func(context.Context) ([]bridgepkg.BridgeInstance, error)

+ ListProvidersFn func(context.Context) ([]bridgepkg.BridgeProvider, error)

+ ListRoutesFn func(context.Context, string) ([]bridgepkg.BridgeRoute, error)

+ ListSecretBindingsFn func(context.Context, string) ([]bridgepkg.BridgeSecretBinding, error)

+ ListTaskSubscriptionsFn func(context.Context, bridgepkg.BridgeTaskSubscriptionQuery) ([]bridgepkg.BridgeTaskSubscription, error)

+ PutSecretBindingFn func(context.Context, bridgepkg.BridgeSecretBinding, *string) error

+ PutTaskSubscriptionFn func(context.Context, bridgepkg.BridgeTaskSubscription) error

+ RefreshBridgeTargetsFn func(context.Context, string, []bridgepkg.BridgeTargetSnapshot) ([]bridgepkg.BridgeTarget, error)

+ ResolveBridgeTargetFn func(context.Context, string, string) (bridgepkg.ResolveBridgeTargetResult, error)

+ ResolveDeliveryTargetFn func(context.Context, bridgepkg.ResolveDeliveryTargetRequest) (*bridgepkg.DeliveryTarget, error)

+ ResolveOrCreateRouteFn func(context.Context, bridgepkg.BridgeRoute) (*bridgepkg.BridgeRoute, bool, error)

+ ResolveRouteFn func(context.Context, bridgepkg.RoutingKey) (*bridgepkg.BridgeRoute, error)

+ RestartInstanceFn func(context.Context, string) (*bridgepkg.BridgeInstance, error)

+ StartInstanceFn func(context.Context, string) (*bridgepkg.BridgeInstance, error)

+ StopInstanceFn func(context.Context, string) (*bridgepkg.BridgeInstance, error)

+ UpdateInstanceFn func(context.Context, bridgepkg.UpdateInstanceRequest) (*bridgepkg.BridgeInstance, error)

+ UpdateInstanceStateFn func(context.Context, bridgepkg.UpdateInstanceStateRequest) (*bridgepkg.BridgeInstance, error)

+ UpsertRouteFn func(context.Context, bridgepkg.BridgeRoute) (*bridgepkg.BridgeRoute, error)

+ func (s StubBridgeService) BuildRoutingKey(ctx context.Context, key bridgepkg.RoutingKey) (bridgepkg.RoutingKey, error)

+ func (s StubBridgeService) CreateInstance(ctx context.Context, req bridgepkg.CreateInstanceRequest) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) DeleteBridgeTaskSubscription(ctx context.Context, subscriptionID string) error

+ func (s StubBridgeService) DeleteSecretBinding(ctx context.Context, bridgeInstanceID string, bindingName string) error

+ func (s StubBridgeService) GetBridgeTaskSubscription(ctx context.Context, subscriptionID string) (bridgepkg.BridgeTaskSubscription, error)

+ func (s StubBridgeService) GetCursor(ctx context.Context, key notifications.CursorKey) (notifications.Cursor, error)

+ func (s StubBridgeService) GetInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) ListBridgeTargets(ctx context.Context, query bridgepkg.BridgeTargetQuery) (bridgepkg.BridgeTargetsResult, error)

+ func (s StubBridgeService) ListBridgeTaskSubscriptions(ctx context.Context, query bridgepkg.BridgeTaskSubscriptionQuery) ([]bridgepkg.BridgeTaskSubscription, error)

+ func (s StubBridgeService) ListInstances(ctx context.Context) ([]bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) ListProviders(ctx context.Context) ([]bridgepkg.BridgeProvider, error)

+ func (s StubBridgeService) ListRoutes(ctx context.Context, bridgeInstanceID string) ([]bridgepkg.BridgeRoute, error)

+ func (s StubBridgeService) ListSecretBindings(ctx context.Context, bridgeInstanceID string) ([]bridgepkg.BridgeSecretBinding, error)

+ func (s StubBridgeService) PutBridgeTaskSubscription(ctx context.Context, subscription bridgepkg.BridgeTaskSubscription) error

+ func (s StubBridgeService) PutSecretBinding(ctx context.Context, binding bridgepkg.BridgeSecretBinding, ...) error

+ func (s StubBridgeService) RefreshBridgeTargets(ctx context.Context, bridgeID string, ...) ([]bridgepkg.BridgeTarget, error)

+ func (s StubBridgeService) ResolveBridgeTarget(ctx context.Context, bridgeID string, query string) (bridgepkg.ResolveBridgeTargetResult, error)

+ func (s StubBridgeService) ResolveDeliveryTarget(ctx context.Context, req bridgepkg.ResolveDeliveryTargetRequest) (*bridgepkg.DeliveryTarget, error)

+ func (s StubBridgeService) ResolveOrCreateRoute(ctx context.Context, route bridgepkg.BridgeRoute) (*bridgepkg.BridgeRoute, bool, error)

+ func (s StubBridgeService) ResolveRoute(ctx context.Context, key bridgepkg.RoutingKey) (*bridgepkg.BridgeRoute, error)

+ func (s StubBridgeService) RestartInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) StartInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) StopInstance(ctx context.Context, id string) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) UpdateInstance(ctx context.Context, req bridgepkg.UpdateInstanceRequest) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) UpdateInstanceState(ctx context.Context, req bridgepkg.UpdateInstanceStateRequest) (*bridgepkg.BridgeInstance, error)

+ func (s StubBridgeService) UpsertRoute(ctx context.Context, route bridgepkg.BridgeRoute) (*bridgepkg.BridgeRoute, error)

+ type StubNetworkService struct

+ InboxFn func(context.Context, string) ([]network.Envelope, error)

+ ListChannelsFn func(context.Context, string) ([]network.ChannelInfo, error)

+ ListPeersFn func(context.Context, string, string) ([]network.PeerInfo, error)

+ SendFn func(context.Context, network.SendRequest) (string, error)

+ StatusFn func(context.Context) (*network.Status, error)

+ WaitInboxFn func(context.Context, string, string) ([]network.Envelope, error)

+ func (s StubNetworkService) Inbox(ctx context.Context, sessionID string) ([]network.Envelope, error)

+ func (s StubNetworkService) ListChannels(ctx context.Context, workspaceID string) ([]network.ChannelInfo, error)

+ func (s StubNetworkService) ListPeers(ctx context.Context, workspaceID string, channel string) ([]network.PeerInfo, error)

+ func (s StubNetworkService) Send(ctx context.Context, req network.SendRequest) (string, error)

+ func (s StubNetworkService) Status(ctx context.Context) (*network.Status, error)

+ func (s StubNetworkService) WaitInbox(ctx context.Context, sessionID string, channel string) ([]network.Envelope, error)

+ type StubNetworkStore struct

+ DeleteNetworkChannelFn func(context.Context, store.NetworkChannelRef) error

+ GetDirectRoomFn func(context.Context, store.NetworkChannelRef, string) (store.NetworkDirectRoomSummary, error)

+ GetNetworkChannelFn func(context.Context, store.NetworkChannelRef) (store.NetworkChannelEntry, error)

+ GetThreadFn func(context.Context, store.NetworkChannelRef, string) (store.NetworkThreadSummary, error)

+ GetWorkFn func(context.Context, string, string) (store.NetworkWorkEntry, error)

+ ListConversationMessagesFn func(context.Context, store.NetworkConversationRef, ...) ([]store.NetworkConversationMessage, error)

+ ListDirectRoomsFn func(context.Context, store.NetworkChannelRef, store.NetworkDirectRoomQuery) ([]store.NetworkDirectRoomSummary, error)

+ ListNetworkAuditFn func(context.Context, store.NetworkAuditQuery) ([]store.NetworkAuditEntry, error)

+ ListNetworkChannelsFn func(context.Context, store.NetworkChannelQuery) ([]store.NetworkChannelEntry, error)

+ ListNetworkMessagesFn func(context.Context, store.NetworkMessageQuery) ([]store.NetworkMessageEntry, error)

+ ListThreadsFn func(context.Context, store.NetworkChannelRef, store.NetworkThreadQuery) ([]store.NetworkThreadSummary, error)

+ ResolveDirectRoomFn func(context.Context, store.NetworkDirectRoomEntry) (store.NetworkDirectRoomSummary, error)

+ WriteConversationMessageFn func(context.Context, store.NetworkConversationMessage) (store.NetworkConversationWriteResult, error)

+ WriteNetworkChannelFn func(context.Context, store.NetworkChannelEntry) error

+ func (s StubNetworkStore) DeleteNetworkChannel(ctx context.Context, ref store.NetworkChannelRef) error

+ func (s StubNetworkStore) GetDirectRoom(ctx context.Context, ref store.NetworkChannelRef, directID string) (store.NetworkDirectRoomSummary, error)

+ func (s StubNetworkStore) GetNetworkChannel(ctx context.Context, ref store.NetworkChannelRef) (store.NetworkChannelEntry, error)

+ func (s StubNetworkStore) GetThread(ctx context.Context, ref store.NetworkChannelRef, threadID string) (store.NetworkThreadSummary, error)

+ func (s StubNetworkStore) GetWork(ctx context.Context, workspaceID string, workID string) (store.NetworkWorkEntry, error)

+ func (s StubNetworkStore) ListConversationMessages(ctx context.Context, ref store.NetworkConversationRef, ...) ([]store.NetworkConversationMessage, error)

+ func (s StubNetworkStore) ListDirectRooms(ctx context.Context, ref store.NetworkChannelRef, ...) ([]store.NetworkDirectRoomSummary, error)

+ func (s StubNetworkStore) ListNetworkAudit(ctx context.Context, query store.NetworkAuditQuery) ([]store.NetworkAuditEntry, error)

+ func (s StubNetworkStore) ListNetworkChannels(ctx context.Context, query store.NetworkChannelQuery) ([]store.NetworkChannelEntry, error)

+ func (s StubNetworkStore) ListNetworkMessages(ctx context.Context, query store.NetworkMessageQuery) ([]store.NetworkMessageEntry, error)

+ func (s StubNetworkStore) ListThreads(ctx context.Context, ref store.NetworkChannelRef, ...) ([]store.NetworkThreadSummary, error)

+ func (s StubNetworkStore) ResolveDirectRoom(ctx context.Context, entry store.NetworkDirectRoomEntry) (store.NetworkDirectRoomSummary, error)

+ func (s StubNetworkStore) WriteConversationMessage(ctx context.Context, entry store.NetworkConversationMessage) (store.NetworkConversationWriteResult, error)

+ func (s StubNetworkStore) WriteNetworkChannel(ctx context.Context, entry store.NetworkChannelEntry) error

+ type StubObserver struct

+ HealthFn func(context.Context) (observe.Health, error)

+ QueryBridgeHealthFn func(context.Context) ([]observe.BridgeInstanceHealth, error)

+ QueryEventsFn func(context.Context, store.EventSummaryQuery) ([]store.EventSummary, error)

+ QueryHookCatalogFn func(context.Context, hookspkg.CatalogFilter) ([]hookspkg.CatalogEntry, error)

+ QueryHookEventsFn func(context.Context, hookspkg.EventFilter) ([]hookspkg.EventDescriptor, error)

+ QueryHookRunsFn func(context.Context, store.HookRunQuery) ([]hookspkg.HookRunRecord, error)

+ QueryTaskDashboardFn func(context.Context, observe.TaskDashboardQuery) (observe.TaskDashboardView, error)

+ QueryTaskInboxFn func(context.Context, observe.TaskInboxQuery, taskpkg.ActorIdentity) (observe.TaskInboxView, error)

+ func (s StubObserver) Health(ctx context.Context) (observe.Health, error)

+ func (s StubObserver) QueryBridgeHealth(ctx context.Context) ([]observe.BridgeInstanceHealth, error)

+ func (s StubObserver) QueryEvents(ctx context.Context, query store.EventSummaryQuery) ([]store.EventSummary, error)

+ func (s StubObserver) QueryHookCatalog(ctx context.Context, filter hookspkg.CatalogFilter) ([]hookspkg.CatalogEntry, error)

+ func (s StubObserver) QueryHookEvents(ctx context.Context, filter hookspkg.EventFilter) ([]hookspkg.EventDescriptor, error)

+ func (s StubObserver) QueryHookRuns(ctx context.Context, query store.HookRunQuery) ([]hookspkg.HookRunRecord, error)

+ func (s StubObserver) QueryTaskDashboard(ctx context.Context, query observe.TaskDashboardQuery) (observe.TaskDashboardView, error)

+ func (s StubObserver) QueryTaskInbox(ctx context.Context, query observe.TaskInboxQuery, actor taskpkg.ActorIdentity) (observe.TaskInboxView, error)

+ type StubResourceService struct

+ DeleteFn func(context.Context, resources.ResourceKind, string, int64) error

+ GetFn func(context.Context, resources.ResourceKind, string) (resources.RawRecord, error)

+ ListFn func(context.Context, resources.ResourceFilter) ([]resources.RawRecord, error)

+ PutFn func(context.Context, resources.RawDraft) (resources.RawRecord, error)

+ func (s StubResourceService) Delete(ctx context.Context, kind resources.ResourceKind, id string, ...) error

+ func (s StubResourceService) Get(ctx context.Context, kind resources.ResourceKind, id string) (resources.RawRecord, error)

+ func (s StubResourceService) List(ctx context.Context, filter resources.ResourceFilter) ([]resources.RawRecord, error)

+ func (s StubResourceService) Put(ctx context.Context, draft resources.RawDraft) (resources.RawRecord, error)

+ type StubSessionManager struct

+ ApproveFn func(context.Context, string, acp.ApproveRequest) error

+ AttachSessionFn func(context.Context, store.SessionAttachRequest) (store.SessionAttach, error)

+ CancelPromptFn func(context.Context, string) error

+ CancelQueuedFn func(context.Context, string, string) (session.SendPromptResult, error)

+ ClearFn func(context.Context, string) (*session.Session, error)

+ CreateFn func(context.Context, session.CreateOpts) (*session.Session, error)

+ DeleteFn func(context.Context, string) error

+ EventsFn func(context.Context, string, store.EventQuery) ([]store.SessionEvent, error)

+ HistoryFn func(context.Context, string, store.EventQuery) ([]store.TurnHistory, error)

+ InputQueueFn func(context.Context, string) (session.InputQueueSummary, error)

+ InterruptFn func(context.Context, string) (session.SendPromptResult, error)

+ ListAllFn func(context.Context) ([]*session.Info, error)

+ ListFn func() []*session.Info

+ ListSessionsFn func(context.Context, store.SessionListQuery) ([]store.SessionInfo, error)

+ PromptFn func(context.Context, string, string) (<-chan acp.AgentEvent, error)

+ RepairFn func(context.Context, session.RepairOpts) (*session.RepairResult, error)

+ ResumeFn func(context.Context, string) (*session.Session, error)

+ SendPromptFn func(context.Context, string, session.SendPromptOpts) (session.SendPromptResult, error)

+ StatusFn func(context.Context, string) (*session.Info, error)

+ SteerFn func(context.Context, string, string) (session.SendPromptResult, error)

+ StopFn func(context.Context, string) error

+ StopWithCauseFn func(context.Context, string, session.StopCause, string) error

+ TranscriptFn func(context.Context, string) ([]transcript.UIMessage, error)

+ func (s StubSessionManager) ApprovePermission(ctx context.Context, id string, req acp.ApproveRequest) error

+ func (s StubSessionManager) AttachSession(ctx context.Context, req store.SessionAttachRequest) (store.SessionAttach, error)

+ func (s StubSessionManager) CancelPrompt(ctx context.Context, id string) error

+ func (s StubSessionManager) CancelQueuedPrompt(ctx context.Context, id string, queueEntryID string) (session.SendPromptResult, error)

+ func (s StubSessionManager) ClearConversation(ctx context.Context, id string) (*session.Session, error)

+ func (s StubSessionManager) Create(ctx context.Context, opts session.CreateOpts) (*session.Session, error)

+ func (s StubSessionManager) Delete(ctx context.Context, id string) error

+ func (s StubSessionManager) Events(ctx context.Context, id string, query store.EventQuery) ([]store.SessionEvent, error)

+ func (s StubSessionManager) History(ctx context.Context, id string, query store.EventQuery) ([]store.TurnHistory, error)

+ func (s StubSessionManager) InputQueueSummary(ctx context.Context, id string) (session.InputQueueSummary, error)

+ func (s StubSessionManager) InterruptPrompt(ctx context.Context, id string) (session.SendPromptResult, error)

+ func (s StubSessionManager) List() []*session.Info

+ func (s StubSessionManager) ListAll(ctx context.Context) ([]*session.Info, error)

+ func (s StubSessionManager) ListSessions(ctx context.Context, query store.SessionListQuery) ([]store.SessionInfo, error)

+ func (s StubSessionManager) Prompt(ctx context.Context, id string, msg string) (<-chan acp.AgentEvent, error)

+ func (s StubSessionManager) RepairSession(ctx context.Context, opts session.RepairOpts) (*session.RepairResult, error)

+ func (s StubSessionManager) Resume(ctx context.Context, id string) (*session.Session, error)

+ func (s StubSessionManager) SendPrompt(ctx context.Context, id string, opts session.SendPromptOpts) (session.SendPromptResult, error)

+ func (s StubSessionManager) Status(ctx context.Context, id string) (*session.Info, error)

+ func (s StubSessionManager) SteerPrompt(ctx context.Context, id string, msg string) (session.SendPromptResult, error)

+ func (s StubSessionManager) Stop(ctx context.Context, id string) error

+ func (s StubSessionManager) StopWithCause(ctx context.Context, id string, cause session.StopCause, detail string) error

+ func (s StubSessionManager) Transcript(ctx context.Context, id string) ([]transcript.UIMessage, error)

+ type StubSkillsRegistry struct

+ ForAgentFn func(ctx context.Context, resolved *workspacepkg.ResolvedWorkspace, ...) ([]*skills.Skill, error)

+ ForWorkspaceFn func(ctx context.Context, resolved *workspacepkg.ResolvedWorkspace) ([]*skills.Skill, error)

+ GetFn func(name string) (*skills.Skill, bool)

+ ListFn func() []*skills.Skill

+ LoadContentFn func(ctx context.Context, skill *skills.Skill) (string, error)

+ LoadResourceFn func(ctx context.Context, skill *skills.Skill, relativePath string) (string, error)

+ RefreshGlobalFn func(ctx context.Context) error

+ SetEnabledFn func(name string, resolved *workspacepkg.ResolvedWorkspace, enabled bool) error

+ SetEnabledForAgentFn func(name string, resolved *workspacepkg.ResolvedWorkspace, agentName string, ...) error

+ func (s StubSkillsRegistry) ForAgent(ctx context.Context, resolved *workspacepkg.ResolvedWorkspace, ...) ([]*skills.Skill, error)

+ func (s StubSkillsRegistry) ForWorkspace(ctx context.Context, resolved *workspacepkg.ResolvedWorkspace) ([]*skills.Skill, error)

+ func (s StubSkillsRegistry) Get(name string) (*skills.Skill, bool)

+ func (s StubSkillsRegistry) List() []*skills.Skill

+ func (s StubSkillsRegistry) LoadContent(ctx context.Context, skill *skills.Skill) (string, error)

+ func (s StubSkillsRegistry) LoadResource(ctx context.Context, skill *skills.Skill, relativePath string) (string, error)

+ func (s StubSkillsRegistry) RefreshGlobal(ctx context.Context) error

+ func (s StubSkillsRegistry) SetEnabled(name string, resolved *workspacepkg.ResolvedWorkspace, enabled bool) error

+ func (s StubSkillsRegistry) SetEnabledForAgent(name string, resolved *workspacepkg.ResolvedWorkspace, agentName string, ...) error

+ type StubTaskManager struct

+ AddDependencyFn func(context.Context, taskpkg.AddDependency, taskpkg.ActorContext) error

+ ApproveTaskFn func(context.Context, string, taskpkg.ExecutionRequest, taskpkg.ActorContext) (*taskpkg.Execution, error)

+ ArchiveTaskFn func(context.Context, string, taskpkg.ActorContext) (taskpkg.TriageState, error)

+ AttachRunSessionFn func(context.Context, string, string, taskpkg.ActorContext) (*taskpkg.Run, error)

+ BindRunReviewSessionFn func(context.Context, taskpkg.BindRunReviewSessionRequest, taskpkg.ActorContext) (taskpkg.RunReviewBinding, error)

+ BulkForceFailRunsFn bulkForceRunFunc

+ BulkForceReleaseRunsFn bulkForceRunFunc

+ CancelRunFn func(context.Context, string, taskpkg.CancelRun, taskpkg.ActorContext) (*taskpkg.Run, error)

+ CancelTaskFn func(context.Context, string, taskpkg.CancelTask, taskpkg.ActorContext) (*taskpkg.Task, error)

+ ClaimNextRunFn func(context.Context, taskpkg.ClaimCriteria, taskpkg.ActorContext) (*taskpkg.ClaimResult, error)

+ ClaimRunFn func(context.Context, string, taskpkg.ClaimRun, taskpkg.ActorContext) (*taskpkg.Run, error)

+ CompleteRunFn func(context.Context, string, taskpkg.RunResult, taskpkg.ActorContext) (*taskpkg.Run, error)

+ CompleteRunLeaseFn func(context.Context, taskpkg.LeaseCompletion, taskpkg.ActorContext) (*taskpkg.Run, error)

+ CreateChildTaskFn func(context.Context, string, taskpkg.CreateTask, taskpkg.ActorContext) (*taskpkg.Task, error)

+ CreateTaskFn func(context.Context, taskpkg.CreateTask, taskpkg.ActorContext) (*taskpkg.Task, error)

+ DeleteExecutionProfileFn func(context.Context, string, taskpkg.ActorContext) error

+ DeleteTaskFn func(context.Context, string, taskpkg.ActorContext) error

+ DismissTaskFn func(context.Context, string, taskpkg.ActorContext) (taskpkg.TriageState, error)

+ DrainSchedulerFn func(context.Context, taskpkg.SchedulerDrainRequest, taskpkg.ActorContext) (taskpkg.SchedulerDrainResult, error)

+ EnqueueRunFn func(context.Context, taskpkg.EnqueueRun, taskpkg.ActorContext) (*taskpkg.Run, error)

+ FailRunFn func(context.Context, string, taskpkg.RunFailure, taskpkg.ActorContext) (*taskpkg.Run, error)

+ FailRunLeaseFn func(context.Context, taskpkg.LeaseFailure, taskpkg.ActorContext) (*taskpkg.Run, error)

+ ForceFailRunFn forceFailRunFunc

+ ForceReleaseRunFn forceReleaseRunFunc

+ GetExecutionProfileFn func(context.Context, string, taskpkg.ActorContext) (taskpkg.ExecutionProfile, error)

+ GetRunReviewFn func(context.Context, string, taskpkg.ActorContext) (taskpkg.RunReview, error)

+ GetTaskFn func(context.Context, string, taskpkg.ActorContext) (*taskpkg.View, error)

+ HeartbeatRunLeaseFn func(context.Context, taskpkg.LeaseHeartbeat, taskpkg.ActorContext) (*taskpkg.Run, error)

+ InspectRunFn func(context.Context, string, taskpkg.ActorContext) (*taskpkg.InspectView, error)

+ InspectTaskFn func(context.Context, string, taskpkg.ActorContext) (*taskpkg.InspectView, error)

+ ListRunReviewsFn func(context.Context, taskpkg.RunReviewQuery, taskpkg.ActorContext) ([]taskpkg.RunReview, error)

+ ListTaskRunsFn func(context.Context, string, taskpkg.RunQuery, taskpkg.ActorContext) ([]taskpkg.Run, error)

+ ListTasksFn func(context.Context, taskpkg.Query, taskpkg.ActorContext) ([]taskpkg.Summary, error)

+ LookupActiveRunForSessionFn func(context.Context, string, string) (taskpkg.AutonomyLeaseHandle, error)

+ LookupRunReviewForSessionFn func(context.Context, string, taskpkg.ActorContext) (taskpkg.RunReviewBinding, error)

+ MarkTaskReadFn func(context.Context, string, taskpkg.ActorContext) (taskpkg.TriageState, error)

+ PauseSchedulerFn func(context.Context, taskpkg.SchedulerPauseRequest, taskpkg.ActorContext) (taskpkg.SchedulerStatus, error)

+ PauseTaskFn pauseTaskFunc

+ PublishTaskFn func(context.Context, string, taskpkg.ExecutionRequest, taskpkg.ActorContext) (*taskpkg.Execution, error)

+ RecordRunReviewFn func(context.Context, taskpkg.RecordRunReviewRequest, taskpkg.ActorContext) (taskpkg.RunReviewResult, error)

+ RecoverExpiredRunLeasesFn func(context.Context, taskpkg.ExpiredLeaseRecovery, taskpkg.ActorContext) ([]taskpkg.ExpiredLeaseRecoveryResult, error)

+ RejectTaskFn func(context.Context, string, taskpkg.ActorContext) (*taskpkg.Task, error)

+ ReleaseRunLeaseFn func(context.Context, taskpkg.LeaseRelease, taskpkg.ActorContext) (*taskpkg.Run, error)

+ RemoveDependencyFn func(context.Context, string, string, taskpkg.ActorContext) error

+ RequestRunReviewFn func(context.Context, taskpkg.RunReviewRequest, taskpkg.ActorContext) (taskpkg.RunReview, bool, error)

+ ResumeSchedulerFn func(context.Context, taskpkg.SchedulerResumeRequest, taskpkg.ActorContext) (taskpkg.SchedulerStatus, error)

+ ResumeTaskFn resumeTaskFunc

+ RetryRunFn retryRunFunc

+ RunDetailFn func(context.Context, string, taskpkg.ActorContext) (*taskpkg.RunDetailView, error)

+ SchedulerBacklogFn func(context.Context, taskpkg.SchedulerBacklogQuery, taskpkg.ActorContext) (taskpkg.SchedulerBacklog, error)

+ SchedulerStatusFn func(context.Context, taskpkg.ActorContext) (taskpkg.SchedulerStatus, error)

+ SetExecutionProfileFn func(context.Context, string, *taskpkg.ExecutionProfile, taskpkg.ActorContext) (taskpkg.ExecutionProfile, error)

+ StartRunFn func(context.Context, string, taskpkg.StartRun, taskpkg.ActorContext) (*taskpkg.Run, error)

+ StartTaskFn func(context.Context, string, taskpkg.ExecutionRequest, taskpkg.ActorContext) (*taskpkg.Execution, error)

+ StreamFn func(context.Context, string, taskpkg.StreamQuery, taskpkg.ActorContext) (<-chan taskpkg.StreamEvent, error)

+ TimelineFn func(context.Context, string, taskpkg.TimelineQuery, taskpkg.ActorContext) ([]taskpkg.TimelineItem, error)

+ TreeFn func(context.Context, string, taskpkg.ActorContext) (*taskpkg.TreeView, error)

+ UpdateTaskFn func(context.Context, string, taskpkg.Patch, taskpkg.ActorContext) (*taskpkg.Task, error)

+ func (s StubTaskManager) AddDependency(ctx context.Context, spec taskpkg.AddDependency, actor taskpkg.ActorContext) error

+ func (s StubTaskManager) ApproveTask(ctx context.Context, id string, req taskpkg.ExecutionRequest, ...) (*taskpkg.Execution, error)

+ func (s StubTaskManager) ArchiveTask(ctx context.Context, id string, actor taskpkg.ActorContext) (taskpkg.TriageState, error)

+ func (s StubTaskManager) AttachRunSession(ctx context.Context, runID string, sessionID string, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) BindRunReviewSession(ctx context.Context, req taskpkg.BindRunReviewSessionRequest, ...) (taskpkg.RunReviewBinding, error)

+ func (s StubTaskManager) BulkForceFailRuns(ctx context.Context, req taskpkg.BulkForceRunRequest, ...) (taskpkg.BulkForceRunResult, error)

+ func (s StubTaskManager) BulkForceReleaseRuns(ctx context.Context, req taskpkg.BulkForceRunRequest, ...) (taskpkg.BulkForceRunResult, error)

+ func (s StubTaskManager) CancelRun(ctx context.Context, runID string, req taskpkg.CancelRun, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) CancelTask(ctx context.Context, id string, req taskpkg.CancelTask, ...) (*taskpkg.Task, error)

+ func (s StubTaskManager) ClaimNextRun(ctx context.Context, criteria taskpkg.ClaimCriteria, ...) (*taskpkg.ClaimResult, error)

+ func (s StubTaskManager) ClaimRun(ctx context.Context, runID string, claim taskpkg.ClaimRun, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) CompleteRun(ctx context.Context, runID string, result taskpkg.RunResult, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) CompleteRunLease(ctx context.Context, completion taskpkg.LeaseCompletion, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) CreateChildTask(ctx context.Context, parentTaskID string, spec taskpkg.CreateTask, ...) (*taskpkg.Task, error)

+ func (s StubTaskManager) CreateTask(ctx context.Context, spec taskpkg.CreateTask, actor taskpkg.ActorContext) (*taskpkg.Task, error)

+ func (s StubTaskManager) DeleteExecutionProfile(ctx context.Context, taskID string, actor taskpkg.ActorContext) error

+ func (s StubTaskManager) DeleteTask(ctx context.Context, id string, actor taskpkg.ActorContext) error

+ func (s StubTaskManager) DismissTask(ctx context.Context, id string, actor taskpkg.ActorContext) (taskpkg.TriageState, error)

+ func (s StubTaskManager) DrainScheduler(ctx context.Context, req taskpkg.SchedulerDrainRequest, ...) (taskpkg.SchedulerDrainResult, error)

+ func (s StubTaskManager) EnqueueRun(ctx context.Context, spec taskpkg.EnqueueRun, actor taskpkg.ActorContext) (*taskpkg.Run, error)

+ func (s StubTaskManager) FailRun(ctx context.Context, runID string, failure taskpkg.RunFailure, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) FailRunLease(ctx context.Context, failure taskpkg.LeaseFailure, actor taskpkg.ActorContext) (*taskpkg.Run, error)

+ func (s StubTaskManager) ForceFailRun(ctx context.Context, runID string, failure taskpkg.ForceFailRun, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) ForceReleaseRun(ctx context.Context, runID string, release taskpkg.ForceReleaseRun, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) GetExecutionProfile(ctx context.Context, taskID string, actor taskpkg.ActorContext) (taskpkg.ExecutionProfile, error)

+ func (s StubTaskManager) GetRunReview(ctx context.Context, reviewID string, actor taskpkg.ActorContext) (taskpkg.RunReview, error)

+ func (s StubTaskManager) GetTask(ctx context.Context, id string, actor taskpkg.ActorContext) (*taskpkg.View, error)

+ func (s StubTaskManager) HeartbeatRunLease(ctx context.Context, heartbeat taskpkg.LeaseHeartbeat, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) InspectRun(ctx context.Context, runID string, actor taskpkg.ActorContext) (*taskpkg.InspectView, error)

+ func (s StubTaskManager) InspectTask(ctx context.Context, taskID string, actor taskpkg.ActorContext) (*taskpkg.InspectView, error)

+ func (s StubTaskManager) ListRunReviews(ctx context.Context, query taskpkg.RunReviewQuery, actor taskpkg.ActorContext) ([]taskpkg.RunReview, error)

+ func (s StubTaskManager) ListTaskRuns(ctx context.Context, taskID string, query taskpkg.RunQuery, ...) ([]taskpkg.Run, error)

+ func (s StubTaskManager) ListTasks(ctx context.Context, query taskpkg.Query, actor taskpkg.ActorContext) ([]taskpkg.Summary, error)

+ func (s StubTaskManager) LookupActiveRunForSession(ctx context.Context, sessionID string, runID string) (taskpkg.AutonomyLeaseHandle, error)

+ func (s StubTaskManager) LookupRunReviewForSession(ctx context.Context, sessionID string, actor taskpkg.ActorContext) (taskpkg.RunReviewBinding, error)

+ func (s StubTaskManager) MarkTaskRead(ctx context.Context, id string, actor taskpkg.ActorContext) (taskpkg.TriageState, error)

+ func (s StubTaskManager) PauseScheduler(ctx context.Context, req taskpkg.SchedulerPauseRequest, ...) (taskpkg.SchedulerStatus, error)

+ func (s StubTaskManager) PauseTask(ctx context.Context, taskID string, req taskpkg.PauseTaskRequest, ...) (*taskpkg.Task, error)

+ func (s StubTaskManager) PublishTask(ctx context.Context, id string, req taskpkg.ExecutionRequest, ...) (*taskpkg.Execution, error)

+ func (s StubTaskManager) RecordRunReview(ctx context.Context, req taskpkg.RecordRunReviewRequest, ...) (taskpkg.RunReviewResult, error)

+ func (s StubTaskManager) RecoverExpiredRunLeases(ctx context.Context, recovery taskpkg.ExpiredLeaseRecovery, ...) ([]taskpkg.ExpiredLeaseRecoveryResult, error)

+ func (s StubTaskManager) RejectTask(ctx context.Context, id string, actor taskpkg.ActorContext) (*taskpkg.Task, error)

+ func (s StubTaskManager) ReleaseRunLease(ctx context.Context, release taskpkg.LeaseRelease, actor taskpkg.ActorContext) (*taskpkg.Run, error)

+ func (s StubTaskManager) RemoveDependency(ctx context.Context, taskID string, dependsOnID string, ...) error

+ func (s StubTaskManager) RequestRunReview(ctx context.Context, req taskpkg.RunReviewRequest, actor taskpkg.ActorContext) (taskpkg.RunReview, bool, error)

+ func (s StubTaskManager) ResumeScheduler(ctx context.Context, req taskpkg.SchedulerResumeRequest, ...) (taskpkg.SchedulerStatus, error)

+ func (s StubTaskManager) ResumeTask(ctx context.Context, taskID string, req taskpkg.ResumeTaskRequest, ...) (*taskpkg.Task, error)

+ func (s StubTaskManager) RetryRun(ctx context.Context, runID string, retry taskpkg.RetryRunRequest, ...) (*taskpkg.RetryRunResult, error)

+ func (s StubTaskManager) RunDetail(ctx context.Context, runID string, actor taskpkg.ActorContext) (*taskpkg.RunDetailView, error)

+ func (s StubTaskManager) SchedulerBacklog(ctx context.Context, query taskpkg.SchedulerBacklogQuery, ...) (taskpkg.SchedulerBacklog, error)

+ func (s StubTaskManager) SchedulerStatus(ctx context.Context, actor taskpkg.ActorContext) (taskpkg.SchedulerStatus, error)

+ func (s StubTaskManager) SetExecutionProfile(ctx context.Context, taskID string, profile *taskpkg.ExecutionProfile, ...) (taskpkg.ExecutionProfile, error)

+ func (s StubTaskManager) StartRun(ctx context.Context, runID string, req taskpkg.StartRun, ...) (*taskpkg.Run, error)

+ func (s StubTaskManager) StartTask(ctx context.Context, id string, req taskpkg.ExecutionRequest, ...) (*taskpkg.Execution, error)

+ func (s StubTaskManager) Stream(ctx context.Context, taskID string, query taskpkg.StreamQuery, ...) (<-chan taskpkg.StreamEvent, error)

+ func (s StubTaskManager) Timeline(ctx context.Context, taskID string, query taskpkg.TimelineQuery, ...) ([]taskpkg.TimelineItem, error)

+ func (s StubTaskManager) Tree(ctx context.Context, taskID string, actor taskpkg.ActorContext) (*taskpkg.TreeView, error)

+ func (s StubTaskManager) UpdateTask(ctx context.Context, id string, patch taskpkg.Patch, ...) (*taskpkg.Task, error)

+ type StubWorkspaceService struct

+ GetFn func(context.Context, string) (workspacepkg.Workspace, error)

+ ListFn func(context.Context) ([]workspacepkg.Workspace, error)

+ RegisterFn func(context.Context, workspacepkg.RegisterOptions) (workspacepkg.Workspace, error)

+ ResolveFn func(context.Context, string) (workspacepkg.ResolvedWorkspace, error)

+ ResolveOrRegisterFn func(context.Context, string) (workspacepkg.ResolvedWorkspace, error)

+ UnregisterFn func(context.Context, string) error

+ UpdateFn func(context.Context, string, workspacepkg.UpdateOptions) error

+ func (s StubWorkspaceService) Get(ctx context.Context, ref string) (workspacepkg.Workspace, error)

+ func (s StubWorkspaceService) List(ctx context.Context) ([]workspacepkg.Workspace, error)

+ func (s StubWorkspaceService) Register(ctx context.Context, opts workspacepkg.RegisterOptions) (workspacepkg.Workspace, error)

+ func (s StubWorkspaceService) Resolve(ctx context.Context, ref string) (workspacepkg.ResolvedWorkspace, error)

+ func (s StubWorkspaceService) ResolveOrRegister(ctx context.Context, path string) (workspacepkg.ResolvedWorkspace, error)

+ func (s StubWorkspaceService) Unregister(ctx context.Context, id string) error

+ func (s StubWorkspaceService) Update(ctx context.Context, id string, opts workspacepkg.UpdateOptions) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL