Functions — github.com/awakenworks/awaken

hub / github.com/awakenworks/awaken / functions

Functions15,944 in github.com/awakenworks/awaken

⨍ Functions 15,944◇ Types & classes 2,546

↓ 37 callersMethodprepare_run_for_dispatch

Create or update the durable run truth before enqueuing a dispatch. The caller assigns `dispatch_id_hint` before this method persists the checkpoint.

crates/awaken-server/src/mailbox/submit.rs:419

↓ 37 callersMethodsnapshot

(&self)

crates/awaken-ext-mcp/src/manager.rs:2646

↓ 37 callersMethodsubmit_background

( self: &Arc<Self>, mut request: RunActivation, )

crates/awaken-server/src/mailbox/submit.rs:264

↓ 37 callersMethodwith_resource_id

(mut self, resource_id: impl Into<String>)

crates/awaken-runtime-contract/src/thread.rs:111

↓ 37 callersMethodwrite

(&self, run: &EvalRun)

crates/awaken-eval/src/eval_run.rs:504

↓ 36 callersMethodexecute_stream

( &self, request: InferenceRequest, )

crates/awaken-runtime/src/engine/retry.rs:287

↓ 36 callersFunctionfetchJson

(url: string, init?: RequestInit)

apps/admin-console/src/lib/api/http.ts:58

↓ 36 callersMethodlist

( &self, namespace: ConfigNamespace, offset: usize, limit: usize, )

crates/awaken-server/src/services/config_service.rs:375

↓ 36 callersFunctionpost_ag_ui_run

(app: axum::Router, payload: Value)

crates/awaken-server/tests/protocol_ag_ui_e2e.rs:235

↓ 36 callersFunctionsample_run

(id: &str, dataset: &str, started: u64)

crates/awaken-eval/src/eval_run_test.rs:36

↓ 36 callersMethodset_store

