emit appends to trace and pushes to the telemetry hook in that order. Both targets are optional; missing ones are silently skipped. Emission order mat

RuntimeBinding is normally wired by scriptnode, not user code, so these tests assemble the same shape manually: parent env -> "runtime" binding -> chi

execBuiltin builds a ScriptNode from the named built-in script and runs it once with a recording publisher attached so callers can assert on host.emit

layerPath is the per-document layer text path. LayerAbstract -> <base>.abstract LayerOverview -> <base>.overview LayerDetail -> "" (detail text

layerPath is the per-document layer text path. LayerAbstract -> <base>.abstract LayerOverview -> <base>.overview LayerDetail -> "" (detail text

---------- helpers ----------

makeFlushedSegments produces n flushed segments, each containing one doc whose ID is "doc-<segIdx>". A small per-segment MemtableMaxDocs threshold cou

matchesAny reports whether path matches any of the given patterns. Supported pattern forms: - "dir/**" — matches dir itself and everything unde

messageToMap projects one model.Message. Role plus parts is the canonical shape; we also expose `content` (= Message.Content()) as a convenience for s

newMockServer returns a httptest server that decodes the inbound request, hands it to handler for inspection, and writes back the supplied raw respons

publishLifecycle is the lifecycle-event analogue of engine.EmitStreamDelta — the engine package only ships emit helpers for stream-delta envelopes, so

resolveTools returns the tool registry and effective allow-list for one round, applying contract-audit Epic A's policy: 1. Registry: graph.ExecutionC

sanitizeToolPairs removes orphaned tool_result messages that can appear after truncation. Anthropic (and compatible APIs) require every tool_result to

sanitizeToolPairs removes orphaned tool_result messages that can appear after truncation. Anthropic (and compatible APIs) require every tool_result to

scopeID returns a per-call unique scope identifier rooted at the test name. Use this in any test that creates a Board so failures stay attributable.

stepActorFor builds the engine.SubjectStep* "stepActor" segment for a graph runner step. The contract documented at sdk/engine/subjects.go demands the

submitWithCron registers a dynamic cron job and persists it as a cron_rule card. The caller's ctx (producer ID + trace span) is preserved on the Event

toWorkspacePath validates the LLM-emitted path and returns the equivalent workspace-relative path. The "memories" segment is preserved so the tool sta

transitionToFailed is the bridge the probe loop uses to surface a fatal verdict. It runs without holding c.mu — the probe loop must remain non-blockin

withDatasets returns a copy of q whose resolvedDatasets is set; used by Service.Search to push the resolved fan-out list down to retrievers without mu

withDatasets returns a copy of q whose resolvedDatasets is set; used by Service.Search to push the resolved fan-out list down to retrievers without mu

writeJSON is the small helper used by both handlers. We avoid importing the daemon's own writeJSON here to keep this helper dependency-free (only stdl

Accept handles the server-side flow: receives a remote SDP offer (typically from an HTTP handler), creates an answer, and returns it. The caller is re

Add returns a new TokenUsage that is the sum of u and other. Numeric fields (token counts, latency, cost) are summed. Model is preserved from u when

AsyncSemanticQueue returns the async semantic durable queue adapter.

BuildLineage walks the supersede chain and revision DAG outward from root and returns every reachable fact exactly once. The traversal follows four ed

C returns the signal channel consumed by the owner loop.

C returns the signal channel consumed by the owner loop.

Clone creates an independent deep copy of this Resolver. All nested maps and slices are recursively copied so that parallel branches cannot mutate eac

DefaultDefaults returns the package's conservative local defaults.

EffectiveFederation returns the deduped recall scope list: primary first, then each Federation entry (sub-scope Federation ignored).

EffectivePartitions returns Partitions if non-empty, else the auto- derived single-partition slice based on IsGlobal.

Enable re-enables convenience log functions.

Evaluate runs the compiled condition against the given Board variables.

--------------------------------------------------------------------------- Context error normalisation ----------------------------------------------

GenerateDatasetContext derives dataset-level L0 + L1 from per-document abstracts. The L1 overview is generated first, then distilled into L0. Returns

GenerateDatasetContext derives dataset-level L0 + L1 from per-document abstracts. The L1 overview is generated first, then distilled into L0. Returns

Has reports whether the given key is present.

Hold starts (or nests) a buffered telemetry scope.

ID is unique within the originating bus instance.

IsProjectable reports whether a fact belongs in projection indexes (profile / relation / graph / retrieval / entity / timeline). It is canonical-activ

IsRetired reports whether a fact is hidden from default Recall: soft-closed or past ExpiresAt.

MergeFilters returns a Filter that requires all non-empty inputs to match.

Names returns the vessel names in plan order. Stable ordering matters for `vesseld plan` and the /v1/vessels listing.

New creates an S3-backed ObjectStore.

NewExporter constructs an Exporter from cfg. Path is required; defaults are applied for any zero-valued size/retention field. The underlying file is o

NewFromConfig creates an Embedder via the registered factory. Returns an error if the provider is not registered.

NewLocalWorkspace creates a workspace rooted at the given directory. The root path is resolved through EvalSymlinks to prevent the root itself from be

NewMemoryJournal returns an empty MemoryJournal.

NewRunner creates an embeddable ops runner. It never starts goroutines; call Run explicitly when the surrounding process is ready to own the lifecycle

OnStage implements port.TelemetryHook.

Open returns (or creates) the on-disk workspace for runID. The runID is validated by [ValidateRunID] before being used as a path component.

Query runs a text search restricted to the scope's namespace and applies the AgentID soft-isolation filter. When the caller's scope has a non-empty Ag

RecordSave folds a Save diagnostic into the aggregate.

Reset schedules a signal after the quiet period. It returns false after Stop.

Reset schedules a signal after the quiet period. It returns false after Stop.

Resolve translates a list of apispec Objects (typically the loader's output) into a Plan. When the configuration has any validation, reference, or fac