Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/awakenworks/awaken
/ functions
Functions
15,944 in github.com/awakenworks/awaken
⨍
Functions
15,944
◇
Types & classes
2,546
↓ 10 callers
Function
field_rule
(name: &str, field: &str, op: MatchOp, value: &str)
crates/awaken-tool-pattern/src/matcher.rs:314
↓ 10 callers
Function
filterFixtures
( reports: ReplayReport[], filter: FixtureFilterState, diffs: Map<string, DiffEntry> = new Map(), )
apps/admin-console/src/lib/eval-reports-filter.ts:24
↓ 10 callers
Method
finish_execution
(self: &Arc<Self>, thread_id: &str, dispatch_id: &str)
crates/awaken-server/src/mailbox/signal_loop.rs:401
↓ 10 callers
Function
formatWindow
(seconds: number)
apps/admin-console/src/lib/agent-stats.ts:227
↓ 10 callers
Function
format_sse_data
Format an agent event as an SSE `data:` line.
crates/awaken-server/src/http_sse.rs:63
↓ 10 callers
Method
get_agent
(&self, id: &str)
crates/awaken-runtime/src/registry/composite.rs:359
↓ 10 callers
Function
get_audit_log
(app: &axum::Router, qs: &str)
crates/awaken-server/tests/restore_routes.rs:196
↓ 10 callers
Method
ids
(&self)
crates/awaken-runtime/src/registry/memory.rs:78
↓ 10 callers
Function
inc_mailbox_operation_by
Increment a mailbox lifecycle/store operation by count.
crates/awaken-server/src/metrics.rs:100
↓ 10 callers
Function
isRecord
(value: unknown)
examples/ai-sdk-starter/src/components/tools/generative-ui-renderers.tsx:90
↓ 10 callers
Function
jsonResponse
(body: unknown, status = 200)
apps/admin-console/src/lib/agent-stats.test.ts:63
↓ 10 callers
Method
latest_run
( &self, thread_id: &str, )
crates/awaken-server/src/mailbox/checkpoint.rs:325
↓ 10 callers
Method
latest_run
(&self, _thread_id: &str)
crates/awaken-runtime/src/backend/mod.rs:901
↓ 10 callers
Function
load_directory
Load every `*.json` file in `dir` as a [`Fixture`], returning them sorted by `id` for deterministic iteration. Files are skipped silently when their
crates/awaken-eval/src/fixture.rs:269
↓ 10 callers
Method
load_pending_message_records
( &self, thread_id: &str, )
crates/awaken-server/src/mailbox/pending_delivery_tests.rs:123
↓ 10 callers
Function
load_task_snapshot
( st: &ProtocolRoutesState, task_id: &str, tenant: Option<&str>, history_length: usize, in
crates/awaken-server/src/protocols/a2a/task.rs:370
↓ 10 callers
Function
make_ctx_with_sink
()
crates/awaken-runtime-contract/src/contract/tool/tests.rs:716
↓ 10 callers
Function
make_fs_skills
()
crates/awaken-ext-skills/tests/skills_integration.rs:43
↓ 10 callers
Function
make_registry_set
(agent_id: &str)
crates/awaken-runtime/src/registry/snapshot.rs:126
↓ 10 callers
Function
make_skills
()
crates/awaken-ext-skills/src/plugin/tests.rs:18
↓ 10 callers
Method
mark_finished
Marks the stream as finished. Subsequent calls to `is_finished` return `true`.
crates/awaken-server/src/protocols/shared.rs:29
↓ 10 callers
Function
mk_run
(id: &str, thread: &str)
crates/awaken-stores/tests/nats_buffered_thread_behavior.rs:103
↓ 10 callers
Function
normalizePreviewAgent
(draft: AgentSpec)
apps/admin-console/src/components/agent-preview-panel.tsx:1145
↓ 10 callers
Function
normalize_pending_positions
(pending: &mut [PendingMessageRecord])
crates/awaken-stores/src/memory/pending.rs:22
↓ 10 callers
Function
normalize_relative_path
(p: &str)
crates/awaken-ext-skills/src/materialize.rs:289
↓ 10 callers
Function
parse_json_rpc_message
(value: Value)
crates/awaken-ext-mcp/src/transport.rs:3728
↓ 10 callers
Function
pluginConfigEntryKey
(pluginId: string, schemaKey: string)
apps/admin-console/src/lib/plugin-config.ts:86
↓ 10 callers
Function
pool_home_fails
( home_key: &str, n: usize, home_behavior: Behavior, switch: PoolSwitchPolicy, breaker: Ar
crates/awaken-runtime/src/engine/pool_executor_test_support.rs:200
↓ 10 callers
Method
priority
(&self)
crates/awaken-server-contract/src/contract/mailbox.rs:334
↓ 10 callers
Method
publish_resources_and_create_publication
( &self, scope_id: &str, publication_id: &str, resources: Vec<RegistryResource
crates/awaken-stores/src/file_versioned_registry.rs:262
↓ 10 callers
Function
read_meta
Read the full hot-meta record (thread_seq watermark + JS seq).
crates/awaken-stores/src/nats_buffered_thread/hot_meta.rs:205
↓ 10 callers
Function
reasoningEffortValue
( mode: ReasoningEffortMode, )
apps/admin-console/src/lib/reasoning-effort.ts:35
↓ 10 callers
Method
record
(&self, event: &MetricsEvent)
crates/awaken-ext-observability/src/composite.rs:50
↓ 10 callers
Method
register_provider_with_signature_and_capability_source
( &mut self, id: impl Into<String>, executor: Arc<dyn LlmExecutor>, signature:
crates/awaken-runtime/src/registry/memory.rs:247
↓ 10 callers
Method
registry_set
(&self)
crates/awaken-runtime/src/runtime/agent_runtime/mod.rs:359
↓ 10 callers
Method
remove
(&mut self)
crates/awaken-runtime-contract/src/state/slot.rs:88
↓ 10 callers
Function
request_text
( app: &axum::Router, method: &str, uri: &str, headers: &[(&str, &str)], body: Option<Valu
crates/awaken-server/tests/a2a_http.rs:331
↓ 10 callers
Function
require_optional_non_empty
(field: &str, value: Option<&str>)
crates/awaken-runtime-contract/src/contract/run.rs:42
↓ 10 callers
Method
require_status
( &self, expected: RunDispatchStatus, transition: &str, )
crates/awaken-server-contract/src/contract/mailbox.rs:651
↓ 10 callers
Method
restore_persisted
( &self, persisted: PersistedState, unknown_policy: UnknownKeyPolicy, )
crates/awaken-runtime/src/state/persistence.rs:55
↓ 10 callers
Method
runtime_manager
( &self, )
crates/awaken-server/src/services/config_service/storage.rs:13
↓ 10 callers
Function
sample_run_record
()
crates/awaken-runtime-contract/src/contract/commit_coordinator.rs:374
↓ 10 callers
Function
sc
(scene: string, image: string, caption?: string)
e2e/demo-video/src/highlight.spec.ts:6
↓ 10 callers
Function
scoped_key
(scope_id: &ScopeId, value: &str)
crates/awaken-server-contract/src/contract/scope.rs:93
↓ 10 callers
Function
seed_provider_and_model
(router: &axum::Router)
crates/awaken-server/tests/config_api.rs:4782
↓ 10 callers
Function
send
(payload)
examples/shared/mcp-ui-demo-server.py:52
↓ 10 callers
Function
serve
(state: ServerState)
crates/awaken-server/src/app.rs:716
↓ 10 callers
Method
set_run_resolver
(&self, resolver: Arc<dyn Resolver>)
crates/awaken-runtime/src/runtime/agent_runtime/mod.rs:193
↓ 10 callers
Function
stage_delete
(target: PathBuf)
crates/awaken-stores/src/file.rs:918
↓ 10 callers
Method
storage_query
Build a storage-level message query.
crates/awaken-server/src/query.rs:107
↓ 10 callers
Function
supported_adapters
Canonical list of provider adapter identifiers supported by the runtime. Computed by probing each candidate name through [`AdapterKind::from_lower_st
crates/awaken-server/src/services/config_runtime.rs:1422
↓ 10 callers
Function
test_broker
()
crates/awaken-server/src/services/config_runtime/credential_tests.rs:35
↓ 10 callers
Function
tokenFailure
()
apps/admin-console/src/lib/eval-reports.test.ts:53
↓ 10 callers
Function
try_consume_compaction_event
Detect and handle a context-compaction event arriving via the inbox. Returns `true` when `payload` was a compaction event — in that case the caller M
crates/awaken-runtime/src/context/compaction.rs:226
↓ 10 callers
Function
unique_model
()
crates/awaken-server/tests/phoenix_observability_e2e.rs:227
↓ 10 callers
Method
updated_at
(&self)
crates/awaken-server-contract/src/contract/mailbox.rs:424
↓ 10 callers
Function
useConfirmDialog
()
apps/admin-console/src/components/confirm-dialog.tsx:129
↓ 10 callers
Method
validate
Pre-commit validation that mirrors the runtime invariants.
crates/awaken-runtime-contract/src/contract/commit_coordinator.rs:193
↓ 10 callers
Function
validate_agent_spec_patch
Validate and decode an `AgentSpecPatch`. Unknown fields are rejected by `AgentSpecPatch`'s serde definition.
crates/awaken-runtime-contract/src/config_validation/mod.rs:125
↓ 10 callers
Function
validate_model_pool_spec
Validate and decode a `ModelPoolSpec` from JSON for config write surfaces. Rejects unknown fields, then delegates every semantic rule to [`validate_m
crates/awaken-runtime-contract/src/config_validation/mod.rs:513
↓ 10 callers
Function
validate_pending_message_record
( record: &PendingMessageRecord, )
crates/awaken-stores/src/pending_message_store.rs:9
↓ 10 callers
Function
validate_resource_identity
( scope_id: &str, kind: &str, id: &str, )
crates/awaken-stores/src/file_versioned_registry.rs:504
↓ 10 callers
Function
withQueryClient
(children: ReactNode)
apps/admin-console/src/test/query.tsx:12
↓ 10 callers
Method
with_decisions
(mut self, decisions: Vec<(String, ToolCallResume)>)
crates/awaken-runtime/src/run.rs:199
↓ 10 callers
Method
with_in_memory_thread_run_store
(self, store: Arc<awaken_stores::InMemoryStore>)
crates/awaken-runtime/src/runtime/agent_runtime/commit.rs:31
↓ 10 callers
Method
with_live_executor
( mut self, executor: Arc<dyn LlmExecutor>, upstream_model: impl Into<String>, )
crates/awaken-eval/src/runtime_replayer.rs:220
↓ 10 callers
Method
with_model_id
(mut self, model_id: impl Into<String>)
crates/awaken-runtime-contract/src/registry_spec/mod.rs:1040
↓ 10 callers
Method
with_tools
(mut self, tools: Vec<Arc<dyn Tool>>)
crates/awaken-runtime/src/registry/resolver.rs:157
↓ 10 callers
Function
write_http_response
(stream: &mut TcpStream, response: HttpResponseSpec)
crates/awaken-ext-mcp/tests/mcp_tests.rs:501
↓ 9 callers
Method
__test_flush_committed_thread_seqs
( &self, thread_id: &str, thread_seqs: &[u64], )
crates/awaken-stores/src/nats_buffered_thread/mod.rs:507
↓ 9 callers
Method
abort
(reason: impl Into<String>)
crates/awaken-server/src/protocols/ai_sdk_v6/types.rs:441
↓ 9 callers
Function
add_by_path
(target: &mut Value, path: &str, value: Value)
crates/awaken-ext-generative-ui/src/json_render.rs:193
↓ 9 callers
Method
add_hook
(&self, hook: H)
crates/awaken-runtime/src/state/store.rs:67
↓ 9 callers
Function
appRoutes
()
apps/admin-console/src/app.tsx:118
↓ 9 callers
Method
apply_locked
(&self)
crates/awaken-server/src/services/config_runtime.rs:741
↓ 9 callers
Function
build_access
()
crates/awaken-runtime/tests/shared_state_integration.rs:56
↓ 9 callers
Function
build_app
(runtime_stats: Option<Arc<RuntimeStatsRegistry>>)
crates/awaken-server/tests/agent_runtime_stats.rs:53
↓ 9 callers
Function
capabilitiesFromResult
( result?: CapabilitiesResult | Capabilities | null, )
apps/admin-console/src/lib/api/capabilities.ts:33
↓ 9 callers
Function
collect_args_conditional_rules
`callable_tools` is the set of tool ids the model could actually invoke at runtime — i.e. `effective_tools = candidate_tools ∖ unconditionally_denied`
crates/awaken-server/src/services/permission_preview.rs:237
↓ 9 callers
Function
configUrl
(namespace: string, id?: string)
apps/admin-console/src/lib/api/http.ts:139
↓ 9 callers
Method
context_policy
(&self)
crates/awaken-runtime/src/registry/resolver.rs:121
↓ 9 callers
Method
create_run
(&self, record: &RunRecord)
crates/awaken-server-contract/src/contract/store_traits_tests.rs:549
↓ 9 callers
Function
cursorAt
(tl: Timeline, frame: number)
e2e/demo-video/src/camera.ts:155
↓ 9 callers
Function
default_scope
()
crates/awaken-ext-permission/src/config.rs:50
↓ 9 callers
Method
delete_with_options
( &self, namespace: ConfigNamespace, id: &str, force: bool, headers: &
crates/awaken-server/src/services/config_service.rs:627
↓ 9 callers
Method
deliver_live
( &self, thread_id: &str, cmd: LiveRunCommand, )
crates/awaken-stores/src/memory_mailbox.rs:781
↓ 9 callers
Method
descriptor
(&self)
crates/awaken-runtime-contract/src/contract/tool/tests.rs:115
↓ 9 callers
Function
empty_spec
()
crates/awaken-runtime/src/registry/resolve/pipeline/catalog.rs:183
↓ 9 callers
Function
enqueue
(store: &StateStore, id: &str, route: OutboxRoute)
crates/awaken-runtime/src/extensions/background/send_message_tool.rs:722
↓ 9 callers
Method
evaluate
(&self, _stats: &StopPolicyStats)
crates/awaken/tests/agent_loop.rs:4848
↓ 9 callers
Function
filterBySearch
( items: T[], query: string, selector: SearchSelector<T>, )
apps/admin-console/src/lib/list-view.ts:22
↓ 9 callers
Method
get
(&self, ns: &str, id: &str)
crates/awaken-server/src/services/audit_log.rs:573
↓ 9 callers
Method
getItem
(key: string)
apps/admin-console/src/lib/admin-token.ts:4
↓ 9 callers
Function
getMcpUiContent
(output: unknown)
examples/ai-sdk-starter/src/components/tools/mcp-app-frame.tsx:9
↓ 9 callers
Method
get_agent
(&self, id: &str)
crates/awaken-runtime/src/registry/memory.rs:414
↓ 9 callers
Method
get_or_insert
(&mut self, key: &str)
crates/awaken-runtime/src/registry/resolve/pool.rs:153
↓ 9 callers
Function
hasRenderableContent
(message: UIMessage)
apps/admin-console/src/components/agent-preview-panel.tsx:1091
↓ 9 callers
Method
is_empty
(&self)
crates/awaken-tool-pattern/src/parser.rs:51
↓ 9 callers
Method
is_match
(&self)
crates/awaken-tool-pattern/src/types.rs:268
↓ 9 callers
Method
list
(&self, owner: &ProfileOwner)
crates/awaken-stores/src/file.rs:1464
← previous
next →
801–900 of 15,944, ranked by callers