fire submits a scheduled task card, skipping if a previous card is still active. It propagates a fresh scheduler-rooted trace span so submitted tasks

flushedIdx builds an index, ingests the canned corpus, and flushes so the read path exercises segment reads (not memtable).

llmEnv assembles a script.Env that exposes only the "llm" global, backed by the supplied resolver / registry. Mirrors the minimal wiring a host would

makeSineWave generates a PCM16 sine wave at the given frequency and amplitude (0-32767), useful for testing spectral features.

AgentID returns the producer's agent identifier. It prefers HeaderAgentID (the post-v0.4 canonical key) and falls back to the legacy HeaderActorID so

Bus returns the persistent event Bus bound to the board.

Cancel removes a previously enqueued job by RequestID. It backs the write_semantic_outbox Compensator when a downstream stage (structured facts) fails

ComputePromptCacheKey returns a deterministic 16-hex-char routing hint derived from stable request inputs.

Detect checks whether the frame constitutes a barge-in candidate. It accumulates consecutive loud frames and returns SpeechCandidate with the buffered

Execute runs a single tool call through the registered middleware chain (outermost first) and the core dispatch (lookup + timeout + telemetry). All er

Extend inserts each word into the set. Empty strings are skipped. Returns the receiver so calls can chain.

Feed receives a token and may return a complete sentence.

IsValid reports whether k is one of the canonical FactKinds.

Link adds memEntryIDs to the entities' linked_ids lists. New entities are created with an initial list; existing entities have their lists merged (ded

LookupModelSpec returns the catalog ModelSpec for a registered model, or a zero-value ModelSpec if the model is not found.

Name returns a stable identifier used by Rankers (e.g. "bm25").

New returns an empty in-memory queue ready for Enqueue / Claim.

NewAsyncSemanticProcessor returns a processor when mem is a recall Memory wired with WithAsyncSemanticQueue. The bool is false when the queue is not c

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

Put creates or overwrites an object.

ScopeID returns the board owner scope identifier.

Set is called once per flag occurrence by the flag package.

Stop cancels every loop and waits for shutdown. It returns the first worker error observed before cancellation, if any.

Sub returns a Workspace view rooted under prefix. All operations are forwarded to the parent workspace after prefixing the caller's path. For local w

Submit dispatches an agent.Request through the named vessel's Captain after passing the daemon-wide concurrency gate and injecting the per-profile rat

WatchFiltered returns a channel that receives newly produced cards matching the filter. The channel is closed when ctx is cancelled. The internal queu

WithBackpressure overrides the default DropNewest policy.

WithBreakerThreshold sets consecutive failures before the breaker opens.

WithBufferSize sets the buffered channel capacity. Values <= 0 fall back to the default (64).

WithConfig supplies the full BBH configuration and skips workspace config discovery. Zero-valued fields still receive BBH defaults.

WithHTTPClient overrides the default *http.Client (120s timeout). Useful for tests and for plugging in OTel/transport middleware.

buildAnswerBody renders the "ASKED_AT? + Q + MEMORIES" block fed into the QA prompt. Top-k memories are listed as bullets in RecallHit ranking order.

deliver is the producer-side helper. It publishes the result, runs every registered OnTerminate hook synchronously (in registration order), and only T

fakeTool is a minimal tool.Tool that records nothing — its only purpose is to populate the registry so we can prove the engine either filters or fails

invoke is a tiny convenience that materialises the bridge's API map and returns it ready for assertions. The bridge name "host" is also returned so te

parseMessage validates and converts one script-side message map.

parseRunOptions decodes the script-supplied call object into internal call options. messages is mandatory and must be supplied explicitly for each llm

Subject helpers — task domain.

writeIntent records the in-progress archive operation atomically. RecoverArchive depends on the intent being either fully present or fully absent — pa

writeIntent records the in-progress archive operation atomically. RecoverArchive depends on the intent being either fully present or fully absent — pa

writeJSON is the success-path counterpart to writeError. status is usually 200; callers wanting 201 / 202 pass that explicitly.

ApplyLoadOptions filters msgs in memory according to opts. It is the reference implementation reused by both the in-memory fallback in [LoadFiltered]

ApplyLoadOptions filters msgs in memory according to opts. It is the reference implementation reused by both the in-memory fallback in [LoadFiltered]

Archive moves old messages to gzip-compressed archive files. The [Coordinator] drives it through its per-conversation worker queue; LLM tools (history

Archive moves old messages to gzip-compressed archive files. The [Coordinator] drives it through its per-conversation worker queue; LLM tools (history

Archive runs message archiving for one conversation. Serialized against concurrent Append/Compact on the same conversationID.

BeforeFinalize fires after engine.Execute returns. The Decider inspects res (read-only) and the original req, and returns a FinalizeDecision that Run

Captain returns the captain entry for the named vessel or errdefs.NotFound. Returned pointer is owned by the fleet — callers must not call Stop on it

Clear removes the conversation and any derived state (summaries, archives) owned by this History implementation.

Detect analyzes a frame during interruptable states (responding/playback). It maintains internal state (counters, buffers) across consecutive calls. R

Envelopes returns a copy of every envelope received so far.

HasTimeSignal reports whether the query asks for or contains a time signal.

IsZero reports whether b carries no explicit limits.

Launch starts every Captain. Returns the first non-nil Launch error after attempting all of them — partial launches are kept running so debugging the

New returns an empty relation projection.

NewChat creates the historical OpenAI Chat Completions adapter.

NewMemoryStore returns an empty in-memory TemporalFactStore.

NewResolver returns the default resolver wired with the system clock.

RegisterWithScope adds a tool to the registry with the specified scope.