MCPcopy Create free account

hub / github.com/AlephantAI/AIephant-AI-Agent-Gateway / functions

Functions4,673 in github.com/AlephantAI/AIephant-AI-Agent-Gateway

⨍ Functions 4,673◇ Types & classes 773↳ Endpoints 1
↓ 1,209 callersMethodclone
(&self)
ai-gateway/src/utils/timer.rs:50
↓ 522 callersMethodget
(&self, provider: &InferenceProvider)
ai-gateway/src/config/providers.rs:80
↓ 461 callersMethodclone
(&self)
ai-gateway/src/agent/tools/mcp_streamable_http/session.rs:135
↓ 240 callersMethodis_empty
(&self)
ai-gateway/src/agent/context.rs:28
↓ 237 callersMethodbuild
(app_state: AppState)
ai-gateway/src/router/meta.rs:43
↓ 215 callersMethodas_ref
(&self)
ai-gateway/src/types/router.rs:16
↓ 199 callersMethodpush
Register on rows where `ModelId::from_str_and_provider` succeeded; under the same `key`, skip if `code/model` already exists.
ai-gateway/src/discover/router/bare_model_expand_index.rs:18
↓ 172 callersMethodas_str
(self)
ai-gateway/src/x402/types.rs:13
↓ 160 callersMethodlen
Returns the number of endpoints currently tracked by the balancer.
crates/dynamic-router/src/router/mod.rs:99
↓ 154 callersMethodget
(&self, workspace_id: &str)
ai-gateway/src/agent/tools/runtime_snapshot/lkg.rs:29
↓ 137 callersFunctionbuild_test_app
(mut config: Config)
ai-gateway/src/app.rs:652
↓ 102 callersMethodheader
(mut self, name: HeaderName, value: HeaderValue)
ai-gateway/src/agent/tools/mcp_streamable_http/test_support.rs:58
↓ 101 callersMethodparse
(value: &str)
ai-gateway/src/dispatcher/regional_endpoint.rs:23
↓ 89 callersMethodconfig
(&self)
ai-gateway/src/app_state.rs:70
↓ 75 callersMethodas_ref
(&self)
ai-gateway/src/dispatcher/client.rs:305
↓ 75 callersMethodstatus
(&self)
ai-gateway/src/agent/tools/mcp_sse/lifecycle.rs:73
↓ 73 callersMethodsend
( &self, payload: &AgentEventLogPayload, )
ai-gateway/src/agent/log_transport.rs:57
↓ 68 callersMethodcall
(&mut self, req: crate::types::request::Request)
ai-gateway/src/app.rs:163
↓ 63 callersFunctionoptional_string
(value: Option<&Value>)
ai-gateway/src/agent/tool_observer.rs:1352
↓ 60 callersFunctionj
( case_id: str, tier: str, intent: str, curl: str, assertions: dict, profile: list[str
crates/gateway-e2e-harness/scripts/generate_tc_matrix.py:73
↓ 59 callersMethodstubs
(&self, stubs: HashMap<&'static str, Times>)
ai-gateway/src/tests/mock.rs:310
↓ 53 callersFunctionget_first
(mapping: dict[str, Any], names: Iterable[str], default: Any = None)
examples/agent/tools/e2e_support.py:152
↓ 52 callersMethodwith_config
(mut self, config: Config)
ai-gateway/src/tests/harness.rs:37
↓ 52 callersMethodwith_mock_args
(mut self, mock_args: MockArgs)
ai-gateway/src/tests/harness.rs:31
↓ 51 callersFunctionsleep
(latency: u32)
crates/mock-server/src/routes/mod.rs:12
↓ 47 callersFunctioncurl_d_json
Return a curl `-d '<json>'` fragment for `sh -c` + inject_curl_trailer. Use single-quoted JSON (inner double quotes). Avoid `\'` wrappers that
crates/gateway-e2e-harness/scripts/generate_tc_matrix.py:61
↓ 46 callersMethodas_str
(self)
ai-gateway/src/middleware/large_context/headers.rs:17
↓ 44 callersMethodresolve
( &self, request: TargetEndpointRequest<'_>, )
ai-gateway/src/dispatcher/target_endpoint.rs:51
↓ 42 callersMethodpath
( &self, model_id: Option<&ModelId>, is_stream: bool, )
ai-gateway/src/endpoints/mod.rs:143
↓ 42 callersMethodput
(&self, envelope: SnapshotEnvelope)
ai-gateway/src/agent/tools/runtime_snapshot/lkg.rs:40
↓ 41 callersFunctiondefault_provider_rules
(provider: &InferenceProvider)
ai-gateway/src/middleware/mapper/rule_data.rs:10
↓ 39 callersMethodcall
(&mut self, req: Request)
ai-gateway/src/agent/tools/service.rs:111
↓ 38 callersFunctionauth_context
(org_id: Uuid)
ai-gateway/src/agent/tools/service.rs:3989
↓ 38 callersMethodbody_json
(&self)
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:82
↓ 37 callersMethodclone
(&self)
crates/dynamic-router/src/router/make.rs:85
↓ 37 callersFunctionrequire
(condition: bool, message: str)
examples/agent/tools/e2e_support.py:169
↓ 35 callersFunctiondefault_non_stream_profile
(provider: &InferenceProvider)
ai-gateway/src/middleware/mapper/non_stream_profile_data.rs:7
↓ 35 callersMethodinto_sourced_events
(self)
ai-gateway/src/agent/event.rs:35
↓ 34 callersFunctionadapt_agent_event
(source: AgentEventSource, mut event: AgentEventInput)
ai-gateway/src/agent/adapter.rs:9
↓ 34 callersMethodas_str
(self)
ai-gateway/src/agent/tools/audit.rs:380
↓ 33 callersFunctioncall_request
(auth_context: AuthContext, body: serde_json::Value)
ai-gateway/src/agent/tools/service.rs:3961
↓ 32 callersFunctionconnect
(config: &DatabaseConfig)
ai-gateway/src/store/mod.rs:12
↓ 31 callersMethodas_str
(self)
ai-gateway/src/agent/event.rs:83
↓ 29 callersMethodis_empty
(&self)
ai-gateway/src/agent/tools/openapi/types.rs:24
↓ 28 callersFunctionresponse_json
(response: Response)
ai-gateway/src/agent/tools/service.rs:4304
↓ 27 callersMethodget
Resolve a `master_key_id` to its decrypted key. Fast path: cache hit → return immediately (no DB round-trip). Slow path: DB fetch → AES-256-GCM decry
ai-gateway/src/store/master_key_cache.rs:88
↓ 27 callersMethodprocess_upstream_sse_json
( &mut self, raw: &[u8], )
ai-gateway/src/ide_adapation/unified_responses_chat_compat.rs:157
↓ 25 callersFunctiontest_streamable_target
(url: &str)
ai-gateway/src/agent/tools/mcp_streamable_http/test_support.rs:235
↓ 25 callersMethodwith_mock_auth
(self)
ai-gateway/src/tests/harness.rs:54
↓ 24 callersMethodlayer
(&self, inner: S)
ai-gateway/src/utils/timer.rs:38
↓ 24 callersMethodprovider
(&self)
ai-gateway/src/endpoints/mod.rs:132
↓ 24 callersMethodredis
(&self)
ai-gateway/src/app_state.rs:82
↓ 23 callersFunctionchat_sse_frame
(value: serde_json::Value)
ai-gateway/src/agent/tool_observer.rs:1456
↓ 23 callersFunctionget_stubs_path
(provider: &str)
ai-gateway/src/tests/mock.rs:13
↓ 23 callersMethodshutdown
(self)
ai-gateway/src/tests/harness.rs:103
↓ 22 callersFunctionbuild_x402_log_message
( stage: X402LogStage, context: &X402LogContext, )
ai-gateway/src/x402/service.rs:156
↓ 22 callersMethodget
(&self, key: &str)
crates/alephant-llm-kv-cache/src/tikv.rs:50
↓ 22 callersFunctionmetadata_string
(metadata: &serde_json::Value, key: &str)
ai-gateway/src/agent/log_payload.rs:400
↓ 22 callersMethodstore
(&self, key: &str, session: &McpStreamableSession, ttl_secs: u64)
ai-gateway/src/agent/tools/mcp_streamable_http/session.rs:60
↓ 21 callersFunctionemit_x402_log_best_effort
(app_state: &AppState, mut message: X402PaymentLogMessage)
ai-gateway/src/x402/service.rs:284
↓ 21 callersMethodexpose
(&self)
ai-gateway/src/types/secret.rs:15
↓ 21 callersMethodlog
(mut self)
ai-gateway/src/logger/service.rs:703
↓ 21 callersFunctionlog_decision
Emit a structured fallback decision log when `policy.observability.emit_decision_log` is `true`. This is the **single canonical emit point** for all
ai-gateway/src/fallback/observability.rs:61
↓ 20 callersFunctionapply_error_log_fields
( message: &mut X402PaymentLogMessage, kind: impl Into<String>, error_message: impl Into<String>,
ai-gateway/src/x402/service.rs:263
↓ 20 callersFunctionjson_error_response
( status: StatusCode, message: impl Into<String>, ty: impl Into<String>, code: impl Into<Strin
ai-gateway/src/x402/service.rs:1491
↓ 19 callersMethodbuild
(self)
ai-gateway/src/tests/harness.rs:42
↓ 19 callersFunctionmerge_assert
Shallow-merge assertion dicts; nested `json` and `headers` dicts merge one level deep.
crates/gateway-e2e-harness/scripts/generate_tc_matrix.py:48
↓ 19 callersFunctiontest_context
(target: &AgentToolTargetConfig)
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:288
↓ 19 callersFunctiontest_egress_policy
()
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:277
↓ 19 callersMethodurl
(&self)
ai-gateway/src/agent/tools/mcp_streamable_http/test_support.rs:130
↓ 18 callersFunctionauth_context
(org_id: Uuid)
ai-gateway/src/agent/service.rs:1773
↓ 18 callersFunctionevent_input
()
ai-gateway/src/agent/service.rs:1865
↓ 18 callersMethodinference_provider
(&self)
ai-gateway/src/types/model_id.rs:201
↓ 18 callersMethodlayer
(&self, inner: S)
ai-gateway/src/router/router_details.rs:36
↓ 18 callersMethodpost
( self, path: str, payload: dict[str, Any], *, step_id: str, t
examples/agent/openapi/client.py:127
↓ 18 callersFunctionvalidate_target_url
( url: &str, cfg: &AgentToolEgressPolicyConfig, )
ai-gateway/src/agent/tools/egress_policy.rs:21
↓ 17 callersMethodas_str
(self)
ai-gateway/src/dispatcher/regional_endpoint.rs:16
↓ 17 callersFunctionbase_event
( event_type: str, *, agent_id: str, run_id: str, agent_name: str | None = None, metad
examples/agent/framework_common.py:149
↓ 17 callersFunctionbuild_stream_response
( id: String, model: String, choices: Vec<ChatChoiceStream>, usage: Option<CompletionUsage>, )
ai-gateway/src/middleware/mapper/stream_normalizer.rs:114
↓ 17 callersMethodemit
( self, event_type: str, *, context: AgentStepContext | None = None, s
examples/agent/langgraph/alephant_adapter.py:115
↓ 16 callersFunctionnamed_provider_config
()
ai-gateway/src/middleware/mapper/openai_compatible.rs:529
↓ 16 callersFunctionraw_string
(event: &AgentEventInput, key: &str)
ai-gateway/src/agent/adapter.rs:699
↓ 16 callersMethodset_provider_is_router_flags
(&self, flags: FxHashMap<String, bool>)
ai-gateway/src/app_state.rs:258
↓ 16 callersFunctiontest_request
()
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:267
↓ 16 callersMethodvalidate
(&self)
ai-gateway/src/config/mod.rs:361
↓ 15 callersMethod_write_response
(self, status: int, body: dict[str, Any])
examples/agent/tools/mcp_mock_server.py:43
↓ 15 callersMethodas_str
(self)
ai-gateway/src/agent/context.rs:84
↓ 15 callersFunctionhas_completion_suffix
(event_type: &str, suffix: &str)
ai-gateway/src/agent/adapter.rs:681
↓ 15 callersMethodinto_response
(self)
ai-gateway/src/error/api.rs:66
↓ 15 callersMethodload
(&self, key: &str)
ai-gateway/src/agent/tools/mcp_streamable_http/session.rs:53
↓ 14 callersMethodcall
(&mut self, req: Request)
ai-gateway/src/agent/service.rs:68
↓ 14 callersFunctionconvert
(request: CreateResponse)
ai-gateway/src/middleware/mapper/responses_to_chat_request.rs:28
↓ 14 callersFunctionenvelope_to_text
(envelope: dict[str, Any])
examples/agent/openapi/client.py:184
↓ 14 callersFunctioninvalid_prompt_inputs
(message: impl Into<String>)
ai-gateway/src/middleware/prompts/templating.rs:8
↓ 14 callersMethodis_empty
Returns whether or not the balancer is empty.
crates/dynamic-router/src/router/mod.rs:104
↓ 14 callersMethodmap_model
Map a model to a new model name for a target provider. If the source model is offered by the target provider, return the source model name. Otherwise
ai-gateway/src/middleware/mapper/model.rs:103
↓ 14 callersMethodmodel
(&self)
ai-gateway/src/endpoints/openai/mod.rs:116
↓ 14 callersFunctionrun_openai_like_nonstream_runtime_case
( case: &UnifiedApiCase, request_payload: Value, response_payload: Value, )
ai-gateway/tests/unified_api.rs:1644
↓ 13 callersFunctionconst_retry
(secs: u64)
ai-gateway/tests/fallback_retry_bridge.rs:23
↓ 13 callersFunctionexecute_tool
( target: &AgentToolTargetConfig, request: &ToolCallRequest, egress_policy: &AgentToolEgressPolicy
ai-gateway/src/agent/tools/executor.rs:109
next →1–100 of 4,673, ranked by callers