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

↓ 12 callersFunctionsnapshot_with_policy

(policy: PermissionPolicy)

crates/awaken-ext-permission/src/plugin/filter_tests.rs:20

↓ 12 callersMethodsubmit_live_then_queue

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

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

↓ 12 callersFunctiontest_dispatch

(id: &str, thread_id: &str)

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

↓ 12 callersFunctionto_chat_message

Convert an awaken `Message` to a genai `ChatMessage`.

crates/awaken-runtime/src/engine/convert.rs:19

↓ 12 callersFunctionunique

(prefix: &str)

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

↓ 12 callersFunctionusage

(prompt: i32, completion: i32, total: i32)

crates/awaken-ext-observability/src/lib_test.rs:42

↓ 12 callersMethoduses_remote_backend

(&self)

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

↓ 12 callersFunctionvalidate_append_only_delta

Validate that a checkpoint append delta contains only new message ids. Re-submitting an already committed id would be an update/upsert attempt, not a

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

↓ 12 callersFunctionviewMessage

(message: { parts?: unknown })

apps/admin-console/src/lib/assistant-message.ts:63

↓ 12 callersMethodwith_adapter

(mut self, adapter: AdapterKind)

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

↓ 12 callersMethodwith_commit_coordinator

Wire a `CommitCoordinator` for atomic checkpoint commits across `ThreadRunStore` and `EventStore` writes (ADR-0036). When set, the runtime tees durabl

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

↓ 12 callersMethodwith_id

(mut self, id: String)

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

↓ 12 callersMethodwith_max_continuation_retries

(mut self, n: usize)

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

↓ 11 callersFunction__resetAuthInterceptorForTesting

()

apps/admin-console/src/lib/auth-interceptor.ts:41

↓ 11 callersFunctionagent

