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

↓ 26 callersFunctionLboth

(enStr: string, anchor = false)

e2e/tests/demo-helpers.ts:108

↓ 26 callersMethodget

(&self, id: &str)

crates/awaken-ext-skills/src/mcp_bridge.rs:726

↓ 26 callersMethodget_or_create_worker

Get or create a per-thread worker.

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

↓ 26 callersMethodinto_response

(self)

crates/awaken-server/src/protocols/mcp/http.rs:628

↓ 26 callersMethodlen

(&self)

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

↓ 26 callersFunctionmake_registry

(skills: Vec<Arc<dyn Skill>>)

crates/awaken-ext-skills/src/plugin/tests.rs:14

↓ 26 callersFunctionmap_service_error

(error: ConfigServiceError)

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

↓ 26 callersMethodresolve

( &self, _request: ResolutionRequest, )

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

↓ 26 callersFunctionresult_label

(result: &Result<T, E>)

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

↓ 26 callersFunctionsample_genai_span

()

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

↓ 26 callersMethodscoped

(&self, id: &str)

crates/awaken-server-contract/src/contract/storage.rs:581

↓ 26 callersFunctionscore

Score `outcome` against `expect`, returning the (possibly empty) list of reasons the run did not meet expectations. An empty result means "all config

crates/awaken-eval/src/score.rs:14

↓ 26 callersMethodwith_metadata

(mut self, key: impl Into<String>, value: impl Into<Value>)

crates/awaken-runtime-contract/src/contract/tool.rs:196

↓ 25 callersFunctionbuild_genai_provider_executor_with_broker

Build an LLM executor from a [`ProviderSpec`]. Auth wiring branches on credential kind: - **Static bearer / explicit env fallback**: the api_key is

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

↓ 25 callersMethodclose_all

(&self)

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

↓ 25 callersMethoddeliver

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

crates/awaken-server/src/mailbox/pending_delivery.rs:70

↓ 25 callersFunctionfind_server_index

(servers: &[McpServerSlot], name: &str)

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

↓ 25 callersMethodget

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

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

↓ 25 callersFunctioninstall_recorder

Install the Prometheus metrics recorder. Must be called once at startup, before any metrics are recorded. Subsequent calls are no-ops.

crates/awaken-server/src/metrics.rs:25

↓ 25 callersMethodlist

List all entries for a key.

crates/awaken-runtime/src/profile/mod.rs:70

↓ 25 callersFunctionmake_runtime

()

crates/awaken-runtime/src/runtime/agent_runtime/control.rs:149

↓ 25 callersFunctionmake_runtime

()

crates/awaken/tests/tool_executor.rs:123

↓ 25 callersFunctionmk_run

(id: &str, thread: &str, updated_at: u64)

crates/awaken-stores/tests/nats_buffered_thread_adversarial.rs:203

↓ 25 callersFunctionoutcome_with

(metrics: AgentMetrics, text: &str)

crates/awaken-eval/src/outcome_test.rs:52

↓ 25 callersFunctionredactSecretString

(input: string)

apps/admin-console/src/lib/agent-secret-redaction.ts:371

↓ 25 callersMethodsave_thread

(&self, thread: &Thread)

crates/awaken-server-contract/src/contract/store_traits_tests.rs:27

↓ 25 callersMethodscoped

(&self, id: &str)

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

↓ 25 callersMethodwith_provider_factory

( mut self, provider_factory: Arc<dyn ProviderExecutorFactory>, )

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

↓ 24 callersMethodappend

(&self, run_id: &str, event: &MetricsEvent)

crates/awaken-ext-observability/src/trace_store/file.rs:233

↓ 24 callersFunctioncaption

(page: Page, text: string)

e2e/tests/demo-helpers.ts:154

↓ 24 callersMethodcreate_run

( &self, run: &RunRecord, )

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

↓ 24 callersFunctiondiff_against_baseline

[`DiffSummary`] suitable for CI gating. Pairing is by `fixture_id`. The returned `entries` are sorted by id.

crates/awaken-eval/src/report.rs:431

↓ 24 callersFunctiondispatch_key

(dispatch_id: &str)

crates/awaken-stores/src/nats_mailbox/keys.rs:5

↓ 24 callersFunctiondraft

