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

↓ 20 callersFunctioncreateQueryClientWrapper

()

apps/admin-console/src/test/query.tsx:5

↓ 20 callersFunctioncurrent_millis

()

crates/awaken-stores/src/nats_mailbox/sweeper.rs:113

↓ 20 callersFunctiondecode

(bytes: &[u8])

crates/awaken-stores/src/nats_mailbox/codec.rs:14

↓ 20 callersMethoddedupe_key

(&self)

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

↓ 20 callersMethodis_success

(&self)

crates/awaken-ext-observability/src/metrics.rs:267

↓ 20 callersMethodload_messages

( &self, thread_id: &str, )

crates/awaken-server/src/mailbox/checkpoint.rs:288

↓ 20 callersFunctionmakeSnapshot

( overrides: Partial<AgentRuntimeSnapshot> = {}, )

apps/admin-console/src/lib/agent-stats.test.ts:19

↓ 20 callersFunctionmanager_with_store_and_inbox

Create a manager with store and owner inbox wired up.

crates/awaken-runtime/src/extensions/background/tests.rs:35

↓ 20 callersMethodpeek

(&self)

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

↓ 20 callersFunctionpost_json

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

crates/awaken-server/tests/restore_routes.rs:141

↓ 20 callersMethodregister

(&mut self, skill: Arc<dyn Skill>)

crates/awaken-ext-skills/src/registry.rs:80

↓ 20 callersFunctionseeded_waiting_run

(run_id: &str, thread_id: &str, agent_id: &str)

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

↓ 20 callersFunctionspan

(model: &str, step: u32)

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

↓ 20 callersMethodspawn_agent

Spawn a sub-agent as a background task with its own inbox. `name` is an optional short identifier for addressing via `send_message`.

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

↓ 20 callersFunctionstream_request_for_thread

(thread_id: &str, logical_id: &str)

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

↓ 20 callersMethodwith_canonical_drafts

(mut self, drafts: Vec<StagedCanonicalEvent>)

crates/awaken-server-contract/src/contract/staged_commit.rs:115

↓ 20 callersMethodwith_tool

(mut self, tool: Arc<dyn Tool>)

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

↓ 19 callersMethodadd

(&mut self, sink: Arc<dyn MetricsSink>)

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

↓ 19 callersFunctionattr_map

Helper: build a HashMap of attribute key -> Value from a SpanData.

crates/awaken-ext-observability/src/otel_test.rs:271

↓ 19 callersFunctionbaseline_run

(id: &str)

crates/awaken-server/tests/eval_api.rs:3814

↓ 19 callersFunctionbuild_agent_env

Build an execution environment for the agent loop. Injects runtime-required default plugins and conditionally adds context truncation when a policy i

crates/awaken-runtime/src/loop_runner/mod.rs:275

↓ 19 callersMethodcancel

Cancel a running task.

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

↓ 19 callersMethodcapabilities

(&self)

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

↓ 19 callersMethodenqueue_outbox

( &self, draft: OutboxMessageDraft, )

crates/awaken-server-contract/src/contract/outbox.rs:259

↓ 19 callersFunctionestimate_message_tokens

Estimate token count for a single message (roughly 4 chars per token).

crates/awaken-runtime-contract/src/contract/transform.rs:50

↓ 19 callersMethodfinished_spans

(&self)

crates/awaken-ext-observability/src/otel_test.rs:238

↓ 19 callersFunctioninitialize_response

(request: &HttpRequestSpec, capabilities: Value)

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

↓ 19 callersFunctionisRecord

(value: unknown)

examples/ai-sdk-starter/src/components/tools/a2ui-protocol.ts:30

↓ 19 callersMethodlist_outbox

( &self, status: Option<OutboxStatus>, limit: usize, )

crates/awaken-server-contract/src/contract/outbox.rs:335

↓ 19 callersMethodload_thread

(&self, thread_id: &str)

crates/awaken-stores/src/memory/mod.rs:140

↓ 19 callersMethodmailbox

(&self)

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

↓ 19 callersFunctionmakeToast

(overrides: Partial<Toast> = {})

apps/admin-console/src/lib/toast-queue.test.ts:14

↓ 19 callersFunctionmake_test_app

()

crates/awaken-server/tests/run_api.rs:460

↓ 19 callersFunctionmake_test_env

(policies: Vec<Arc<dyn StopPolicy>>)

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

↓ 19 callersMethodnormalize_lineage

Normalize lineage identifiers in-place.

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

↓ 19 callersFunctionnormalize_lineage_id

(value: Option<&str>)

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

↓ 19 callersFunctionnow_ms

()

crates/awaken-runtime/src/context/compaction.rs:492

