Unlock releases the per-key lock for key. Calling Unlock without a matching prior Lock panics (mirrors sync.Mutex). Safe to call Unlock(K1) and Unlock

Lock blocks until the caller holds the per-key lock for key. Two Lock(K) calls with the same key serialise; Lock(K1) and Lock(K2) for distinct keys ne

Add inserts one pre-built Entry verbatim and returns the assigned entry ID. Two ingest modes: - e.ID == "" (content-addressable): the ID is derived

Contains reports whether word is in the set. The check is case-insensitive — callers can pass raw surface forms.

Contains checks if a path contains a substring — intended for tests.

Content returns the concatenated text of all text parts.

Close shuts down the bus. After Close returns, every subscription channel will be closed and subsequent Publish / Subscribe calls return ErrBusClosed.

Unlock releases the per-key lock for key. Calling Unlock without a matching prior Lock panics (mirrors sync.Mutex). Safe to call Unlock(K1) and Unlock

Load returns messages suited for the next LLM call. Implementations MAY compress, summarize, or window the underlying transcript. budget is a hint; i

Close releases backend resources.

Lock blocks until the caller holds the per-key lock for key. Two Lock(K) calls with the same key serialise; Lock(K1) and Lock(K2) for distinct keys ne

Save extracts facts from msgs and writes them synchronously.

New constructs a v2 Memory. The defaults wire a fully in-memory stack so callers can exercise the write path without external dependencies; production

IsZero reports whether no time bounds were supplied.

Wait blocks until the run reaches a terminal state, then returns the agent.Result and any error returned by agent.Run. Wait honours ctx cancellation:

Close releases signaling resources (HTTP connections, etc.).

asMap is the unchecked downcast we apply when State is structured (Sierra's initial_state.json is rigorously typed; this helper exists only to keep ca

Done returns the underlying done channel for callers that want to integrate Handle completion into a larger select{}. The channel is closed when the r

Done transitions a claimed card to done status with a result payload. Publishes EventTaskCompleted to Bus() for task-typed cards.

Set stores a dependency under the given key. Overwrites any existing value for the same key.

IsZero reports whether the spec carries no caps, no defaults, and no limits. Used by the resolver to skip the wrap step entirely.

Do is the low-level escape hatch when a test needs full control of headers / status / streaming. It dials the daemon's unix socket, sets the default a

Decode decodes a single compressed packet into PCM16LE samples.

Close stops async workers and the TTL sweeper; safe to call more than once.

PartitionKey is the canonical store / projection / async-queue partition ("rt-1/u:alice" / "rt-1/global"). AgentID is intentionally excluded — per doc

List returns scope-local facts matching the query, ordered by ObservedAt ascending.

Register adds a tool to the registry with the default scope (ScopeAgent).

Shutdown stops accepting new work and waits for in-flight per- conversation queues to drain. After Shutdown is observed, Append/Compact/Archive return

Name is used for logs / metrics and to distinguish multiple projections registered against the same Memory.

Project conveys "these entries currently exist (alive, not tombstoned/expired) in the primary index, under scope". Semantics are ADDITIVE: the projec

WithTemporalStore installs the canonical TemporalFact store. The default is an in-memory store suitable for tests and local development. Production d

Append attaches refs to factID within scope. Implementations must be idempotent on (scope, factID, refs[i].ID).

---------- Vars ---------- SetVar sets a board-level variable. Concurrent-safe.

Produce creates a new Card in Pending status and notifies matching watchers.

--- tiny schema helpers --- These return JSON-Schema fragments. They live here (not sierra_common.go) so each tool's registration call stays readable

Send injects a text message into the session, skipping STT. If the session is currently responding or playing, it triggers a barge-in. Returns false i

DefaultDAGConfig returns a DAGConfig with sensible defaults.

DefaultDAGConfig returns a DAGConfig with sensible defaults.

Header returns the header value or "" when absent.

String returns the raw prefix name.

Close performs a multi-phase shutdown: 1. Take the write lock, mark closed, snapshot subscribers, release lock. New Publish / Subscribe calls now fai

Delete removes facts by ID within a scope. Missing IDs are ignored so callers can issue idempotent forgets.

Stop is the impatient counterpart to Drain. It transitions to PhaseStopping, cancels the Captain's root context (which propagates ctx cancellation to

Sierra τ-bench tool ports — common helpers Sierra's Python tools (sierra-research/tau-bench, commit 59a200c6, dated 2026-03-18) all follow the same w

Recall runs the configured retrieval pipeline against the scope-derived namespace.

Send writes a value into the pipe. Returns false if the pipe has been interrupted (context cancelled). Blocks if the buffer is full.

Len returns the number of cards.

MustWrite panics on error — intended for tests.

Open returns the per-run workspace for runID. Implementations must return the same instance for the same runID within their process lifetime; this is

String returns the raw prefix name.

emit is the core logging function. It creates an OTel LogRecord, injects trace_id/span_id from ctx when available, and emits it through the global Log

Launch transitions the Captain from PhasePending into PhaseRunning, subscribes every Sidecar agent to the bus, and starts the probe loop (when Probes

NewInMemoryStore creates a new in-memory message store with optional limits.

NewInMemoryStore creates a new in-memory message store with optional limits.

GetVar retrieves a board-level variable.

Supports reports whether the model supports the given capability.

URL returns the base URL the LLMProfile config should use as `base_url` (a.k.a. `baseURL` in YAML).