Publish routes env to every matching subscription according to each subscription's BackpressurePolicy.

Close shuts the underlying httptest.Server down. Always pair with `defer m.Close()` to avoid leaking listeners across tests.

New constructs a Captain from spec. It validates the spec, applies options, builds the per-agent runtime view (engine, seeder, observers), but does NO

Phase reports the current lifecycle phase. Safe to call concurrently with Launch / Submit / Stop.

Call is the synchronous sugar over Submit + Handle.Wait. It blocks until the run reaches a terminal state and returns the agent.Result + error pair ag

Encode encodes a PCM16LE buffer into compressed audio. The pcm slice contains interleaved samples at the encoder's configured sample rate and channel

ExtractJSON extracts the first complete JSON value (object/array/scalar) from text. It tolerates surrounding prose and markdown fenced code blocks, pr

Name identifies the source. Must match the constants used by the planner so per-source budgets line up.

C returns the envelope channel. The channel is closed exactly once, either when Close is invoked or when the parent bus is closed.

NewLocalExecutor creates a new LocalExecutor.

Append durably persists newMessages — and only newMessages — to the conversation. It MUST be safe to call from multiple goroutines for the same conver

Query emits candidates for the supplied plan. Implementations should respect plan.SourceBudgets[s.Name()] for fanout cap. A non-nil error on the Sourc

asyncTestScope is the shared canonical scope used by the async memory facade tests. Tests rely on a stable scope so the in-memory queue's FIFO is obse

newBoard returns a Board whose Close is registered with t.Cleanup, so tests never leak the board lifecycle goroutine.

Name identifies the probe in observability and probe-result reporting. Should be stable across restarts (e.g. "llm-reachable", "tool-reachable").

NewLLMExtractor wires an llm.LLM with the default system prompt.

Extract implements Extractor. Path: 1. Caller-supplied Input.Facts pass through unchanged (clone). 2. If Input.Turns is non-empty, render to JSONL an

GetVarString retrieves a board variable as a string. It returns "" when the key is missing or the stored value is not a string.

--- Document lifecycle ---------------------------------------------------- PutDocument writes raw content under (datasetID, name). Behaviour: - Sour

WithAsyncSemanticQueue installs the durable outbox backend that Save(WriteModeAsyncSemantic) writes to inside the scope write lock. When this option

Context returns the board lifecycle context. It is cancelled on Close.

NewRegistry creates a new tool registry.

WithEngine wires a single, pre-constructed engine that every agent shares. Convenience for vessels whose agents all run the same graph; callers needin

asFloat returns the underlying numeric value for a JSON-decoded `any`. encoding/json decodes JSON numbers as float64; some fixtures hand-write int lit

ContainsPhrase reports whether a folded token sequence occurs contiguously.

NewSummaryDAG creates a new SummaryDAG.

NewSummaryDAG creates a new SummaryDAG.

DisabledCaps creates a ModelCaps with the given capabilities disabled.

Subscribe creates a subscription. pattern is validated; ctx cancellation triggers Close.

ToolCalls extracts all tool-call parts.

Error formats the cause and detail into a human-readable message.

Execute runs the graph from entry (or startNode) to END.

ContainsAnyLiteral reports whether any raw literal occurs in the normalised lower-cased text.

Error implements the error interface. The string contains the Reason so logs that swallow ShortCircuit through a generic err.Error() call still carry

Get returns a clone so callers cannot mutate stored facts.

NewMemoryBus constructs an in-process Bus.

String formats the accumulated values for `--help` output.

buildGraph creates an executable Graph from raw components for testing.

Build constructs a single node from its declarative definition. The engine's two reserved types (__end__ and passthrough) are handled directly so call

Interrupt signals abnormal end of stream. Read returns context.Canceled immediately, even if buffered values remain. Idempotent.

NewProviderRegistry returns an empty registry.

New creates a ScriptNode with the given script and configuration.

Handler returns the http.Handler so tests can drive routes via httptest.NewRecorder without spinning up a real listener.

Len reports the number of entries in the set.

NewFileStore creates a FileStore rooted at the given prefix directory within the workspace (e.g. "memory").