↓ 19 callersFunctionoptional_json

( field: &str, value: Option<&T>, )

crates/awaken-stores/src/postgres/run.rs:21

↓ 19 callersFunctionparseReportsNdjson

(text: string)

apps/admin-console/src/lib/eval-reports.ts:75

↓ 19 callersFunctionpermission_rules_from_state

( policy: Option<&PermissionPolicy>, overrides: Option<&PermissionOverrides>, )

crates/awaken-ext-permission/src/state.rs:203

↓ 19 callersFunctionpost_json

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

crates/awaken-server/tests/run_api.rs:719

↓ 19 callersMethodreduce

(&mut self, action: HandoffAction)

crates/awaken-runtime/src/extensions/handoff/state.rs:18

↓ 19 callersMethodrefresh_dispatch_depth_metrics

(&self)

crates/awaken-server/src/mailbox/signal_loop.rs:29

↓ 19 callersMethodregister_tool

( &mut self, id: impl Into<String>, tool: Arc<dyn Tool>, )

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

↓ 19 callersFunctionreplay_all

Replay a slice of fixtures through `replayer`, preserving input order.

crates/awaken-eval/src/replay.rs:21

↓ 19 callersFunctiontemp_dir

(suffix: &str)

crates/awaken-ext-observability/src/wiring.rs:447

↓ 19 callersFunctiontest_policy

All test policies use zero backoff so tests run instantly.

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

↓ 19 callersFunctionvalidate_model_spec

Validate and decode a `ModelSpec` from JSON for config write surfaces. Rejects unknown fields (read-time deserialization stays lenient), then delegat

crates/awaken-runtime-contract/src/config_validation/mod.rs:303

↓ 19 callersFunctionwait_for_span

Poll Phoenix's spans REST endpoint until `predicate` returns `Some(span)` or attempts run out. `spans_url` is typically `{base}/v1/projects/default/s

e2e/phoenix/test-helpers/src/lib.rs:212

↓ 19 callersMethodwith_max_rounds

(mut self, max_rounds: usize)

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

↓ 19 callersMethodwith_tool_executor

(mut self, executor: Arc<dyn ToolExecutor>)

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

↓ 18 callersMethodack

( &self, dispatch_id: &str, claim_token: &str, now: u64, )

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

↓ 18 callersFunctionempty_snapshot

()

crates/awaken-ext-observability/src/attribution_fills_tests.rs:28

↓ 18 callersMethodis_terminal

Returns `true` for terminal states that cannot transition further.

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

↓ 18 callersMethodlist_replay