(thread_id: &str, run_id: &str, value: i64)

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

↓ 24 callersFunctionget

(row: &sqlx::postgres::PgRow, name: &str)

crates/awaken-stores/src/postgres_outbox.rs:584

↓ 24 callersFunctionprepare_resume

Prepare tool call states for resume. For each decision: - `Cancel` → status = Cancelled - `Resume` → status = Resuming The runtime stores the full `

crates/awaken-runtime/src/loop_runner/resume.rs:56

↓ 24 callersMethodregister_keys

Register standalone state keys (not owned by any plugin). Keys that are already registered are silently skipped. This is used to install plugin-decla

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

↓ 24 callersMethodresolver

(&self)

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

↓ 24 callersMethodrevision

(&self)

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

↓ 24 callersMethodshutdown

(&self)

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

↓ 24 callersMethodsuccess

Create a success result. # Examples ``` use awaken_runtime_contract::contract::tool::ToolResult; use serde_json::json; let result = ToolResult::suc

crates/awaken-runtime-contract/src/contract/tool.rs:73

↓ 24 callersMethodtick

(&self)

crates/awaken-server/src/outbox_relay.rs:91

↓ 24 callersFunctionupdateField

(key: K, value: AgentSpec[K])

apps/admin-console/src/pages/agent-editor-page.tsx:447

↓ 24 callersFunctionuseToast

()

apps/admin-console/src/components/toast-provider.tsx:144

↓ 24 callersMethodwith_max_attempts

(mut self, max_attempts: u32)

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

↓ 24 callersFunctionwrite_lock

(lock: &RwLock<T>)

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

↓ 23 callersMethodas_str

(self)

crates/awaken-runtime/src/extensions/background/types.rs:23

↓ 23 callersFunctionencode

(dispatch: &RunDispatch)

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

↓ 23 callersMethodexecute

( &self, _request: InferenceRequest, )

crates/awaken-runtime/src/engine/mock.rs:108

↓ 23 callersFunctionfetchHref

(input: string | URL | Request)

apps/admin-console/src/pages/agent-editor-page.test.tsx:34

↓ 23 callersFunctionid

()

crates/awaken/tests/tool_executor.rs:160

↓ 23 callersMethodinto_response

(self)

crates/awaken-server/src/protocols/a2a/error.rs:171

↓ 23 callersMethodis_empty

Returns `true` when no criterion is set; useful for sanity-checking hand-authored fixture files.

crates/awaken-eval/src/expectation.rs:147

↓ 23 callersFunctionlock_unpoison

(m: &Mutex<T>)

crates/awaken-ext-observability/src/plugin/shared.rs:145

↓ 23 callersMethodrefresh

(&self)

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

↓ 23 callersMethodrun_id

(&self)

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

↓ 23 callersMethodtranscode

(&mut self, item: &AgentEvent)

crates/awaken-server/tests/transport_tests.rs:172

↓ 23 callersMethodwith_max_retries

Set the maximum number of retry attempts.

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

↓ 23 callersMethodwith_plugin

crates/awaken-runtime/src/builder.rs:128

↓ 22 callersFunctionaiSdkTextMessages

( messages: Array<{ role: AiSdkRole; text: string; id?: string }>, )

e2e/tests/ai-sdk-test-utils.ts:35

↓ 22 callersFunctionbase_spec

()

crates/awaken-contract/tests/agent_spec_patch.rs:9

↓ 22 callersFunctionbreaker

()

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

↓ 22 callersMethodbuild

( &self, endpoint: &RemoteEndpoint, )

crates/awaken-runtime/src/builder_tests.rs:110

↓ 22 callersMethodexecute

( &self, request: InferenceRequest, )

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

↓ 22 callersMethodget

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

crates/awaken-stores/src/memory_versioned_registry.rs:76

↓ 22 callersMethodload_dispatch

(&self, dispatch_id: &str)

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

↓ 22 callersFunctionmake_manager_with

( entries: Vec<(&str, Vec<McpToolDefinition>)>, )

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

↓ 22 callersFunctionmake_runtime

()

crates/awaken-runtime/src/runtime/agent_runtime/tests.rs:19

↓ 22 callersFunctionmake_simple_app

(llm: Arc<dyn LlmExecutor>)

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