Provide the state store for metadata persistence. Called once during plugin registration or run start. Subsequent calls are silently ignored (OnceLoc

crates/awaken-runtime/src/extensions/background/manager.rs:146

↓ 36 callersMethodsubmit_command

( &self, env: &ExecutionEnv, command: StateCommand, )

crates/awaken-runtime/src/phase/engine.rs:49

↓ 36 callersMethodtake

(&self)

crates/awaken-runtime/src/loop_runner/tests.rs:747

↓ 36 callersMethodvalidate_for_persist

Validate persisted dispatch lifecycle invariants.

crates/awaken-server-contract/src/contract/mailbox.rs:678

↓ 35 callersFunctiondefault_ctx

()

crates/awaken-ext-skills/tests/tool_state_tests.rs:69

↓ 35 callersFunctiondiffPatchableAgentFields

(current: AgentSpec, original: AgentSpec)

apps/admin-console/src/lib/agent-editor-helpers.ts:159

↓ 35 callersMethodforce_flush

Block until the flusher has drained all pending entries for the given thread.

crates/awaken-stores/src/nats_buffered_thread/mod.rs:583

↓ 35 callersMethodlen

(&self)

crates/awaken-server/src/services/pinned_registry.rs:198

↓ 35 callersFunctionmake_store

(fixture: &NatsFixture)

crates/awaken-stores/tests/nats_mailbox_conformance.rs:10

↓ 35 callersMethodprocess

Process a genai stream event. Returns what to emit to the event sink.

crates/awaken-runtime/src/engine/streaming.rs:106

↓ 35 callersMethodpush_json

Allocate a sequence ID, format the JSON as an SSE frame (`data: {json}\n\n`), store it, notify subscribers, and return `(seq, frame)`. ADR-0034 D3: f

crates/awaken-server/src/transport/replay_buffer.rs:40

↓ 35 callersFunctionreport

(id: &str, passed: bool, failures: Vec<Failure>)

crates/awaken-eval/src/report_test.rs:5

↓ 35 callersMethodvalidate

Reject configurations that would hang every request: a `Semaphore::new(0)` makes `acquire_owned()` block forever, so the first eval task posted to the

crates/awaken-server/src/eval_limits.rs:58

↓ 34 callersMethodappend

( &self, _run_id: &str, _event: &awaken_ext_observability::MetricsEvent, )

crates/awaken-server/src/app_test.rs:76

↓ 34 callersMethodappend_replay

( &self, draft: ProtocolReplayDraft, )

crates/awaken-stores/src/postgres_protocol_replay.rs:119

↓ 34 callersMethodclaim

( &self, thread_id: &str, consumer_id: &str, lease_ms: u64, now: u64,

crates/awaken-stores/src/nats_mailbox/mod.rs:380

↓ 34 callersFunctionexecute_streaming

Execute LLM inference with streaming, emitting delta events via sink. Consumes the token stream from `execute_stream()`, forwards deltas to sink, and

crates/awaken-runtime/src/loop_runner/inference.rs:77

↓ 34 callersFunctionextract_sse_events

(body: &str)

crates/awaken-server/tests/protocol_ag_ui_e2e.rs:254

↓ 34 callersMethodget

( &self, id: &str, version: u64, )

crates/awaken-server-contract/src/contract/versioned_registry/mod.rs:615

↓ 34 callersMethodlen

(&self)

crates/awaken-ext-observability/src/composite.rs:24

↓ 34 callersMethodregister_run

Register an active run. Returns error if thread already has one. Uses atomic try-insert to avoid TOCTOU race between check and insert. When a mailbox

crates/awaken-runtime/src/runtime/agent_runtime/mod.rs:461

↓ 34 callersMethodregister_spec

crates/awaken-runtime/src/registry/memory.rs:309

↓ 33 callersMethodadvance

(&mut self, n: usize)

crates/awaken-tool-pattern/src/parser.rs:59

↓ 33 callersFunctionbase_stats

()

crates/awaken-runtime/src/policies/tests.rs:107

↓ 33 callersMethoddispatch_epoch

(&self)

crates/awaken-server-contract/src/contract/mailbox.rs:344

↓ 33 callersFunctionget

(app: axum::Router, uri: &str)

crates/awaken-server/src/protocols/ai_sdk_v6/replay.rs:257

↓ 33 callersFunctionparse

(response: Response)

examples/openui-chat/src/lib/ag-ui-adapter.ts:43

↓ 33 callersFunctionpatch_overrides

Seed a builtin agent with `system_prompt` for override tests. Uses the already-seeded "bootstrap" agent from `make_app`.

crates/awaken-server/tests/config_api.rs:3489

↓ 33 callersFunctionrecord_mailbox_operation_result

(operation: &str, result: &str, start: Instant)

crates/awaken-server/src/mailbox/helpers.rs:270

↓ 33 callersMethodrun

(&self, ctx: &PhaseContext)

crates/awaken-ext-observability/src/plugin/hooks.rs:124

↓ 33 callersFunctionspawn_http_server

( handler: Arc<dyn Fn(HttpRequestSpec) -> HttpResponseSpec + Send + Sync>, )

crates/awaken-ext-mcp/tests/mcp_tests.rs:577

↓ 33 callersMethodwith_base_revision

(mut self, revision: u64)

crates/awaken-runtime-contract/src/state/command.rs:30

↓ 32 callersMethodcreate_run_channels

( &self, run_id: String, )

crates/awaken-runtime/src/runtime/agent_runtime/mod.rs:419

↓ 32 callersMethodenqueue

(&self, dispatch: &RunDispatch)

crates/awaken-stores/src/sqlite_mailbox/mod.rs:366

↓ 32 callersFunctionfetch

(app: axum::Router, uri: &str)

crates/awaken-server/tests/agent_runtime_stats.rs:159

↓ 32 callersFunctionmake_dispatch

(id: &str, thread_id: &str)

crates/awaken-stores/src/sqlite_mailbox/tests.rs:3

↓ 32 callersFunctionmake_request

()

crates/awaken-runtime/src/loop_runner/inference.rs:739

↓ 32 callersMethodmerge_parallel

Merge two batches from parallel execution using registered merge strategies.

crates/awaken-runtime/src/state/store.rs:79

↓ 32 callersFunctiononChange

()

apps/admin-console/src/lib/use-theme.ts:46

↓ 32 callersFunctionseed_thread

Helper: create a thread in the store and return its ID.

crates/awaken-server/tests/http_api.rs:543

↓ 32 callersFunctionunique_config

(fixture: &NatsFixture)

crates/awaken-stores/tests/nats_buffered_thread_fixture.rs:29

↓ 32 callersMethodwith_dedupe_key

(mut self, dedupe_key: impl Into<Option<String>>)

crates/awaken-server-contract/src/contract/mailbox.rs:226

↓ 31 callersFunctioncompile_output

Compile a JSON Render SpecStream JSONL string or a complete spec object string.

crates/awaken-ext-generative-ui/src/json_render.rs:53

↓ 31 callersMethodemit

(&self, event: AgentEvent)

crates/awaken-server-contract/src/contract/durable_event_sink.rs:437

↓ 31 callersMethodfinish

Finalize the collector into a `StreamResult`.

crates/awaken-runtime/src/engine/streaming.rs:240

↓ 31 callersMethodfrom

(e: McpTransportError)

crates/awaken-ext-mcp/src/error.rs:48

↓ 31 callersFunctionget

(app: &axum::Router, uri: &str, token: Option<&str>)

crates/awaken-server/tests/trace_routes.rs:164

↓ 31 callersMethodis_empty

Returns `true` when the channel buffer is empty.

crates/awaken-runtime/src/inbox.rs:89

↓ 31 callersMethodnext

(&mut self)

crates/awaken-server/tests/config_api.rs:389

↓ 31 callersMethodon_run_end

(&self, metrics: &AgentMetrics)

crates/awaken-ext-observability/src/sink.rs:107

↓ 31 callersMethodpublish_resource

( &self, scope_id: &str, kind: &str, id: &str, value: Value, v

crates/awaken-stores/src/file_versioned_registry.rs:137

↓ 31 callersMethodrun

( &self, ctx: &PhaseContext, )

crates/awaken-runtime/src/runtime/agent_runtime/runner/tests.rs:1484

↓ 31 callersMethodwith_provider

(self, provider: impl Into<String>)

crates/awaken-ext-observability/src/plugin/plugin.rs:69

↓ 31 callersMethodwith_run_identity

(mut self, identity: RunIdentity)

crates/awaken-runtime/src/hooks/context.rs:132

↓ 30 callersMethodack

(self: Box<Self>)

crates/awaken-stores/src/memory_mailbox.rs:47

↓ 30 callersFunctionbuild_state

( config_store: Arc<dyn ConfigStore>, )

crates/awaken-server/src/services/config_service/tests.rs:242

↓ 30 callersMethodload_dispatch

(&self, dispatch_id: &str)

crates/awaken-stores/src/memory_mailbox.rs:639

↓ 30 callersFunctionload_run

( store: &NatsBufferedThreadStore<T>, run_id: &str, )

crates/awaken-stores/src/nats_buffered_thread/reader.rs:176

↓ 30 callersMethodmerge

Merge `other` into `self` with last-wins semantics per field.

crates/awaken-runtime-contract/src/contract/inference.rs:213

↓ 30 callersFunctionmock_executor

()

crates/awaken-runtime/src/registry/resolver.rs:360

↓ 30 callersFunctionpool_all

( home_key: &str, behaviors: Vec<Behavior>, switch: PoolSwitchPolicy, breaker: Arc<CircuitBrea

crates/awaken-runtime/src/engine/pool_executor_test_support.rs:231

↓ 30 callersMethodscoped_id

(&self, id: &str)

crates/awaken-server/src/app/modules.rs:92

↓ 30 callersFunctionuiMessage

Build a `UIMessage` from an array of parts. Caller decides the shape so * each test case mirrors an AI SDK stream snapshot without relying on a *

apps/admin-console/src/components/agent-preview-panel.test.tsx:62

↓ 29 callersMethodappend

( thread_id: impl Into<String>, message_delta: Vec<Message>, expected_message_count: O

crates/awaken-runtime-contract/src/contract/commit_coordinator.rs:148

↓ 29 callersFunctionapply_builtin_seed

Apply a seed to the given ConfigStore. Behavior per spec in `seed.specs`: - No existing record → create new Builtin record. (created) - Existing Buil

crates/awaken-server/src/services/builtin_seed/mod.rs:100

↓ 29 callersFunctioncurrent_millis

Wall-clock time in milliseconds since the UNIX epoch. Panics if the system clock is set before 1970 — a severely misconfigured system that cannot be

crates/awaken-stores/src/lib.rs:31

↓ 29 callersMethodlen

(self)

crates/awaken-runtime-contract/src/contract/storage.rs:102

↓ 29 callersFunctionload_messages

( store: &NatsBufferedThreadStore<T>, thread_id: &str, )

crates/awaken-stores/src/nats_buffered_thread/reader.rs:93

↓ 29 callersMethodrecord

(&self, event: &MetricsEvent)

crates/awaken-ext-observability/tests/wiring_integration.rs:268

↓ 29 callersFunctionsafeErrorMessage

(error: unknown)

apps/admin-console/src/lib/safe-error-message.ts:3

↓ 29 callersFunctiontool_map

(tools: Vec<Arc<dyn Tool>>)

crates/awaken-runtime/src/execution/executor.rs:371

↓ 29 callersMethodtry_recv

Try to receive the next pending message without blocking. Returns `None` when the channel is empty (or all senders dropped).

crates/awaken-runtime/src/inbox.rs:103

↓ 29 callersFunctionwire_sse_relay

( event_rx: mpsc::Receiver<AgentEvent>, encoder: E, buffer_size: usize, replay_buffer: Option<

crates/awaken-server/src/http_run.rs:36

↓ 28 callersMethodtake

(&mut self)

crates/awaken-ext-observability/src/batching.rs:47

↓ 28 callersMethodwith_created_at

(mut self, created_at: u64)

crates/awaken-server-contract/src/contract/mailbox.rs:238

↓ 28 callersMethodwith_tool_result

(mut self, result: ToolResult)

crates/awaken-runtime/src/hooks/context.rs:193

↓ 27 callersFunctionapply_overrides

If `overrides` is `Some(json)`, decode it as `T::Patch` and merge into `spec`. Returns `Err` only if decode fails (forward compat: unknown fields caus

crates/awaken-server/src/services/config_envelope.rs:17

↓ 27 callersFunctionbase_spec

()

crates/awaken-runtime-contract/tests/agent_spec_patch.rs:11

↓ 27 callersMethodexecute

( &self, tools: &HashMap<String, Arc<dyn Tool>>, calls: &[ToolCall], base_ctx:

crates/awaken-runtime/src/execution/executor.rs:95

↓ 27 callersMethodget

(&self, key: &str)

crates/awaken-ext-observability/src/otel.rs:110

↓ 27 callersFunctionhome_of

(home_key: &str, n: usize)

crates/awaken-runtime/src/engine/pool_executor_test_support.rs:196

↓ 27 callersFunctioninference

(agent: &str, input: i32, output: i32, duration_ms: u64, err: bool)

crates/awaken-ext-observability/src/runtime_stats_test.rs:13

↓ 27 callersFunctionis_tombstone

NATS KV helper predicates.

crates/awaken-stores/src/nats_mailbox/kv_helpers.rs:3

↓ 27 callersMethodload_messages

(&self, thread_id: &str)

crates/awaken-stores/tests/fault_injection.rs:62

↓ 27 callersFunctionmake_mailbox

(runtime: Arc<AgentRuntime>, store: Arc<InMemoryMailboxStore>)

crates/awaken-server/src/mailbox/tests.rs:959

↓ 27 callersMethodsnapshot_for

Aggregate every retained bucket for `agent_id` into a single snapshot. Returns `None` when the agent is unknown.

crates/awaken-ext-observability/src/runtime_stats.rs:160

↓ 27 callersMethodtext

Accumulated text so far — useful to construct a continuation prompt without having to finalize the collector.

crates/awaken-runtime/src/engine/streaming.rs:83

↓ 27 callersFunctiontool

(agent: &str, name: &str, duration_ms: u64, err: bool)

crates/awaken-ext-observability/src/runtime_stats_test.rs:44

↓ 27 callersFunctiontrace_to_provider_script

Walk the trace's events in order, reconstructing the scripted upstream. Only `MetricsEvent::Inference` records contribute to the script: `ScriptedLlm

crates/awaken-eval/src/curate.rs:138

↓ 27 callersMethodupdate

( &self, namespace: ConfigNamespace, id: &str, body: Value, )

crates/awaken-server/src/services/config_service.rs:567

← previous next →201–300 of 15,944, ranked by callers