( &self, stream: ProtocolStreamKey, from: Option<ProtocolReplayCursor>, limit:

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

↓ 18 callersMethodlist_runs

(&self, query: &RunQuery)

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

↓ 18 callersFunctionmake_agent

Build an agent backed by a single-script executor (the script repeats on every attempt).

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

↓ 18 callersFunctionpatternMatches

(pattern: string, toolId: string)

apps/admin-console/src/lib/tool-catalog.ts:22

↓ 18 callersMethodput

( &self, namespace: &str, id: &str, value: &Value, )

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

↓ 18 callersMethodregister_provider

( &mut self, id: impl Into<String>, executor: Arc<dyn LlmExecutor>, )

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

↓ 18 callersMethodsave_thread

(&self, _t: &Thread)

crates/awaken-server/src/routes_test.rs:702

↓ 18 callersFunctionseed_v1

(specs: Vec<BuiltinSpec>)

crates/awaken-server/src/services/builtin_seed/tests.rs:55

↓ 18 callersFunctionshot

(page: Page, opts: ShotOpts = {})

e2e/tests/demo-helpers.ts:268

↓ 18 callersMethodshutdown

(&self)

crates/awaken-server/src/services/config_runtime.rs:805

↓ 18 callersMethodstore

Returns a reference to the store, if set.

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

↓ 18 callersMethodupsert_with_revision

(&mut self, dispatch: RunDispatch, revision: u64)

crates/awaken-stores/src/nats_mailbox/index.rs:33

↓ 18 callersMethodwith_run_id_hint

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

crates/awaken-runtime/src/run.rs:281

↓ 18 callersMethodwith_server_event_publisher

Attach a publisher for advisory server-authored canonical events.

crates/awaken-server/src/mailbox/runtime_event_capture.rs:54

↓ 17 callersMethodappend_pending_message_records

( &self, thread_id: &str, messages: &[Message], delivery_mode: DeliveryMode,

crates/awaken-stores/src/memory/pending.rs:100

↓ 17 callersMethodas_str

(&self)

crates/awaken-runtime-contract/src/contract/event_store.rs:57

↓ 17 callersMethodbuild

(self)

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

↓ 17 callersMethodcheckpoint_append

( &self, thread_id: &str, messages: &[Message], expected_version: Option<u64>,

crates/awaken-stores/src/file.rs:1664

↓ 17 callersFunctiondecode_http_response_payload

( body: Value, request_id: i64, progress_registration: Option<(ProgressTokenKey, mpsc::Sender<McpP

crates/awaken-ext-mcp/src/transport.rs:3737

↓ 17 callersFunctiondraft

(wire_event_id: &str, protocol_version: &str, payload: &[u8])

crates/awaken-stores/tests/memory_protocol_replay_log_conformance.rs:13

↓ 17 callersFunctionextract_tool_call_decisions

Extract tool-call decisions from assistant message parts.

crates/awaken-server/src/protocols/ai_sdk_v6/request.rs:354

↓ 17 callersMethodforce_flush_all_pending

(&self)

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

↓ 17 callersFunctionidentity

(agent: &str)

crates/awaken-ext-observability/src/plugin/tests.rs:1047

↓ 17 callersFunctioninstall_default_sinks

Pure assembly entry point taking pre-resolved [`WiringSettings`]. Always returns a non-null sink: When `settings.disabled` is `true`, returns a bare

crates/awaken-ext-observability/src/wiring.rs:165

↓ 17 callersMethodis_empty

(&self)

crates/awaken-ext-generative-ui/src/a2ui/plugin.rs:66

↓ 17 callersMethodload_dispatch

( &self, dispatch_id: &str, )

crates/awaken-server/src/mailbox/live_delivery.rs:229

↓ 17 callersFunctionmake_capturing_sink

Build an OtelMetricsSink backed by our in-memory exporter so exported OTel spans can be inspected.

crates/awaken-ext-observability/src/otel_test.rs:253

↓ 17 callersFunctionmake_manager_with_store

()

crates/awaken-server/src/services/config_runtime.rs:2025

↓ 17 callersFunctionmake_prefixed_store

(prefix: &str)

crates/awaken-stores/tests/postgres_store.rs:40

↓ 17 callersFunctionmodel_with

(id: &str, ctx: Option<u32>, out: Option<u32>)

crates/awaken-runtime/src/registry/resolve/pool.rs:295

↓ 17 callersFunctionreject_empty

( surface: &'static str, field: &'static str, value: &str, )

crates/awaken-runtime-contract/src/config_validation/mod.rs:614

↓ 17 callersMethodsave_messages

( &self, _id: &str, _msgs: &[Message], )

crates/awaken-server/src/routes_test.rs:718

↓ 17 callersMethodset

(&self, owner: &ProfileOwner, key: &str, value: Value)

crates/awaken-stores/src/memory/mod.rs:568

↓ 16 callersFunctionapi

Authenticated backend request helper.

e2e/tests/admin-demo.spec.ts:296

↓ 16 callersFunctionasRecord

(value: unknown)

apps/admin-console/src/lib/plugin-config.ts:512

↓ 16 callersFunctionbuild_test_app

()

crates/awaken-server/src/config_routes.rs:1154

↓ 16 callersMethodcancel

Cancel a run by dispatch_id or thread_id. If Queued: transitions to Cancelled via store. If Claimed/Running: cancels runtime run via dual-index looku

crates/awaken-server/src/mailbox/cancel.rs:29

↓ 16 callersMethodcancel

Signal cancellation. Wakes all async waiters immediately.

crates/awaken-runtime-contract/src/cancellation.rs:47

↓ 16 callersMethodcheckpoint

( &self, _thread_id: &str, _messages: &[Message], _run: &RunRe

crates/awaken-server/src/mailbox/checkpoint.rs:345

↓ 16 callersMethodcreate

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

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

↓ 16 callersMethodcreated_at

(&self)

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

↓ 16 callersMethodevents

(&self)

crates/awaken-runtime/src/extensions/a2a/progress_sink.rs:83

↓ 16 callersMethodexport_persisted

Export all persistent keys (every scope) into one `PersistedState`.

crates/awaken-runtime/src/state/persistence.rs:10

↓ 16 callersMethodexpose_secret

Reach through the redaction to obtain the plaintext value. Calls to this function are the trust boundary: every caller is responsible for not propaga

crates/awaken-runtime-contract/src/secret.rs:36

↓ 16 callersFunctionformatRelativeTime

(ms: number | undefined | null)

apps/admin-console/src/lib/format-time.ts:12

↓ 16 callersFunctionmark_superseded_at_epoch

( dispatch: &mut RunDispatch, now: u64, epoch: u64, reason: Option<&str>, )

crates/awaken-stores/src/mailbox_state.rs:33

← previous next →401–500 of 15,944, ranked by callers