↓ 22 callersFunctionmake_store

(fixture: &NatsFixture)

crates/awaken-stores/tests/nats_mailbox_behavior.rs:55

↓ 22 callersMethodquery

Query audit events with optional filters and keyset pagination. Returns `Err` if `filter.cursor` is present but not valid base64.

crates/awaken-server/src/services/audit_log.rs:338

↓ 22 callersMethodrecord

(&self, event: &MetricsEvent)

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

↓ 22 callersMethodsave_thread

(&self, thread: &Thread)

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

↓ 22 callersMethodsetItem

(key: string, value: string)

apps/admin-console/src/lib/admin-token.ts:5

↓ 22 callersMethodset_owner_inbox

Set the inbox sender that background tasks receive for pushing messages to the owner thread.

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

↓ 22 callersFunctiontest_request

()

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

↓ 22 callersFunctionwait_for_dispatch

( store: &InMemoryMailboxStore, dispatch_id: &str, predicate: F, )

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

↓ 21 callersFunctionapply_agent_prompt_override

( mut spec: AgentSpec, overrides: &StarterPromptOverrides, )

examples/src/starter_backend/mod.rs:351

↓ 21 callersMethodarc

(self)

crates/awaken-eval/src/test_support.rs:48

↓ 21 callersMethodcontext_scopes

(&self)

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

↓ 21 callersFunctiondeepEqualCanonical

(a: unknown, b: unknown)

apps/admin-console/src/lib/agent-editor-canonical.ts:31

↓ 21 callersFunctiondurable_sink

( stager: Arc<RecordingStager>, inner: Arc<VecEventSink>, mode: RuntimeEventDurability, )

crates/awaken-server-contract/src/contract/durable_event_sink/tests.rs:27

↓ 21 callersMethodenqueue_outbox

( &self, draft: OutboxMessageDraft, )

crates/awaken-stores/src/memory_outbox.rs:51

↓ 21 callersMethodexecute

( &self, _request: InferenceRequest, )

crates/awaken-runtime/src/extensions/a2a/tests.rs:53

↓ 21 callersMethodis_terminal

(self)

crates/awaken-runtime/src/extensions/background/types.rs:32

↓ 21 callersMethodlist_dispatches

( &self, thread_id: &str, status_filter: Option<&[RunDispatchStatus]>, limit:

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

↓ 21 callersFunctionlockedFieldChange

( spec: AgentSpec, parsed: Record<string, unknown>, )

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

↓ 21 callersFunctionmake_llm_response_with_tokens

(input: i32, output: i32)

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

↓ 21 callersFunctionmake_manager

(transport: Arc<MutablePromptTransport>)

crates/awaken-ext-skills/src/mcp_bridge.rs:945

↓ 21 callersMethodmeta

(&self)

crates/awaken-ext-skills/src/tools.rs:602

↓ 21 callersFunctionnow_ms

()

crates/awaken-runtime/src/loop_runner/compaction.rs:224

↓ 21 callersMethodrender_catalog

( &self, _active: &HashSet<String>, visibility: Option<&SkillVisibilityStateValue>,

crates/awaken-ext-skills/src/plugin/discovery.rs:95

↓ 21 callersMethodsubmit

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

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

↓ 21 callersFunctionvalidate_a2ui_messages

Validate an array of A2UI messages. Returns errors found (at most one per message). Empty `Vec` means all messages are valid.

crates/awaken-ext-generative-ui/src/a2ui/validation.rs:24

↓ 21 callersMethodvalidate_thread_hierarchy

Validate parent-child hierarchy invariants for a thread.

crates/awaken-server-contract/src/contract/store_traits.rs:207

↓ 21 callersMethodwith_title

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

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

↓ 20 callersMethodapply_run_projection

Update the thread's run pointers from a durable run record.

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

↓ 20 callersFunctionbreaker_threshold

(n: u32)

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

↓ 20 callersMethodbuild_dispatch

Build a RunDispatch from the durable run prepared above.

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

↓ 20 callersMethodcheckpoint

( &self, thread_id: &str, messages: &[Message], run: &RunRecord, )

crates/awaken-stores/tests/nats_buffered_thread_adversarial.rs:154

← previous next →301–400 of 15,944, ranked by callers