MCPcopy Create free account

hub / github.com/awakenworks/awaken / functions

Functions15,944 in github.com/awakenworks/awaken

↓ 63 callersFunctionpin
(id: &str, version: u64)
crates/awaken-server/src/services/pinned_registry.rs:284
↓ 63 callersMethodreplace
(&mut self, id: impl Into<String>, value: V)
crates/awaken-runtime/src/registry/memory.rs:70
↓ 63 callersFunctionrun_phase
Dispatch helper: invoke the appropriate phase hook sharing the plugin's inner state.
crates/awaken-ext-observability/src/plugin/tests.rs:60
↓ 63 callersMethodwith_in_memory_thread_run_store
( mut self, store: Arc<awaken_stores::InMemoryStore>, )
crates/awaken-runtime/src/builder.rs:196
↓ 62 callersMethodis_empty
(&self)
crates/awaken-ext-observability/src/composite.rs:28
↓ 62 callersFunctionmake_app
()
crates/awaken-server/tests/config_api.rs:652
↓ 62 callersMethodrun_phase_with_context
( &self, env: &ExecutionEnv, ctx: PhaseContext, )
crates/awaken-runtime/src/phase/engine.rs:67
↓ 62 callersMethodwith_tool_info
( mut self, name: impl Into<String>, call_id: impl Into<String>, args: Option<
crates/awaken-runtime/src/hooks/context.rs:146
↓ 60 callersMethodget
(&self, session_id: &str)
crates/awaken-server/src/protocols/mcp/http.rs:48
↓ 60 callersMethodget
( &self, scope_id: &str, kind: &str, id: &str, version: u64, )
crates/awaken-server/tests/run_api.rs:73
↓ 60 callersFunctionmake_test_app
()
crates/awaken-server/tests/http_api.rs:384
↓ 59 callersMethodis_empty
(&self)
crates/awaken-ext-skills/src/registry.rs:33
↓ 59 callersMethodis_empty
(&self)
crates/awaken-stores/tests/adr0036_mandatory.rs:59
↓ 59 callersMethodremove
(&self, session_id: &str)
crates/awaken-server/src/protocols/mcp/http.rs:52
↓ 58 callersMethodclear
Delete all entries for a key.
crates/awaken-runtime/src/profile/mod.rs:75
↓ 58 callersFunctionempty_snapshot
()
crates/awaken-ext-observability/src/lib_test.rs:12
↓ 58 callersFunctionmakeReport
(overrides: Partial<ReplayReport> = {})
apps/admin-console/src/lib/eval-reports.test.ts:20
↓ 58 callersFunctionrun_phase
Dispatch helper: invoke the appropriate phase hook sharing the plugin's inner state.
crates/awaken-ext-observability/src/lib_test.rs:17
↓ 56 callersMethodexecute
(&self, args: Value, ctx: &ToolCallContext)
crates/awaken-ext-skills/src/tools.rs:115
↓ 56 callersMethodget_mut
(&mut self)
crates/awaken-runtime-contract/src/state/slot.rs:80
↓ 56 callersFunctionmake_encoder_with_run
(thread_id: &str, run_id: &str)
crates/awaken-server/tests/protocol_ag_ui.rs:22
↓ 55 callersFunctionC
caption pair shorthand
e2e/tests/admin-demo.spec.ts:44
↓ 55 callersMethodbegin_mutation
(&self)
crates/awaken-runtime/src/state/store.rs:74
↓ 55 callersFunctionempty_snapshot
()
crates/awaken-ext-observability/src/plugin/tests.rs:25
↓ 55 callersFunctionmerge_agent_spec
Apply a [`AgentSpecPatch`] on top of a base [`AgentSpec`], producing the effective spec passed to the resolver. Semantics: - Scalar fields (`model_id
crates/awaken-runtime-contract/src/agent_spec_patch.rs:208
↓ 55 callersMethodtry_send
Try to send a message without invoking the closed-channel fallback. Runtime control paths use this when the caller owns fallback policy itself, for e
crates/awaken-runtime/src/inbox.rs:79
↓ 55 callersFunctionupsert
( states: &mut ToolCallStateMap, call_id: &str, tool: &str, status: ToolCallSt
crates/awaken-runtime/src/agent/state/tool_call_lifecycle.rs:148
↓ 54 callersMethodapply
(&self)
crates/awaken-server/src/services/config_runtime.rs:727
↓ 54 callersMethodemit
Emit a custom event to the owner agent. The event is delivered to the agent's inbox and drained at step boundaries or when the agent is waiting for b
crates/awaken-runtime/src/extensions/background/types.rs:118
↓ 54 callersMethodget
( &self, namespace: &str, id: &str, )
crates/awaken-stores/src/postgres/config.rs:32
↓ 54 callersMethodrecord
(&self, event: &MetricsEvent)
crates/awaken-server/tests/agent_dashboard_e2e.rs:95
↓ 53 callersMethodenqueue
(&self, dispatch: &RunDispatch)
crates/awaken-stores/src/nats_mailbox/mod.rs:377
↓ 53 callersFunctionensure_admin_auth
( admin: &AdminModuleState, headers: &HeaderMap, )
crates/awaken-server/src/config_routes.rs:766
↓ 53 callersFunctionmake_dispatch
(thread_id: &str, agent_id: &str)
crates/awaken-stores/src/memory_mailbox/tests.rs:5
↓ 53 callersFunctionvalidate_id
── Filesystem helpers ──────────────────────────────────────────────
crates/awaken-stores/src/file.rs:596
↓ 52 callersMethodis_empty
(self)
crates/awaken-runtime-contract/src/contract/storage.rs:108
↓ 52 callersFunctionrequest_json
( app: &axum::Router, method: &str, uri: &str, headers: &[(&str, &str)], body: Option<Valu
crates/awaken-server/tests/a2a_http.rs:293
↓ 51 callersMethodcreate_run
(&self, record: &RunRecord)
crates/awaken-stores/tests/fault_injection.rs:92
↓ 51 callersMethoddrain
Drain all currently buffered messages into a `Vec`.
crates/awaken-runtime/src/inbox.rs:128
↓ 51 callersMethodexecute
(&self, args: Value, ctx: &ToolCallContext)
crates/awaken-ext-mcp/src/manager.rs:218
↓ 51 callersMethodlen
(&self)
crates/awaken-ext-mcp/src/manager.rs:2627
↓ 51 callersMethodload_thread
(&self, thread_id: &str)
crates/awaken-stores/tests/fault_injection.rs:46
↓ 51 callersFunctionmanager_with_store
Create a manager with a StateStore wired up (keys registered).
crates/awaken-runtime/src/extensions/background/tests.rs:24
↓ 51 callersMethodset
(&self, resolver: Arc<dyn AgentResolver>)
examples/src/starter_backend/generative_ui_tools.rs:18
↓ 50 callersMethodids
(&self)
crates/awaken-ext-mcp/src/manager.rs:2639
↓ 50 callersMethodkey
(&self)
crates/awaken-ext-permission/src/rules.rs:74
↓ 50 callersMethodwith_parameters
(mut self, schema: Value)
crates/awaken-runtime-contract/src/contract/tool.rs:334
↓ 49 callersMethodemit
Record an audit event. Best-effort: failures emit a warning and increment the write-failure metric but are never propagated to callers.
crates/awaken-server/src/services/audit_log.rs:92
↓ 48 callersMethodappend
( &self, draft: CanonicalEventDraft, options: AppendOptions, )
crates/awaken-stores/src/postgres_event.rs:208
↓ 48 callersFunctionbuild_registries
( tools: Vec<(&str, Arc<dyn Tool>)>, model_id: &str, model_spec: ModelSpec, provider_id: &str,
crates/awaken-runtime/src/registry/resolve/pipeline/tests.rs:176
↓ 48 callersMethodexists
(&self, namespace: &str, id: &str)
crates/awaken-server-contract/src/contract/config_store.rs:232
↓ 48 callersMethodremove
(&mut self, id: &str)
crates/awaken-runtime/src/registry/memory.rs:74
↓ 48 callersFunctiontest_dispatch
(id: &str, thread_id: &str)
crates/awaken-stores/tests/nats_mailbox_behavior.rs:16
↓ 47 callersFunctionrenderEditorRoute
(path = "/agents/new")
apps/admin-console/src/pages/agent-editor-page.test.tsx:88
↓ 47 callersMethodwith_model
(self, model: impl Into<String>)
crates/awaken-ext-observability/src/plugin/plugin.rs:59
↓ 46 callersFunctionget
(app: axum::Router, uri: &str)
crates/awaken-server/src/event_routes.rs:346
↓ 46 callersFunctionmake_dispatch
Construct a `RunDispatch` with sensible defaults for conformance tests.
crates/awaken-stores/tests/mailbox_conformance.rs:21
↓ 44 callersMethodall
Slice over all public namespace variants.
crates/awaken-server/src/services/config_service.rs:63
↓ 44 callersMethoddelete
Delete a typed entry.
crates/awaken-runtime/src/profile/mod.rs:64
↓ 44 callersMethodremove
(&mut self, key: &str)
crates/awaken-ext-observability/src/otel.rs:114
↓ 44 callersMethodrun_phase
( &self, env: &ExecutionEnv, phase: Phase, )
crates/awaken-runtime/src/phase/engine.rs:58
↓ 43 callersFunctionget_json
(app: axum::Router, uri: &str)
crates/awaken-server/tests/http_api.rs:431
↓ 43 callersFunctionparse_skill_md
Parse a SKILL.md (frontmatter + markdown body).
crates/awaken-ext-skills/src/skill_md.rs:144
↓ 43 callersMethodread
Read a typed value. Returns `K::Value::default()` if the entry is missing. - `K::KEY` is the namespace (which data type) - `key` is the dynamic ident
crates/awaken-runtime/src/profile/mod.rs:43
↓ 43 callersMethodrecord
(&self, event: &MetricsEvent)
crates/awaken-ext-observability/src/trace_store/sink.rs:34
↓ 43 callersFunctionrun
(args: Vec<String>)
crates/awaken-eval/src/bin/awaken-eval/main.rs:41
↓ 42 callersMethodcancelled
Wait until cancellation is requested. Use this for tasks that do their work, emit a result, then park themselves until killed: ```ignore |ctx| async
crates/awaken-runtime/src/extensions/background/types.rs:145
↓ 42 callersFunctionevaluate_tool_permission
( ruleset: &PermissionRuleset, tool_id: &str, tool_args: &Value, )
crates/awaken-ext-permission/src/rules.rs:349
↓ 42 callersMethodis_empty
(&self)
crates/awaken-ext-mcp/src/manager.rs:2631
↓ 42 callersMethodload
Load a fixture from a JSON file on disk.
crates/awaken-eval/src/fixture.rs:141
↓ 42 callersFunctionmake_encoder_with_run
(thread_id: &str, run_id: &str)
crates/awaken-server/tests/protocol_ai_sdk.rs:19
↓ 42 callersMethodscoped
(&self, scope: &ScopeContext)
crates/awaken-server/src/app/modules.rs:338
↓ 42 callersFunctiontr
(pair: { en: string; zh: string })
e2e/tests/demo-helpers.ts:62
↓ 41 callersMethoderror
Create an error result. # Examples ``` use awaken_runtime_contract::contract::tool::ToolResult; let result = ToolResult::error("calc", "division by
crates/awaken-runtime-contract/src/contract/tool.rs:112
↓ 41 callersMethodload
(run_store: &dyn ThreadRunStore, thread_id: &str)
crates/awaken-server/src/mailbox.rs:595
↓ 41 callersMethodload_run
( &self, id: &str, )
crates/awaken-server/src/mailbox/checkpoint.rs:318
↓ 41 callersFunctionread_lock
(lock: &RwLock<T>)
crates/awaken-ext-mcp/src/manager.rs:658
↓ 40 callersMethodapply_seed
Apply a built-in spec seed to the underlying ConfigStore. Idempotent and version-aware. See [`apply_builtin_seed`](crate::services::builtin_seed::app
crates/awaken-server/src/services/config_runtime.rs:658
↓ 40 callersMethodmessages
(&self)
crates/awaken-runtime/src/run.rs:148
↓ 40 callersMethodremove
(&mut self, dispatch_id: &str)
crates/awaken-stores/src/nats_mailbox/index.rs:71
↓ 40 callersFunctionvalidate_run_inputs
Validate and normalize run request inputs. Checks that messages are non-empty, trims/generates thread_id. Returns `(thread_id, messages)`. Internal v
crates/awaken-server/src/mailbox/helpers.rs:83
↓ 39 callersFunctionattr_str
Extract a string attribute from a Phoenix span JSON payload. Phoenix wraps OTel attributes under `attributes.{key}` (flat dotted keys), `attributes.<
e2e/phoenix/test-helpers/src/lib.rs:190
↓ 39 callersMethodcommit
(self: Box<Self>)
crates/awaken-server/tests/config_api.rs:432
↓ 39 callersMethodenqueue
(&self, dispatch: &RunDispatch)
crates/awaken-server/src/mailbox/tests.rs:216
↓ 39 callersFunctioninbox_channel
Create a new `(InboxSender, InboxReceiver)` pair.
crates/awaken-runtime/src/inbox.rs:214
↓ 39 callersFunctionmake_registry_with_skills
(skill_data: &[EmbeddedSkillData])
crates/awaken-ext-skills/tests/tool_state_tests.rs:64
↓ 39 callersMethodread
(&self, run_id: &str)
crates/awaken-ext-observability/src/trace_store/file.rs:246
↓ 39 callersMethodrecord_failure
Record a failed request to `model`, potentially opening the circuit.
crates/awaken-runtime/src/engine/circuit_breaker.rs:146
↓ 39 callersFunctionredactSecretsForDisplay
(value: T)
apps/admin-console/src/lib/agent-secret-redaction.ts:205
↓ 38 callersFunctioncfg
(name: &str)
crates/awaken-ext-mcp/tests/mcp_tests.rs:34
↓ 38 callersMethodcreate_with_headers
( &self, namespace: ConfigNamespace, body: Value, headers: &HeaderMap, )
crates/awaken-server/src/services/config_service.rs:526
↓ 38 callersMethodinsert
(&self, session: Arc<McpHttpSession>)
crates/awaken-server/src/protocols/mcp/http.rs:41
↓ 38 callersFunctionmake_runtime
()
crates/awaken-server/src/mailbox/tests.rs:955
↓ 38 callersFunctionoutcome
(metrics: AgentMetrics, text: &str)
crates/awaken-eval/src/score_test.rs:70
↓ 38 callersMethodreduce
(&mut self, action: CompactionAction)
crates/awaken-runtime/src/context/plugin/compaction.rs:206
↓ 38 callersMethodregister_model
Register a `ModelSpec`, extracting the id from `spec.id`. This is the single registration chokepoint for every entry point (`AgentRuntimeBuilder::wit
crates/awaken-runtime/src/registry/memory.rs:191
↓ 38 callersMethodto_value
(&self)
crates/awaken-server/src/mailbox.rs:131
↓ 37 callersMethodbuild
( &self, endpoint: &RemoteEndpoint, )
crates/awaken-server/tests/run_api.rs:388
↓ 37 callersMethodclone
(&self)
crates/awaken-runtime-contract/src/secret.rs:65
↓ 37 callersFunctionp
(search: string)
apps/admin-console/src/lib/list-url-state.test.ts:29
← previousnext →101–200 of 15,944, ranked by callers