ScoreText computes BM25 for arbitrary text content.

SetAgentID stamps the agent identifier (sdk/agent.Agent.ID) of the producer onto the envelope. The call is dual-write: it sets both HeaderAgentID (th

SetRunID is a typed shorthand for SetHeader(HeaderRunID, id).

SpanContext returns the OTel SpanContext encoded in this envelope's TraceID / SpanID fields, or an invalid SpanContext if the envelope was produced ou

WithBinary overrides the nsjail binary path. By default the Runner uses exec.LookPath("nsjail"); set this for hermetic builds where nsjail lives in a

WithBreakerCooldown sets the duration before a tripped breaker enters half-open state.

WithDetectorInterruptThreshold sets the barge-in threshold (before boost). Default: 0.015 (RMS) or 0.55 (classifier).

WithTelemetryHook installs a telemetry observer for projection fanout, drift detection, and high-level Save/Recall pipeline stages.

genPair returns a freshly minted self-signed cert + private key (PEM-encoded) suitable for both server and CA roles in unit tests. The cert is valid f

listDocsNamespace dumps every retrieval.Doc currently held in the dataset's __docs namespace; used to assert doc-level write behaviour independently o

listDocsNamespace dumps every retrieval.Doc currently held in the dataset's __docs namespace; used to assert doc-level write behaviour independently o

makeRecord builds a Record without the default length/count limits that logtest.RecordFactory's zero value would otherwise apply (which truncate strin

Integration tests require real credentials. Set: EMBEDDING_PROVIDER (e.g. "azure" or "openai") EMBEDDING_API_KEY EMBEDDING_MODEL (e.g. "text-

pickFinalish returns Final if non-empty, otherwise lifts Fused/Reranked. When lifting from Reranked or Fused the slice is shallow-copied so that down

pickFinalish returns Final if non-empty, otherwise lifts Fused/Reranked. When lifting from Reranked or Fused the slice is shallow-copied so that down

publicSaveTrace copies the in-flight domain.SaveTrace (when explain was requested) into the public SaveTrace surface.

segmentDirs returns the names of segment directories on disk.

sortedKeys is the small helper used by every error message and Names() call so error output is stable across runs.

AttachRevision stores a revision annotation on f.Metadata. It does not mutate unrelated keys.

Build resolves every reference through provider and assembles a [crypto/tls.Config] suitable for an mTLS HTTP listener. The returned config has Client

===== SummaryIndex (was compactor_index.go) ===== BuildSummaryIndex generates a summary index string from the top-level summaries of a conversation. T

===== SummaryIndex (was compactor_index.go) ===== BuildSummaryIndex generates a summary index string from the top-level summaries of a conversation. T

EmitStreamDelta is the low-level form of the EmitStreamX helpers. Custom nodes that need to set fields outside the type-specific helpers (e.g. a forwa

ExecuteAll runs multiple tool calls concurrently with a semaphore limiting parallelism. Results are returned in the same order as the input calls.

Finish assembles the round result. It is mandatory to call Finish (or Close) before the round goes out of scope, otherwise the underlying stream may l

InitLog initializes the OpenTelemetry LoggerProvider. Sinks are exactly the WithLogProcessor entries supplied by the caller; pass them in any order,

Len returns the number of stored conversations (useful for testing/monitoring).

Len returns the number of stored conversations (useful for testing/monitoring).

ListByFact returns refs in append order.

New returns an empty entity projection.

NewBuffer returns a [History] that keeps the most recent messages for each conversation up to a cap (default 50; override with [WithBufferMax]). It i

NewBuffer returns a [History] that keeps the most recent messages for each conversation up to a cap (default 50; override with [WithBufferMax]). It i

NewEventReloader wires a Rebuilder to an EventNotifier. opts.Debounce defaults to 500ms; opts.RebuildTimeout defaults to 30s. RetryBackoff defaults t

NewEventReloader wires a Rebuilder to an EventNotifier. opts.Debounce defaults to 500ms; opts.RebuildTimeout defaults to 30s. RetryBackoff defaults t

NewPlainTextExporter returns an sdklog.Exporter that formats each record via FormatPlainTextRecordLine and writes it to w. All severities are written

NewReconciler returns the multi-scope operator API when mem is this package's Memory implementation.

NewSegmenter creates a new Segmenter.

NewSemanticSilenceDecider creates a decider that reduces the silence threshold when the partial transcript appears sentence-complete. silenceDuration

NodeID returns the value of the well-known node_id header.

OnRunStart fires after Run prepared the engine inputs but before engine.Execute is invoked. info carries the immutable identification fields agreed fo

Phase fetches GET /v1/vessels/{id}/phase and returns the parsed phase string. Test-friendly wrapper.

Property creates a simple typed property definition.

RecordRunSummary emits a short-lived "engine.run.summary" span summarising one engine.Run. The span is started and ended synchronously inside this cal

Register associates scheme with backend p. Re-registering the same scheme overwrites the previous backend; this is the seam through which tests inject

ResolveMap resolves all string values in a config map. Non-string values are passed through unchanged. When a string value is exactly a single ${scop

Run blocks until ctx is cancelled or Close is called. Run MUST be called at most once. When target or notifier is nil, Run returns immediately as a no

Run blocks until ctx is cancelled or Close is called. Run MUST be called at most once. When target or notifier is nil, Run returns immediately as a no

WaitRun polls GET /v1/runs/{run_id} until the run reaches a terminal state (status != "running") or the budget elapses. The returned map is the raw de

WithEngineFactory installs a custom factory that the Captain invokes once per agent at New time. This is the primary extension point for vessels that

WithLLMExtractor enables LLM-driven fact extraction in the default compiler pipeline. The supplied client is consulted on Save calls whose SaveRequest

WithRunID sets the run identifier the executor uses in telemetry and event subjects.

WithSpeechOnset sets how many consecutive loud frames are required to confirm speech onset (default 3). Prevents short transient noise from triggering

WithVADThreshold sets a fixed speech-score threshold, bypassing adaptive calibration. In spectral mode the score is in [0, 1] (try 0.45); in energy-on

buildFlags translates sandbox.ExecOptions into the nsjail CLI flag list that precedes the "--" separator. The command and its arguments are appended b

delta returns after.values[name] - before.values[name], with the "missing" sentinel mapped to zero so a "no data point ever emitted" case is observabl

drainEvents collects every envelope emitted on sub until either matchCount envelopes satisfy match (returning early), or the deadline elapses. match

dumpEvents renders a compact "[type@seq run_id]" summary for fatal messages. Keeps test failures debuggable without forcing JSON.

nsSetup orchestrates "open or create" of one namespace: it loads the manifest (or starts fresh), garbage-collects abandoned partial flushes, replays o

fakeNsjail writes a tiny shell script that mimics nsjail's argv contract: everything up to "--" is its own flags, everything after is "cmd args...". T

fenceCheck is the inline guard at the top of every public mutating / reading API. Returns ErrFenced if the namespace has observed a takeover; the call

------------------------------------------------------------------- Post-processing helpers ----------------------------------------------------------

installMemTracer replaces the global TracerProvider with one that pipes every span through `exp` synchronously (WithSyncer). The returned cleanup rest