New creates a ByteDance LLM instance.

New builds an adapter pointing at the DashScope Qwen-Image endpoint. An empty model defaults to "qwen-image-2.0-pro"; an empty baseURL defaults to htt

Notify implements [Notifier]. It is safe to call concurrently — each call serialises through a mutex because all events feed the same shared card body

QueryCards queries cards on the board by filter.

RunText processes text input directly, skipping STT. Produces the same Event stream as RunAudio/RunAudioStream.

Source returns the AudioSource that reads from the remote audio track.

Stop calls Stop on every Captain concurrently. Used after Drain returns or after the drain timeout fires.

WithAgentExecutor sets the executor for running tasks on target agents.

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

WithConfig sets the Kanban configuration.

completedEngine appends a single assistant reply and returns nil. Used as the "happy path" engine across run tests.

fakeLLMEngineFactory mirrors cmd/vesseld/catalog/engine_graph_llm.go in shape: it loops calling client.Generate, executes any tool calls via deps.Tool

ProjectRequired runs required projections synchronously. The first failure short-circuits and is returned wrapped with the failing projection's name.

---------- Subject helpers ---------- SanitiseID escapes characters that would corrupt an event.Subject when the input is concatenated into one. event

ToolResults extracts all tool-result parts.

Validate returns nil when the spec is internally consistent and satisfies the constraints v0.1.0 of the vessel runtime enforces. Errors are classified

WithRetrievalIndex overrides the retrieval backend that powers the retrieval projection. The default is memory/retrieval/memory.New(). Memory.Close c

classify returns a score indicating speech likelihood. In spectral mode it returns a combined [0, 1] score from RMS, ZCR, sub-band energy and pitch; i

fixedClock returns a deterministic time so segment timestamps across test runs are reproducible. Concurrent callers (e.g. background compactor + main

--------------------------------------------------------------------------- Constructors — wrap an existing error with a category marker. Each catego

metadataString coerces a metadata value to string; missing -> "".

metadataString coerces a metadata value to string; missing -> "".

objectSchema is a tiny convenience for writing JSON-Schema fragments inline. The "additionalProperties: false" keeps the schema strict so a forgetful

parsePart dispatches on "type" to a per-type validator. Unknown types are explicitly rejected — silently dropping them would let a script attach data

This file isolates the model.* → map[string]any projections that the LLM bridge serves up to scripts. Keeping projection separate from round logic and

resolveValueRef turns a v1alpha1.ValueRef into the plain-text value it points at. opts.AllowFile / opts.AllowSecret control which sources are honoured

sanitiseID escapes characters that would corrupt a Subject. See sdk/graph/executor/subjects.go for the rationale; the implementation is intentionally

ApplyOptions folds option funcs into a GenerateOptions value.

Calls snapshots the recorded call slice. The returned slice is safe to mutate; the underlying buffer is copied.

Emit pushes one streaming event. Type is a short tag like "token", "tool_call", "tool_result", "delta". Payload SHOULD be a map[string]any so downstre

LookupModel returns the full catalog ModelInfo for a registered (provider, model) pair, plus an `ok` flag. Used by the resolver to surface non-spec me

New always returns errdefs.NotAvailable on non-Linux platforms. nsjail uses Linux-specific namespace and cgroup primitives that have no counterpart on

New builds an adapter pointing at MiniMax's image-generation endpoint. An empty model defaults to "image-01"; an empty baseURL defaults to https://api

New returns an empty graph projection with optional tuning.

NewEnvelope constructs an Envelope with ID and Time populated. Behaviour: - if subject is empty, returns ErrInvalidSubject (Subject.Validate is calle

NewFanout constructs a Fanout. Projections are partitioned by their declared Consistency so the fanout itself stays oblivious to individual projection

NewLLMBridge exposes LLM calls to scripts as the global "llm": llm.run({ messages }) // blocking, returns full result map l

OnTerminate registers a hook that runs synchronously when the underlying run reaches a terminal state, BEFORE Wait returns and BEFORE Done is closed.

RegisterModels associates a list of models with a provider.

RunWithFallback executes an operation against multiple providers with retry, circuit-breaker, and fallback support. Parameters: - n: number of provid

SetHeader sets a header value, allocating Headers lazily.

Submit is a convenience wrapper around POST /v1/vessels/{id}/submit that returns the run_id for a successful 202 response, or fails the test on any no

TemporalStore returns the canonical fact ledger adapter.

WithDetectorThreshold sets the speech-onset threshold. In classifier mode this is a score in [0,1]; otherwise it is an RMS value. Default: 0.008 (RMS)

WithSpectral enables or disables spectral analysis (ZCR, sub-band energy, pitch detection). When disabled, falls back to pure RMS energy detection. En

Pure math tests for the IR metrics. We deliberately use closed-form inputs so a regression in the formula (wrong log base, wrong gain function, off-by

authn enforces the Authorization: Bearer <token> contract for TCP requests. Unix socket requests are detected via RemoteAddr containing "@" / unix pre

cacheLen is a test-only helper that reaches into MemoryBus's route cache. Living in the same package keeps it private to the test binary.

drain reads up to n envelopes from ch within timeout.