Interface AgentThreadBoundTopology

Agent topology plus target-side proof for standing memory state.

interface AgentThreadBoundTopology {
    requireBoundThread: BoundThreadTargetValidator;
    observe(
        context: ActorContext,
        input: AgentThreadObserveInput,
    ): Promise<Response>;
    resume(
        context: ActorContext,
        record: ApprovalRecord,
        decision: ApprovalDecision,
    ): Promise<AgentRunEnvelope>;
    start(
        context: ActorContext,
        input: AgentThreadStartInput,
    ): Promise<AgentRunEnvelope>;
    status(
        context: ActorContext,
        input: AgentThreadRunRef,
    ): Promise<AgentRunEnvelope | undefined>;
    terminate?(
        context: ActorContext,
        input: AgentThreadRunRef,
        replayOnly?: boolean,
    ): Promise<AgentRunEnvelope>;
}

Hierarchy (View Summary)

AgentThreadTopology
- AgentThreadBoundTopology
  - AgentThreadDispatchTopology

Index

Properties

requireBoundThread

Methods

observe resume start status terminate?

Properties

requireBoundThread

requireBoundThread: BoundThreadTargetValidator

Methods

observe

observe(
context: ActorContext,
input: AgentThreadObserveInput,
): Promise<Response>
Parameters
- context: ActorContext
- input: AgentThreadObserveInput
Returns Promise<Response>
Inherited from AgentThreadTopology.observe
- Defined in packages/flowsafe/src/agent-host/thread-topology.ts:235

resume

resume(
    context: ActorContext,
    record: ApprovalRecord,
    decision: ApprovalDecision,
): Promise<AgentRunEnvelope>
Resumes a decided agent approval's run through its thread object. An implementation sends expectedSuspensionFor(record) with the resume, so a decision for an earlier suspension of the step is refused; without it the resume is unchecked. A run that has ended rejects with a 409 whose reason.code is RUN_NOT_SUSPENDED when the context's principal started it, and with a 404 RunRouteError otherwise.
Parameters
- context: ActorContext
- record: ApprovalRecord
- decision: ApprovalDecision
Returns Promise<AgentRunEnvelope>
Inherited from AgentThreadTopology.resume
- Defined in packages/flowsafe/src/agent-host/thread-topology.ts:252

start

start(
context: ActorContext,
input: AgentThreadStartInput,
): Promise<AgentRunEnvelope>
Parameters
- context: ActorContext
- input: AgentThreadStartInput
Returns Promise<AgentRunEnvelope>
Inherited from AgentThreadTopology.start
- Defined in packages/flowsafe/src/agent-host/thread-topology.ts:227

status

status(
context: ActorContext,
input: AgentThreadRunRef,
): Promise<AgentRunEnvelope | undefined>
Parameters
- context: ActorContext
- input: AgentThreadRunRef
Returns Promise<AgentRunEnvelope | undefined>
Inherited from AgentThreadTopology.status
- Defined in packages/flowsafe/src/agent-host/thread-topology.ts:231

`Optional`terminate

terminate?(
    context: ActorContext,
    input: AgentThreadRunRef,
    replayOnly?: boolean,
): Promise<AgentRunEnvelope>
Parameters
- context: ActorContext
- input: AgentThreadRunRef
- OptionalreplayOnly: boolean
Returns Promise<AgentRunEnvelope>
Inherited from AgentThreadTopology.terminate
- Defined in packages/flowsafe/src/agent-host/thread-topology.ts:239