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

Submit produces a task card on the board and executes via AgentExecutor. All tasks are asynchronous; results are delivered via callback.

fillConfig substitutes the mock OpenAI base URL into the template; the daemon helper does the __SOCKET__ substitution itself because it picks the temp

New creates a Node. toolReg is optional: pass nil when the surrounding engine.Run is expected to supply the registry via [engine.Dependencies] under

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

add is the package-internal append. Nil errors are ignored so helpers can call e.add(maybeErr) unconditionally.

--------------------------------------------------------------------------- Helpers ------------------------------------------------------------------

AppendChannelMessage appends a message to a channel, creating the channel on demand.

Get retrieves the object content. Returns ErrKeyNotFound if absent.

HasToolCalls reports whether the message contains any tool calls.

Lookup implements EntityStore.

NewFileSummaryStore creates a FileSummaryStore rooted at the given prefix.

NewFileSummaryStore creates a FileSummaryStore rooted at the given prefix.

Register adds a provider factory. Overwrites any previous registration.

Frame helpers for testing.

newService spins up a Service backed by the retrieval backend (RetrievalChunkRepo/LayerRepo on sdk/retrieval/memory; documents in FSDocumentRepo on a

newService spins up a Service backed by the retrieval backend (RetrievalChunkRepo/LayerRepo on sdk/retrieval/memory; documents in FSDocumentRepo on a

Append validates and stores facts atomically. Each fact must carry a non-empty ID and a valid FactKind. Duplicate IDs are rejected against both alread

NamespaceFor maps a scope to its v2 retrieval namespace. Mirrors the v1 scheme (per-user when UserID is set, runtime-global otherwise) so the namespac

NewFallbackLLM creates a fallback-aware LLM from a primary and fallbacks.

NewTextMessage creates a simple text message.

Publish delivers env to every matching subscription. Implementations must: - fill env.ID and env.Time when zero; - return ErrBusClosed once Close has

Sources collects non-nil sources in registration order.

long produces a deterministic filler string just over the cache threshold. Using a fixed character so each test's "long" segment is easy to spot in fa

NewResolver creates a new Resolver.

Register binds the script-backed node builders ("script", every built-in declared by the scriptnode builtin catalog, plus a fallback that resolves typ

CanonicalKey returns a stable scope qualifier for federation dedup and sub-scope identity. It extends PartitionKey with /a:{agent} when AgentID is set

Error implements the error interface. The output lists every problem on its own line with a leading " - " bullet so logs and CLI output read cleanly.

Forget hard-deletes one entry; journal (when configured) captures the reason.

Run starts the session loop. It blocks until ctx is cancelled or the audio source is exhausted. For text-only sessions (source == nil), Run blocks unt

Stop closes the Kanban admission path and waits for in-flight executors. The wait is bounded by the stop timeout (DefaultStopTimeout = 10s, or the val

makeMsg is a tiny constructor that keeps the table-driven tests below readable by collapsing the verbose Parts boilerplate.

makeMsg is a tiny constructor that keeps the table-driven tests below readable by collapsing the verbose Parts boilerplate.

newKanban returns a Kanban + Board pair, both auto-stopped on test cleanup.

AddScope registers a named scope with its values.

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

Done is closed after Close has canceled the context and all accepted work has returned.

New creates a new JS runtime with a VM pool.

NewWorkspace creates a workspace.Workspace backed by an ObjectStore.

Required marks the given property names as required in the JSON Schema. Duplicate names are silently ignored.

Submit dispatches one [agent.Run] asynchronously. The returned Handle is the caller's receipt — call Handle.Wait to retrieve the result, or use [Logs]

WithPoolSize sets the VM pool size.

jsonString is the Go analogue of Python's json.dumps. Tools return this on the success path so the Hits string mirrors what Sierra emits at the equiva

--------------------------------------------------------------------------- Helpers ------------------------------------------------------------------

--------------------------------------------------------------------------- Test-only resolver constructor -------------------------------------------

AddDocument updates corpus statistics for a new document's tokens.

Len returns how many problems are recorded.

New returns the default rule-based planner with built-in lens specs (tests and callers that do not use lens.Registry).

NewEnergyDetector creates an EnergyDetector with the given options.

Remove deletes a dependency. Missing keys are a no-op.

String returns a stable label for diagnostics.

Subscribe creates a new subscription matching pattern. The returned Subscription is closed automatically when ctx is cancelled. pattern is validated a

Text returns the last assistant text message in Result.Messages, or "" if none. Convenience for chat-style callers; multi-modal callers should walk Me

WithCaps wraps inner so that GenerateOptions fields the model does not support are dropped or downgraded, and Messages containing unsupported modality

--------------------------------------------------------------------------- Helpers — schedulers are typically wired through Kanban.New(WithScheduler)

ContainsAny reports whether any token occurs as a folded token.

Lookup returns the union of linked memory IDs for the given query entities under scope. Order is deterministic — entities are normalized + sorted, the

NamespaceFor returns the retrieval namespace for a scope: ltm_<runtime>__u<len>_<user> when UserID != "" ltm_<runtime>__global otherwise

New creates a new Lua runtime with a VM pool.