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

Report structured tool call progress. Emits an [`AgentEvent::ActivitySnapshot`] with `activity_type = "tool-call-progress"`. No-op if no `activity_si

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

↓ 16 callersFunctionsample_tool_span

()

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

↓ 16 callersMethodsend_task_inbox_message

Send a message to a child task's live inbox. This is the internal low-latency transport for parent→child communication within the same process. For c

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

↓ 16 callersFunctionstate_for_admin_surface_test

(address: &str, admin_api_config: AdminApiConfig)

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

↓ 16 callersFunctiontest_server_event_publisher

( event_store: Arc<InMemoryEventStore>, )

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

↓ 16 callersMethodthreads_dir

(&self)

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

↓ 16 callersFunctiontool_error

(tool_name: &str, code: &str, message: impl Into<String>)

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

↓ 16 callersMethodtouch

Ensure timestamps are initialized and mark the thread as updated.

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

↓ 16 callersMethodwith_priority

(mut self, priority: u8)

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

↓ 16 callersMethodwith_section

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

crates/awaken-runtime-contract/src/registry_spec/mod.rs:1156

↓ 15 callersMethodack

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

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

↓ 15 callersFunctionasString

(value: unknown)

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

↓ 15 callersFunctioncallsFor

(fetchSpy: FetchSpyLike, path: string, method = "GET")

apps/admin-console/src/test/http.ts:29

↓ 15 callersMethodcancel_all

Cancel all running tasks for a given thread. Returns the number of tasks cancelled.

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

↓ 15 callersFunctioncleanup_staged_file_ops

Clean up staged file operations on error.

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

↓ 15 callersMethodcommit_checkpoint_staged

( &self, plan: ThreadCommit, staged: ThreadCommitStagedWrites, )

crates/awaken-stores/src/file_commit_coordinator.rs:127

↓ 15 callersFunctiondraft

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

crates/awaken-stores/tests/postgres_protocol_replay_log.rs:34

↓ 15 callersFunctiondraft

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

crates/awaken-stores/tests/postgres_event_store.rs:36

↓ 15 callersFunctionenc

()

crates/awaken-server/src/protocols/acp/encoder.rs:286

↓ 15 callersMethodevents

Clone all collected events without clearing the buffer.

crates/awaken-runtime-contract/src/contract/event_sink.rs:46

↓ 15 callersMethodexecute

( &self, request: InferenceRequest, )

crates/awaken-runtime/src/engine/scripted.rs:166

↓ 15 callersFunctionfrom_json

( value: serde_json::Value, )

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

↓ 15 callersFunctiongen_message_id

Generate a time-ordered UUID v7 message identifier.

crates/awaken-runtime-contract/src/contract/message.rs:309

↓ 15 callersMethodget

(&self, id: &str)

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

↓ 15 callersFunctionisAgentRuntimeSnapshot

( value: unknown, )

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

↓ 15 callersMethodis_empty

(&self)

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

↓ 15 callersMethodlist_replay

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

crates/awaken-server-contract/src/contract/protocol_replay_log.rs:385

↓ 15 callersMethodlist_threads_query

(&self, query: &ThreadQuery)

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

↓ 15 callersMethodload_dispatch

(&self, dispatch_id: &str)

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

↓ 15 callersFunctionmake_registry

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

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

↓ 15 callersFunctionmake_request

()

crates/awaken-runtime/src/engine/scripted.rs:273

↓ 15 callersFunctionmake_skill_registry

()

crates/awaken/tests/skill_permission_e2e.rs:245

↓ 15 callersFunctionmake_store

(fixture: &NatsFixture)

crates/awaken-stores/tests/nats_buffered_thread_conformance.rs:14

↓ 15 callersMethodoptional

(self)

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

↓ 15 callersFunctionpattern_matches

(pattern: &ToolCallPattern, tool_id: &str, tool_args: &Value)

crates/awaken-tool-pattern/src/matcher.rs:15

↓ 15 callersFunctionpolicies_from_specs

Convert declarative stop condition specs into policy instances.

crates/awaken-runtime/src/policies/policy.rs:294

↓ 15 callersFunctionpost_json

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

crates/awaken-server/tests/a2a_gateway.rs:486

↓ 15 callersMethodpull_dispatch_signals

( &self, max: usize, expires: std::time::Duration, )

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

↓ 15 callersMethodrecord_background_task

(&self, span: &BackgroundTaskSpan)

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

↓ 15 callersMethodrecord_stream_failure

(&self, request: &InferenceRequest, err: &InferenceExecutionError)

crates/awaken-runtime/src/engine/modality_guard.rs:93

↓ 15 callersMethodregister

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

↓ 15 callersFunctionrenderProviders

()

apps/admin-console/src/pages/providers-page.test.tsx:94

↓ 15 callersFunctionrep

(id: string, passed: boolean)

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

↓ 15 callersFunctionresolveBreadcrumbs

(pathname: string)

apps/admin-console/src/lib/nav.ts:101

↓ 15 callersFunctionscene

( page: Page, pair: { en: string; zh: string }, )

e2e/tests/demo-helpers.ts:159

↓ 15 callersFunctionsend_request

( router: &axum::Router, method: Method, uri: &str, body: Option<Value>, )

crates/awaken-server/tests/config_backends.rs:321

↓ 15 callersMethodshutdown

(&self)

crates/awaken-server/tests/agent_dashboard_e2e.rs:104

↓ 15 callersMethodskip_whitespace

(&mut self)

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

↓ 15 callersMethodsnapshot

(&self)

crates/awaken-runtime/src/registry/snapshot.rs:80

↓ 15 callersFunctionstage_write

Write and fsync a temp file, returning a staged write for later commit.

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

↓ 15 callersFunctionstore

()

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

↓ 15 callersFunctionstubFetch

( overrides?: Record<string, unknown>, supportedAdapters = ["openai", "anthropic"], options?: { list

apps/admin-console/src/pages/providers-page.test.tsx:24

↓ 15 callersFunctionsummarizeChange

(event: AuditEvent)

apps/admin-console/src/lib/audit-log.ts:70

↓ 15 callersMethodtoken_for

( &self, provider_id: &str, scope: &str, )

crates/awaken-runtime/src/credentials/broker.rs:290

↓ 15 callersMethodtransform

( &self, mut messages: Vec<Message>, tool_descriptors: &[ToolDescriptor], )

crates/awaken-runtime/src/context/transform/mod.rs:46

↓ 15 callersMethodtry_dispatch_next

(self: &Arc<Self>, thread_id: &str)

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

↓ 15 callersFunctionupdate

(nextConfig: DeferredToolsConfig)

apps/admin-console/src/components/editors/deferred-tools-editor.tsx:27

↓ 15 callersFunctionvalidate_skill_spec

Validate and decode a `SkillSpec` for config write surfaces.

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

↓ 14 callersFunctionapply_context_messages

Insert context messages into the message list at their declared target positions.

crates/awaken-runtime/src/loop_runner/actions.rs:291

↓ 14 callersFunctioncaptured_inference_span

(run_id: &str, text: &str, with_user: bool)

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

↓ 14 callersMethodclaim_outbox

( &self, lane: &str, target: &str, limit: usize, lease_ms: u64,

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

↓ 14 callersMethodcreate_run

(&self, record: &RunRecord)

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

↓ 14 callersMethodemit

(&self, event: AgentEvent)

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

↓ 14 callersFunctionencode_event_to_sse

Encode a single agent event through a transcoder into SSE data frames.

crates/awaken-server/src/transport/transcoder.rs:11

↓ 14 callersMethodfind_dependents

Return all records in other namespaces that reference `id` in `namespace`. - Providers: scans models for `provider_id == id` - Models: scans agents f

crates/awaken-server/src/services/config_service/dependencies.rs:18

↓ 14 callersFunctionfind_event

(events: &'a [Value], event_type: &str)

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

↓ 14 callersFunctionfind_split_point

Find the split point in history that fits the token budget. Always keeps at least `min_recent` messages from the end. Adjusts boundaries to avoid spl

crates/awaken-runtime/src/context/transform/truncation.rs:10

↓ 14 callersMethodinto_rules

Convert this configuration into a list of [`ReminderRule`]s.

crates/awaken-ext-reminder/src/config.rs:168

↓ 14 callersFunctioninvalidateConfigMutation

(queryClient: QueryClient, namespace: string, id?: string)

apps/admin-console/src/lib/query/invalidation.ts:8

↓ 14 callersFunctionisToolAllowed

(catalog: AgentSpecCatalog, toolId: string)

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

↓ 14 callersMethodkind

Stable string discriminator used for grouping in reports.

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

↓ 14 callersMethodlist_threads

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

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

↓ 14 callersFunctionload

(override?: Partial<typeof filter>)

apps/admin-console/src/pages/audit-log-page.tsx:84

↓ 14 callersMethodlock_apply

(&self)

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

↓ 14 callersFunctionmake_llm_error

()

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

↓ 14 callersFunctionmake_local_registry

()

crates/awaken-runtime/src/registry/composite.rs:499

↓ 14 callersFunctionmake_run

(run_id: &str, thread_id: &str, status: RunStatus)

crates/awaken-stores/src/memory/tests.rs:14

↓ 14 callersFunctionmake_run

(run_id: &str, thread_id: &str, status: RunStatus)

crates/awaken-stores/tests/thread_store_conformance.rs:12

↓ 14 callersFunctionmerge_checkpoint_append_messages

Merge an append checkpoint delta into the committed message projection. Committed history is append-only (ADR-0042 I1/D6): only message ids not alrea

crates/awaken-runtime-contract/src/contract/storage/message_append.rs:155

↓ 14 callersFunctionmessaging_env

Build a messaging-enabled env (registers the outbox + dead-letter keys) and a store wired to the manager.

crates/awaken-runtime/src/extensions/background/send_message_tool.rs:696

↓ 14 callersFunctionmodel

(overrides: Partial<ModelSpec>)

apps/admin-console/src/pages/models-page.test.tsx:60

↓ 14 callersFunctionplain

Drop labelKey from crumbs so tests focus on the resolved literals.

apps/admin-console/src/lib/nav.test.ts:10

↓ 14 callersFunctionpost_json

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

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

↓ 14 callersFunctionprepare_queued_dispatch

( mailbox: &Arc<Mailbox>, thread_id: &str, content: &str, )

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

↓ 14 callersMethodregister

Register or replace credential material for a provider id. Replacing material **invalidates the cache** for all scopes of that provider — the next `t

