MCPcopy Create free account

hub / github.com/awakenworks/awaken / functions

Functions15,944 in github.com/awakenworks/awaken

⨍ Functions 15,944◇ Types & classes 2,546
↓ 14 callersMethodtool_descriptors
(&self)
crates/awaken-runtime/src/registry/resolver.rs:203
↓ 14 callersMethodvalidate_args
(&self, args: &Value)
crates/awaken-ext-generative-ui/src/a2ui/tool.rs:276
↓ 14 callersFunctionvalidate_parallel_state_batches
Validate that parallel tool state batches do not conflict on exclusive keys. Returns `Ok(())` if all modifications are compatible, or `Err(ParallelMe
crates/awaken-runtime/src/loop_runner/parallel_merge.rs:40
↓ 14 callersMethodwith_available_at
(mut self, available_at: u64)
crates/awaken-server-contract/src/contract/mailbox.rs:232
↓ 14 callersMethodwith_backoff_base_ms
Set the backoff base delay in milliseconds.
crates/awaken-runtime/src/engine/retry.rs:94
↓ 14 callersMethodwith_continue_run_id
(self, run_id: impl Into<String>)
crates/awaken-runtime/src/run.rs:256
↓ 14 callersMethodwith_registry_snapshot
(mut self, snapshot: Arc<RegistrySnapshot>)
crates/awaken-runtime/src/hooks/context.rs:241
↓ 13 callersFunctionchecked_i64_to_u64
(field: &str, value: i64)
crates/awaken-stores/src/postgres_versioned_registry/helpers.rs:368
↓ 13 callersMethodcheckpoint
( &self, thread_id: &str, messages: &[Message], run: &RunRecord, )
crates/awaken-stores/tests/nats_buffered_thread_behavior.rs:92
↓ 13 callersMethodclaim
( &self, thread_id: &str, consumer_id: &str, lease_ms: u64, now: u64,
crates/awaken-stores/src/sqlite_mailbox/mod.rs:444
↓ 13 callersMethodclaim_token
(&self)
crates/awaken-server-contract/src/contract/mailbox.rs:374
↓ 13 callersFunctioncleanup_thread_index
(store: &NatsMailboxStore, dispatch: &RunDispatch)
crates/awaken-stores/src/nats_mailbox/ops_write.rs:539
↓ 13 callersMethodcreate_run
(&self, _r: &RunRecord)
crates/awaken-server/src/routes_test.rs:739
↓ 13 callersFunctiondeserialize_namespace
(entries: &[(String, Value)])
crates/awaken-server/src/services/config_runtime.rs:1498
↓ 13 callersMethodemit
(&self, event: AgentEvent)
crates/awaken-server/src/transport/channel_sink.rs:21
↓ 13 callersMethodencode_cursor
(&self, offset: usize)
crates/awaken-server-contract/src/contract/storage.rs:91
↓ 13 callersFunctionensure_supported_version
(headers: &HeaderMap)
crates/awaken-server/src/protocols/a2a/common.rs:142
↓ 13 callersMethodexecute
(&self, args: Value, _ctx: &ToolCallContext)
examples/src/research/tools.rs:35
↓ 13 callersFunctionextract_event_types
(events: &[Value])
crates/awaken-server/tests/protocol_ag_ui_e2e.rs:262
↓ 13 callersFunctionfilterSkills
( skills: SkillInfo[], filter: SkillsFilterState, )
apps/admin-console/src/lib/skills-filter.ts:19
↓ 13 callersMethodis_cancelled
Returns `true` if cancellation has been requested.
crates/awaken-runtime/src/extensions/background/types.rs:150
↓ 13 callersMethodlease_until
(&self)
crates/awaken-server-contract/src/contract/mailbox.rs:384
↓ 13 callersMethodload_dispatch
(&self, dispatch_id: &str)
crates/awaken-stores/src/nats_mailbox/mod.rs:485
↓ 13 callersMethodload_run
(&self, run_id: &str)
crates/awaken-stores/tests/fault_injection.rs:99
↓ 13 callersMethodload_run
(&self, _run_id: &str)
crates/awaken-runtime/src/backend/mod.rs:897
↓ 13 callersMethodload_thread
(&self, _id: &str)
crates/awaken-server/src/routes_test.rs:699
↓ 13 callersFunctionmake_ctx
(snapshot: Snapshot)
crates/awaken-ext-permission/src/plugin/filter_tests.rs:26
↓ 13 callersFunctionmake_policy
(max_tokens: usize, min_recent: usize)
crates/awaken-runtime/src/context/transform/mod.rs:106
↓ 13 callersFunctionmake_tool_span
(name: &str, error: bool)
crates/awaken-ext-observability/tests/observability_integration.rs:73
↓ 13 callersFunctionnon_blank_string
(value: &Value, key: &str)
crates/awaken-server-contract/src/contract/durable_event_sink/compaction.rs:383
↓ 13 callersMethodpublish
( &self, managed: ManagedConfigSnapshot, )
crates/awaken-server/src/services/config_runtime/publish.rs:7
↓ 13 callersMethodput
(&self, ns: &str, id: &str, value: &Value)
crates/awaken-server/src/services/audit_log.rs:598
↓ 13 callersMethodread
(&self, run_id: &str)
crates/awaken-eval/src/eval_run.rs:583
↓ 13 callersFunctionreadListState
( params: URLSearchParams, options: ReadListStateOptions<TKey>, )
apps/admin-console/src/lib/list-url-state.ts:42
↓ 13 callersFunctionread_flushed_seq
( kv: &async_nats::jetstream::kv::Store, thread_id: &str, )
crates/awaken-stores/src/nats_buffered_thread/hot_meta.rs:233
↓ 13 callersFunctionregistry_content_hash
( value_schema_version: u32, value: &Value, )
crates/awaken-server-contract/src/contract/pinned_registry.rs:58
↓ 13 callersFunctionrequest_for_thread
(thread_id: &str)
crates/awaken-runtime/src/engine/pool_executor_test_support.rs:40
↓ 13 callersMethodrun
( &self, ctx: &PhaseContext, )
crates/awaken-runtime/tests/event_lifecycle.rs:138
↓ 13 callersMethodsnapshot
(&self)
crates/awaken-ext-skills/src/registry.rs:125
↓ 13 callersMethodstart_lifecycle
Start framework-managed startup recovery plus sweep/GC maintenance. This method is idempotent: repeated calls return a handle to the already-running
crates/awaken-server/src/mailbox/lifecycle.rs:41
↓ 13 callersFunctionsuccess_response
(u: Option<TokenUsage>)
crates/awaken-ext-observability/src/lib_test.rs:112
↓ 13 callersFunctiontemp_root
(name: &str)
crates/awaken-ext-observability/src/trace_store/file_test.rs:4
↓ 13 callersFunctiontool
Helper: create a simple tool descriptor with the given id.
crates/awaken-runtime/src/loop_runner/tests.rs:421
↓ 13 callersFunctiontoolStats
( agent_id: string, tool: string, overrides: Partial<AgentToolStats> = {}, )
apps/admin-console/src/lib/eval-reports.test.ts:38
↓ 13 callersFunctionupdateRule
(index: number, nextRule: ReminderConfigDraft["rules"][number])
apps/admin-console/src/components/editors/reminder-editor.tsx:45
↓ 13 callersMethodwith_responses
(mut self, responses: Vec<String>)
crates/awaken-runtime/src/engine/mock.rs:34
↓ 12 callersFunctiona2aSendMessagePayload
(text: string, taskId?: string)
e2e/tests/a2a-test-utils.ts:3
↓ 12 callersFunctionagentItem
(id: string, modelId = "bootstrap")
apps/admin-console/src/pages/agents-page.test.tsx:12
↓ 12 callersFunctionagent_prompt_id
Stable id derived from an agent's effective system prompt under a specific agent identity. Equal `(agent_id, role, content)` triples share an id. Ide
crates/awaken-runtime-contract/src/identity.rs:22
↓ 12 callersFunctionalready_consumed
(pending_id: &str)
crates/awaken-stores/src/memory/pending.rs:34
↓ 12 callersFunctionasString
(value: unknown)
examples/ai-sdk-starter/src/hooks/use-chat-session.ts:41
↓ 12 callersFunctionat
(ms: number)
apps/admin-console/src/lib/format-time.test.ts:11
↓ 12 callersFunctionbuild_coordinator
()
crates/awaken-stores/src/memory_commit_coordinator.rs:252
↓ 12 callersFunctionbuild_material
Build typed material from raw fields (adapter + kind + api_key). Used at config write time for **eager validation** — the server rejects invalid (kin
crates/awaken-runtime/src/credentials/material.rs:206
↓ 12 callersFunctionbuild_remote_runtime
( endpoint: RemoteEndpoint, abort_count: Arc<AtomicUsize>, )
crates/awaken-runtime/src/runtime/agent_runtime/runner/tests.rs:238
↓ 12 callersFunctionbuild_test_service_with_tool
( id: &str, description: &str, )
crates/awaken-server/src/services/config_service/tests.rs:1808
↓ 12 callersFunctionbundled_fixtures_dir
()
crates/awaken-eval/tests/eval_integration.rs:26
↓ 12 callersMethodcancel
Cancel the running agent loop cooperatively.
crates/awaken-runtime/src/runtime/agent_runtime/mod.rs:58
↓ 12 callersMethodclaim_dispatch
( &self, dispatch_id: &str, consumer_id: &str, lease_ms: u64, now: u64
crates/awaken-server/src/mailbox/tests.rs:233
↓ 12 callersFunctionclickByName
( page: Page, role: Parameters<Page['getByRole']>[0], name: string | RegExp, opts: { timeout?: number
e2e/tests/admin-demo.spec.ts:151
↓ 12 callersMethodcollect_commands
Run phase hooks without committing — return the combined StateCommand.
crates/awaken-runtime/src/phase/engine.rs:77
↓ 12 callersFunctioncompareString
(a: string | undefined, b: string | undefined)
apps/admin-console/src/lib/list-view.ts:111
↓ 12 callersFunctionctx
(agent: &str)
crates/awaken-ext-observability/src/runtime_stats_test.rs:4
↓ 12 callersMethoddelete_thread_with_strategy
( &self, thread_id: &str, strategy: ChildThreadDeleteStrategy, )
crates/awaken-stores/src/file.rs:1180
↓ 12 callersMethodensure_current
( &self, kv: &async_nats::jetstream::kv::Store, )
crates/awaken-stores/src/nats_buffered_thread/hierarchy_claim.rs:85
↓ 12 callersMethoderror
(&self, message: impl Into<String>)
crates/awaken-tool-pattern/src/parser.rs:91
↓ 12 callersFunctioneval_config_store
Fetch the config store required by `EvalRoutesState`. Route composition only mounts eval handlers once this module state exists, so handlers do not ca
crates/awaken-server/src/services/eval_common.rs:23
↓ 12 callersMethodexecute
(&self, args: Value, _ctx: &ToolCallContext)
crates/awaken-runtime-contract/src/contract/tool/tests.rs:119
↓ 12 callersFunctionexpectJsonObject
(label: string, response: APIResponse)
e2e/tests/api-surface.spec.ts:43
↓ 12 callersFunctionfind_compaction_boundary
Find a safe compaction boundary in the message history. Returns the index of the last message that can be safely compacted (all tool call/result pair
crates/awaken-runtime/src/context/compaction.rs:33
↓ 12 callersFunctionformatActor
(actor: string)
apps/admin-console/src/lib/audit-log.ts:49
↓ 12 callersMethodget
( &self, owner: &ProfileOwner, key: &str, )
crates/awaken-runtime-contract/src/contract/profile_store.rs:157
↓ 12 callersFunctiongoSidebar
* Navigate by clicking the sidebar link (SPA client-side nav — no full reload, * so no white "Loading…" flash and the cursor/caption layer stays aliv
e2e/tests/admin-demo.spec.ts:189
↓ 12 callersFunctionhandle_server_request
( sampling_handler: Option<&dyn SamplingHandler>, roots: &[Root], request: &JsonRpcRequest, )
crates/awaken-ext-mcp/src/transport.rs:3814
↓ 12 callersFunctionid
()
crates/awaken/tests/skill_permission_e2e.rs:199
↓ 12 callersMethodid
(&self)
crates/awaken-runtime/src/registry/resolver.rs:105
↓ 12 callersMethodinterrupt
(&self, thread_id: &str, now: u64)
crates/awaken-stores/src/memory_mailbox.rs:546
↓ 12 callersFunctionisAgentActor
(actor: string | null | undefined)
apps/admin-console/src/lib/audit-log.ts:60
↓ 12 callersFunctionis_live_mode
(mode: EvalRunExecutionMode)
crates/awaken-server/src/services/eval_run_service.rs:117
↓ 12 callersFunctionjsonResponse
(body: unknown, status = 200)
apps/admin-console/src/lib/api/config-resource.test.ts:5
↓ 12 callersFunctionkey
(scope_id: &str, kind: &str, id: &str)
crates/awaken-stores/src/memory_versioned_registry.rs:654
↓ 12 callersFunctionkey
(replay_buffers: &ReplayBufferMap)
crates/awaken-server/src/protocol_replay_state.rs:193
↓ 12 callersMethodload_state
(&self)
crates/awaken-stores/src/file_versioned_registry.rs:62
↓ 12 callersFunctionmake_app_with_tools
(llm: Arc<dyn LlmExecutor>)
crates/awaken-server/tests/protocol_ag_ui_e2e.rs:224
↓ 12 callersFunctionmake_genai_span
(model: &str, provider: &str, input: i32, output: i32)
crates/awaken-ext-observability/tests/observability_integration.rs:16
↓ 12 callersFunctionmake_outcome
(text: &str)
crates/awaken-eval/src/judge.rs:436
↓ 12 callersFunctionmake_permission_preview_app
()
crates/awaken-server/tests/config_api.rs:4682
↓ 12 callersFunctionmake_run_record
(run_id: &str, thread_id: &str, status: RunStatus)
crates/awaken-server/src/mailbox/tests.rs:8824
↓ 12 callersFunctionmake_runtime
()
crates/awaken/tests/skill_permission_e2e.rs:170
↓ 12 callersMethodproject_event
( &self, event: &CanonicalEvent, )
crates/awaken-server/src/protocol_projector.rs:90
↓ 12 callersFunctionpublish_model
( store: &InMemoryVersionedRegistryStore, id: &str, provider_id: &str, )
crates/awaken-stores/tests/registry_graph_validator.rs:360
↓ 12 callersMethodput
(&self, namespace: &str, id: &str, value: &Value)
crates/awaken-stores/src/memory/mod.rs:637
↓ 12 callersMethodput_if_revision
( &self, namespace: &str, id: &str, value: &Value, expected_revision:
crates/awaken-stores/src/memory/mod.rs:687
↓ 12 callersFunctionread_json
( path: &Path, )
crates/awaken-stores/src/file.rs:1044
↓ 12 callersFunctionrecv_inbox_event
(rx: &mut crate::inbox::InboxReceiver)
crates/awaken-runtime/src/loop_runner/compaction_tests.rs:177
↓ 12 callersMethodregistry_snapshot
(&self)
crates/awaken-runtime/src/runtime/agent_runtime/mod.rs:351
↓ 12 callersMethodreport_activity
Report an activity snapshot (full state replacement) for this tool call. Emits an [`AgentEvent::ActivitySnapshot`] with `message_id` set to this cont
crates/awaken-runtime-contract/src/contract/tool.rs:395
↓ 12 callersFunctionrun_record
(thread_id: &str, run_id: &str)
crates/awaken-stores/src/memory_commit_coordinator.rs:229
↓ 12 callersMethodscope_activation
( &self, mut request: awaken_runtime::RunActivation, )
crates/awaken-server/src/app/modules.rs:112
↓ 12 callersFunctionseed_run
Helper: seed a run record into the store.
crates/awaken-server/tests/http_api.rs:569
← previousnext →601–700 of 15,944, ranked by callers