newHandle is the internal constructor.

newPipeline is the tiny helper that wires the trace appender and hook. Each test supplies its own stage list.

newTestVAD creates an EnergyVAD with spectral disabled and tiny sample counts suitable for unit testing of segmentation logic.

promoteAgentTools is the agent-level policy gate hand-off. When agent.Agent.Tools is set and the caller's Dependencies container does NOT already defi

publishGraphEvent fires-and-forgets a run-level envelope. Headers carry the well-known IDs that callers may need for predicate filtering when subject

queueDepth peeks into the in-memory queue by claiming and then silently dropping the claimed jobs. Tests that need to assert "no enqueue happened" use

resolve converts a workspace-relative path into an object key with prefix.

transitionPhaseLocked records the new phase and emits the bus envelope. Callers MUST hold c.mu. Two side-effects bake the captain-level restart count

--------------------------------------------------------------------------- Channel / event helpers --------------------------------------------------

Assemble constructs the context window from summaries + recent messages.

Assemble constructs the context window from summaries + recent messages.

Build constructs every Captain declared in the plan, in plan order. Each Captain gets its own event.Bus so log subscribers can scope by vessel; the da

Canonical implements port.AliasResolver. Resolution falls back through progressively-broader scopes: full -> drop AgentID -> drop UserID -> runtime-on

Close stops Run and the underlying notifier. In the normal (non-nil target & notifier) configuration Close blocks until Run has actually returned, so

Close stops Run and the underlying notifier. In the normal (non-nil target & notifier) configuration Close blocks until Run has actually returned, so

CompileCondition compiles a raw expression string into a reusable program.

EntryMatchesScope reports whether e satisfies the persistence and partition filters in query. Nil query matches all entries (used by legacy/uncoped pa

FeedbackBoost returns the score multiplier derived from fact feedback fields for fusion / rank. The boost math stays here because fusion and rank are

ForgetRequired runs required forgets synchronously. First failure short-circuits with an error. Callers must hold the canonical fact snapshot if they

FuncTool wraps a plain function as a Tool.

History implements Journal.

Lineage returns the full revision DAG rooted at factID — the set of facts reachable via Supersedes / CorrectedBy / Revision.SourceFactID edges, classi

New returns an empty profile projection.

New constructs an Index rooted directly in a local workspace. BBH accepts the Workspace interface so callers can share the same constructor shape as

New creates a Kanban instance.

New constructs an Index rooted directly in a local workspace. BBH accepts the Workspace interface so callers can share the same constructor shape as

NewBoard creates a scope-scoped board with a persistent event Bus.

NewFileCheckpointStore creates a file-based checkpoint store.

NewInspector opens an offline, read-only inspector rooted at a BBH workspace. It opens Badger with a read-only lock, so it cannot inspect a workspace

NewMockHost returns a ready-to-use MockHost. The interrupt channel is buffered so [MockHost.Interrupt] never blocks the test goroutine when the engine

Open returns (or creates) the in-memory workspace for runID. The runID is treated as an opaque key — no path validation is applied because no filesyst

PayloadMap safely converts a Card.Payload to map[string]any. After Done(), Payload is map[string]any (direct assertion). Before Done() (Pending/Claime

ProjectOptional runs optional projections best-effort. Failures only emit telemetry; the call always returns nil.

Provider returns the OTel / metrics tag used by this instance. Mostly a debugging aid; exported so eval drivers and observability dashboards can intro

RunAudioStream processes streaming audio input. Requires a non-nil STT provider.

Sanitize maps an arbitrary user/runtime/dataset token into the retrieval namespace alphabet accepted by all in-tree backends.

Sanitize maps an arbitrary user/runtime/dataset token into the retrieval namespace alphabet accepted by all in-tree backends.

SaveAsync enqueues extraction on the configured JobQueue and returns immediately.

SetFallback installs a builder that handles every node type for which no explicit builder is registered. Pass nil to clear.

String returns the canonical name of the Consistency level.

WithHost installs the engine.Host the executor will hand to nodes via ExecutionContext.Host. When omitted the executor falls back to engine.NoopHost{}

WithProviderName overrides the OTel / metrics provider tag used by this LLM instance. Wrapping adapters (sdkx/llm/azure, deepseek, qwen, ...) call thi

agentIDFor resolves the agent.id the executor stamps onto every published envelope (HeaderAgentID) and uses as the prefix of the step subject segment

--------------------------------------------------------------------------- Generic helpers — keep validation loops short and consistent. ------------

categoryLabel returns the stable short token attached to per-category metrics and log records ("rate_limit" / "auth" / "billing" / "context_overflow"

cloneDoc deep-copies the parts a Search hit should not share with the index's internal storage (slices and maps).

docsFor builds a small canned corpus shared across read tests.