(id: &str, model_id: &str, delegates: impl IntoIterator<Item = &'a str>)

crates/awaken-stores/tests/registry_graph_validator.rs:408

↓ 11 callersFunctionagent

( id: &str, model_id: &str, delegates: impl IntoIterator<Item = &'a str>, )

crates/awaken-server/src/services/frozen_registry.rs:1085

↓ 11 callersFunctionagentSpec

(id: string)

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

↓ 11 callersFunctionappend_specs

( kind: &str, specs: &[T], id: fn(&T) -> &str, resources: &mut Vec<RegistryResourcePublish>, )

crates/awaken-server/src/services/config_runtime/versioned_publish.rs:243

↓ 11 callersFunctionapply_tool_filter_payloads

Apply tool filter payloads (exclusions and inclusions) to a tool list. - If any `IncludeOnlyTools` payloads exist, only tools in the combined allow-l

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

↓ 11 callersFunctionasObject

( value: unknown, )

examples/copilotkit-starter/lib/persisted-http-agent.ts:257

↓ 11 callersMethodas_str

(&self)

crates/awaken-server-contract/src/contract/scope.rs:43

↓ 11 callersFunctionbuild_chat_request

Build a genai `ChatRequest` from messages, system prompt, and tools.

crates/awaken-runtime/src/engine/convert.rs:159

↓ 11 callersMethodclaim_dispatch

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

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

↓ 11 callersMethodcreate_publication

( &self, scope_id: &str, publication_id: &str, entries: Vec<VersionRef>,

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

↓ 11 callersFunctiondashboardData

(overrides: Partial<DashboardData> = {})

apps/admin-console/src/pages/dashboard-page.test.tsx:83

↓ 11 callersMethoddecode_dispatch

(&self, mut dispatch: RunDispatch)

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

↓ 11 callersMethoddeliver_live

( &self, thread_id: &str, cmd: LiveRunCommand, )

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

↓ 11 callersMethoddeliver_live_to

( &self, target: &LiveRunTarget, cmd: LiveRunCommand, )

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

↓ 11 callersFunctionderiveSourceState

(meta: RecordMeta)

apps/admin-console/src/lib/api/types.ts:567

↓ 11 callersFunctiondiffReports

( baseline: ReplayReport[], next: ReplayReport[], )

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

↓ 11 callersFunctiondraft

(payload: i64)

crates/awaken-stores/tests/postgres_outbox_store.rs:25

↓ 11 callersFunctioneffective_policy

Return a [`ContextWindowPolicy`] clamped against the model's published capabilities. When a `ModelSpec` declares `context_window` and/or `max_output_

crates/awaken-runtime/src/context/effective_policy.rs:20

↓ 11 callersMethodevent_tables

(&self)

crates/awaken-stores/src/postgres_event.rs:309

↓ 11 callersFunctionisAgentEditorTab

(value: unknown)

apps/admin-console/src/lib/editor-tabs.ts:70

↓ 11 callersMethodis_cancelled

Check if cancellation has been requested (synchronous poll).

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

↓ 11 callersMethodis_resumable_waiting

(&self)

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

↓ 11 callersFunctionlatest_run

()

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

↓ 11 callersMethodlatest_run

(&self, thread_id: &str)

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

↓ 11 callersMethodlist

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

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

↓ 11 callersFunctionlive_target_for_run

(run: &RunRecord)

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

↓ 11 callersMethodload_committed_messages

( &self, thread_id: &str, )

crates/awaken-server/src/mailbox/pending_delivery_tests.rs:67

↓ 11 callersFunctionmakeEvent

( action: AuditEvent["action"], before?: Record<string, unknown> | null, after?: Record<string, unknown>

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

↓ 11 callersFunctionmake_ctx

(sink: Option<Arc<dyn EventSink>>)

crates/awaken-ext-generative-ui/src/run.rs:125

↓ 11 callersFunctionmake_registry

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

crates/awaken-ext-skills/src/plugin/active_instructions.rs:284

↓ 11 callersFunctionmake_request

()

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

↓ 11 callersFunctionmake_run

(run_id: &str, thread_id: &str, updated_at: u64)

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

↓ 11 callersFunctionmake_test_app

(agent_ids: &[&str])

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

↓ 11 callersFunctionmetaItem

( id: string, sourceKind: "builtin" | "user", userOverrides?: Record<string, unknown>, )

apps/admin-console/src/pages/agents-page.test.tsx:52

↓ 11 callersMethodon_run_end

(&self, metrics: &awaken_ext_observability::AgentMetrics)

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

↓ 11 callersMethodpatch_tool_overrides

PATCH /v1/config/tools/:id/overrides — see ADR-0029.

crates/awaken-server/src/services/config_service/tool_overrides.rs:15

↓ 11 callersFunctionprune

(registry: &mut ProtocolReplayRegistry)

crates/awaken-server/src/protocol_replay_state.rs:197

↓ 11 callersFunctionpublish_agent

( store: &InMemoryVersionedRegistryStore, spec: AgentSpec, )

crates/awaken-stores/tests/registry_graph_validator.rs:352

↓ 11 callersFunctionpublish_agent

( store: &InMemoryVersionedRegistryStore, spec: AgentSpec, )

crates/awaken-server/src/services/frozen_registry.rs:963

↓ 11 callersFunctionregistry

()

crates/awaken-server/src/protocol_replay_state.rs:189

↓ 11 callersFunctionreject_blank

(field: &str, value: &str)

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

↓ 11 callersFunctionrename

(node: Json, from: string, to: string)

packages/design-tokens/tokens.parity.test.ts:42

↓ 11 callersFunctionrenderDashboard

()

apps/admin-console/src/pages/dashboard-page.test.tsx:75

↓ 11 callersMethodreplay

(&self, fixture: &Fixture)

crates/awaken-eval/src/runtime_replayer.rs:322

↓ 11 callersFunctionresolve_model_capabilities

( mut model: ModelSpec, provider_source: Option<&str>, discovered: Option<&ModelCapabilityPatch>,

crates/awaken-runtime/src/registry/model_capabilities.rs:93

↓ 11 callersFunctionrouter

(members: Vec<RouterMember>)

crates/awaken-runtime/src/engine/pool_router.rs:261

↓ 11 callersFunctionrun_child_agent

Spawn a child agent run and await its terminal state. Returns the canonical [`BackendRunResult`] including final persisted state, status, response, a

crates/awaken-runtime/src/child_agent/mod.rs:170

↓ 11 callersFunctionsample_background_task_span

( status: awaken_runtime::extensions::background::TaskStatus, )

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

↓ 11 callersMethodsave_messages

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

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

↓ 11 callersMethodsave_thread

(&self, thread: &Thread)

crates/awaken-server/src/services/thread_service.rs:168

↓ 11 callersMethodsend_request

( &self, method: &str, params: Option<Value>, progress_registration: Option<(P

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

↓ 11 callersFunctionshared_config

(fixture: &NatsFixture)

crates/awaken-stores/tests/nats_buffered_thread_distributed.rs:20

↓ 11 callersFunctionspec_from_json

(src: &str)

crates/awaken-contract/tests/agent_spec_catalog.rs:11

↓ 11 callersFunctionspec_from_json

(src: &str)

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

↓ 11 callersMethodtimeout

(mut self, t: Duration)

crates/awaken-ext-observability/src/otel_config.rs:188

↓ 11 callersFunctiontogglePluginState

( pluginIds: string[] | undefined, activeHookFilter: string[] | undefined, pluginId: string, )

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

↓ 11 callersMethodunconditionally_denied_against

(&self, registry_tool_ids: I)

crates/awaken-ext-permission/src/rules.rs:286

↓ 11 callersMethodunscoped

(&self, id: &'a str)

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

↓ 11 callersFunctionunwrap_spec

If `value` is an envelope, return its `spec` field; otherwise return `value` unchanged. Used by callers that internally operate on bare specs. Used t

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

↓ 11 callersFunctionverify_event_ordering

(events: &[AgentEvent])

crates/awaken-runtime/tests/event_lifecycle.rs:219

↓ 11 callersFunctionwait_until

( timeout: Duration, interval: Duration, mut predicate: impl FnMut() -> bool, )

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

↓ 11 callersFunctionwithFilter

(overrides: Partial<SkillsFilterState>)

apps/admin-console/src/lib/skills-filter.test.ts:56

↓ 11 callersMethodwith_audit_log

(mut self, logger: Arc<AuditLogger>)

crates/awaken-server/src/app.rs:518

↓ 11 callersMethodwith_cooldown

(mut self, turns: u32)

crates/awaken-runtime-contract/src/contract/context_message.rs:158

↓ 11 callersMethodwith_dispatch_id

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

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

↓ 11 callersMethodwith_resume_mode

(mut self, resume_mode: ToolCallResumeMode)

crates/awaken-runtime/src/agent/state/tool_call_lifecycle.rs:54

↓ 11 callersFunctionwriteListState

( params: URLSearchParams, state: ListState<TKey>, options: ReadListStateOptions<TKey>, )

apps/admin-console/src/lib/list-url-state.ts:91

↓ 10 callersFunctionasString

(value: unknown)

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

↓ 10 callersFunctionatomic_write

( dir: &Path, filename: &str, content: &str, )

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

↓ 10 callersMethodavailable_at

(&self)

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

↓ 10 callersFunctionbadge

( id: string, spec: Parameters<NonNullable<(typeof AGENT_EDITOR_TABS)[number]["badge"]>>[0], )

apps/admin-console/src/lib/editor-tabs.test.ts:64

↓ 10 callersMethodbuild_options

(&self, request: &InferenceRequest)

crates/awaken-runtime/src/engine/executor.rs:116

↓ 10 callersFunctionbuild_service_router

(state: ServerState)

crates/awaken-server/src/app.rs:792

↓ 10 callersMethodcall_count

(&self)

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

↓ 10 callersFunctioncanonicalStringify

(value: unknown)

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

↓ 10 callersFunctioncheckpoint_parent_thread_id

( existing_thread: Option<&'a Thread>, run: &'a RunRecord, )

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

↓ 10 callersMethodclaim

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

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

↓ 10 callersMethodclaim

Transition a queued dispatch to claimed.

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

↓ 10 callersMethodcommitted_message_exists

( &self, thread_id: &str, message_id: &str, )

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

↓ 10 callersFunctionconvert_messages

Convert `UIMessage` list to runtime input messages. Assistant history is already persisted server-side, so incoming assistant UI messages are intenti

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

↓ 10 callersMethodcreate_run_channels_with_inbox

( &self, run_id: String, dispatch_id: Option<String>, inbox_tx: Option<InboxSe

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

↓ 10 callersFunctioncurrent_epoch_for_conn

(conn: &Connection, thread_id: &str)

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

↓ 10 callersFunctiondeserialize

(deserializer: D)

crates/awaken-runtime-contract/src/skill_spec_patch.rs:110

↓ 10 callersFunctionempty_snapshot

()

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

↓ 10 callersFunctionfetchAgentRuntimeStats

( agentId: string, options?: FetchAgentRuntimeStatsOptions | typeof fetch, fetchImpl: typeof fetch = glo

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

↓ 10 callersFunctionfetch_json

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

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

← previous next →701–800 of 15,944, ranked by callers