crates/awaken-runtime/src/credentials/broker.rs:250

↓ 14 callersMethodregistries

(&self)

crates/awaken-runtime/src/registry/snapshot.rs:29

↓ 14 callersFunctionrelease_dedupe_lock

Delete the dedupe lock. Idempotent — failures are logged and swallowed because a stale lock is recoverable (manual purge or TTL sweep) while a panicki

crates/awaken-stores/src/nats_mailbox/ops_write.rs:315

↓ 14 callersFunctionrenderModels

()

apps/admin-console/src/pages/models-page.test.tsx:100

↓ 14 callersFunctionresetCrud

(overrides: Partial<typeof pageState.crud> = {})

apps/admin-console/src/pages/models-page.test.tsx:70

↓ 14 callersMethodresolve

( &self, req: awaken_runtime::ResolutionRequest, )

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

↓ 14 callersMethodresume_run_id

(&self)

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

↓ 14 callersMethodrun

(&self, ctx: &PhaseContext)

crates/awaken-ext-permission/src/plugin/filter.rs:39

↓ 14 callersFunctionseed_thread_with_lineage

( store: &InMemoryStore, title: Option<&str>, resource_id: Option<&str>, paren

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

↓ 14 callersFunctionsend_message_payload

(task_id: &str, context_id: &str, message_id: &str, text: &str)

crates/awaken-server/tests/a2a_http.rs:372

↓ 14 callersFunctionspan

()

crates/awaken-ext-observability/src/trace_store/file_test.rs:14

↓ 14 callersFunctionspawn_mock_a2a_server

( completion_mode: MockCompletionMode, slow_poll: bool, supports_subscribe: bool, )

crates/awaken-server/tests/a2a_gateway.rs:327

↓ 14 callersFunctionspec

(id: &str)

crates/awaken-ext-skills/src/config_skill.rs:340

↓ 14 callersFunctionsse_body_stream

Convert an mpsc receiver of SSE chunks into an async stream suitable for HTTP response. Injects periodic SSE comment heartbeats (`: heartbeat`) when

crates/awaken-server/src/http_sse.rs:21

↓ 14 callersMethodstore

(&self)

crates/awaken-stores/src/postgres_commit_coordinator.rs:52

↓ 14 callersMethodsubscribe

(&self)

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

← previous next →501–600 of 15,944, ranked by callers