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
↓ 3 callersFunctionmerge_prompt_cache_messages_into_body
When `Alephant-Prompt-ID` is present (trimmed non-empty), merge Redis `prompt:cache:*` template `messages` into the JSON body (and apply `inputs`-styl
ai-gateway/src/content_filter/prompt_cache.rs:224
↓ 3 callersFunctionmerge_s_dash_3_into_s3
[`config::Environment`] with [`config::Case::Kebab`] maps the `S3` segment to the JSON key `s-3`. After [`merge`] with defaults / YAML `s3`, both keys
ai-gateway/src/config/mod.rs:183
↓ 3 callersFunctionmerge_x_dash_402_into_x402
[`config::Environment`] with [`config::Case::Kebab`] maps the `X402` segment to the JSON key `x-402`. Fold that env-derived key into the canonical YAM
ai-gateway/src/config/mod.rs:203
↓ 3 callersFunctionmetadata_i32
(metadata: &serde_json::Value, key: &str)
ai-gateway/src/agent/policy.rs:376
↓ 3 callersFunctionmetadata_i64
(metadata: &serde_json::Value, key: &str)
ai-gateway/src/agent/policy.rs:372
↓ 3 callersFunctionmime_from_data_uri
(uri: &str)
ai-gateway/src/middleware/mapper/mod.rs:488
↓ 3 callersFunctionmodel_access_allowed
( request_model: &str, allowed_models: Option<&[String]>, blocked_models: Option<&[String]>, )
ai-gateway/src/virtual_key/model_policy.rs:10
↓ 3 callersFunctionmodel_ids_from_config_json
(v: &Value)
ai-gateway/src/default_model/resolve.rs:29
↓ 3 callersFunctionmodel_interaction_type_from_info
(info: Option<&serde_json::Value>)
ai-gateway/src/default_model/choose.rs:325
↓ 3 callersFunctionmodel_weighted
()
ai-gateway/tests/weighted_balance.rs:487
↓ 3 callersFunctionmoney_fields
(price: Option<&Money>)
ai-gateway/src/x402/service.rs:1445
↓ 3 callersFunctionnon_empty
(value: String)
ai-gateway/src/agent/tools/openapi/executor.rs:620
↓ 3 callersFunctionnon_empty_string_ids
(a: Value)
ai-gateway/src/default_model/resolve.rs:17
↓ 3 callersFunctionnonempty_string_opt
(s: &str)
ai-gateway/src/logger/service.rs:56
↓ 3 callersFunctionnonempty_trimmed
(value: Option<&str>)
ai-gateway/src/agent/name.rs:82
↓ 3 callersFunctionnormalize_endpoint_type
(value: Option<String>)
ai-gateway/src/x402/snapshot.rs:65
↓ 3 callersFunctionnormalize_model
(raw_model: str | None)
scripts/mock_openai_8011.py:46
↓ 3 callersFunctionnormalize_responses_for_target
( source_endpoint: &ApiEndpoint, target_endpoint: &ApiEndpoint, body: Bytes, profile: ClientPr
ai-gateway/src/ide_adapation/responses_strategy.rs:15
↓ 3 callersFunctionnormalize_tool_calls
( tool_calls: Vec<ChatCompletionMessageToolCall>, )
ai-gateway/src/middleware/mapper/response_normalizer.rs:29
↓ 3 callersFunctionnormalize_unified_passthrough_body_model
( body: &Bytes, target_provider: InferenceProvider, )
ai-gateway/src/middleware/mapper/service.rs:646
↓ 3 callersFunctionobserve_responses_stream_mcp_call_from_item
( request_id: uuid::Uuid, event: &Value, item: &Value, event_type: &'static str, kind: Obs
ai-gateway/src/agent/tool_observer.rs:910
↓ 3 callersFunctionobserved_chat_stream_tool_call_envelope
( ctx: &AgentContext, observed: &ObservedChatCompletionStreamToolCall, request_id: Uuid, provi
ai-gateway/src/logger/service.rs:227
↓ 3 callersFunctionobserved_responses_stream_item_envelope
( ctx: &AgentContext, observed: &ObservedResponsesStreamItem, request_id: Uuid, provider: &str
ai-gateway/src/logger/service.rs:398
↓ 3 callersFunctionobserved_tool_call_envelope
( ctx: &AgentContext, observed: &ObservedToolCall, request_id: Uuid, provider: &str, model
ai-gateway/src/logger/service.rs:143
↓ 3 callersFunctionopenapi_operation_id
(target: &AgentToolTargetConfig)
ai-gateway/src/agent/tools/service.rs:1067
↓ 3 callersFunctionopenapi_operation_slug
(target: &AgentToolTargetConfig)
ai-gateway/src/agent/tools/service.rs:1074
↓ 3 callersFunctionopenapi_response_with_output
( target: &RuntimeOpenApiTarget, request: &ToolCallRequest, options: &OpenApiExecutionOptions,
ai-gateway/src/agent/tools/openapi/executor.rs:529
↓ 3 callersFunctionopenapi_service_slug
(target: &AgentToolTargetConfig)
ai-gateway/src/agent/tools/service.rs:1060
↓ 3 callersFunctionopenapi_target_revision
(request: &ToolCallRequest)
ai-gateway/src/agent/tools/service.rs:1051
↓ 3 callersFunctionparse_args
(argv: list[str])
scripts/provider_mock/mock_native_anthropic_base.py:253
↓ 3 callersFunctionparse_header_string
( headers: &HeaderMap, key: &str, )
ai-gateway/src/session_headers.rs:21
↓ 3 callersFunctionparse_snapshot_json
(raw: &str)
ai-gateway/src/x402/snapshot.rs:61
↓ 3 callersFunctionpick_best_scored_gateway_model
( scored: &[ScoredGatewayModel], excluded_provider_code: Option<&str>, )
ai-gateway/src/default_model/choose.rs:252
↓ 3 callersMethodpoll
(self: Pin<&mut Self>, cx: &mut Context<'_>)
ai-gateway/src/utils/retry.rs:132
↓ 3 callersFunctionpost_json_rpc
( client: &reqwest::Client, url: &str, body: &T, )
ai-gateway/src/agent/tools/mcp_sse/lifecycle.rs:413
↓ 3 callersFunctionpost_json_rpc
( client: &reqwest::Client, url: url::Url, body: &T, session_id: Option<&str>, protocol_ve
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:1102
↓ 3 callersFunctionpreserve_original_field
( obj: &mut serde_json::Map<String, serde_json::Value>, source_key: &str, original_key: &str, )
ai-gateway/src/agent/service.rs:188
↓ 3 callersFunctionprint_log_fields_summary
(scenario: &str, out: &(String, String, u16, String))
ai-gateway/examples/cloud_log_bodies_real_storage.rs:408
↓ 3 callersFunctionprofile_from_str
(s: &str)
ai-gateway/src/ide_adapation/client_profile.rs:141
↓ 3 callersMethodprovider_skips_model_mapping_catalog
(&self, provider: &InferenceProvider)
ai-gateway/src/app_state.rs:272
↓ 3 callersMethodproviders
(&self)
ai-gateway/src/config/balance.rs:121
↓ 3 callersFunctionput_sse_record
(buf: &mut BytesMut, payload: &[u8])
ai-gateway/src/ide_adapation/unified_responses_chat_compat.rs:80
↓ 3 callersFunctionread_bucket
Parallel read with 2s budget. Any backend error → `None` (MISS). Any empty slot → `None`. All full → random slot.
crates/alephant-llm-kv-cache/src/bucket.rs:12
↓ 3 callersFunctionread_jsonl
(path: Path)
examples/agent/tools/e2e_support.py:93
↓ 3 callersMethodreceive_request
(self)
ai-gateway/src/agent/tools/openapi/executor.rs:1271
↓ 3 callersFunctionredact_expanded_curl
(s: &str, vars: &HashMap<String, String>)
crates/gateway-e2e-harness/src/curl_run.rs:175
↓ 3 callersFunctionredis_key
(master_key_id: Uuid)
ai-gateway/src/dispatcher/regional_endpoint.rs:44
↓ 3 callersFunctionregex_once
(pattern: &str, hay: &str)
crates/alephant-llm-kv-cache/src/settings.rs:61
↓ 3 callersMethodregister_provider_capabilities
( &mut self, provider: InferenceProvider, )
ai-gateway/src/middleware/mapper/registry.rs:286
↓ 3 callersFunctionremove_internal_gateway_auth_headers
(headers: &mut HeaderMap)
ai-gateway/src/dispatcher/upstream_auth.rs:86
↓ 3 callersFunctionresolve_primary_model
( body_model: Option<&str>, header_model_override: Option<&str>, )
ai-gateway/src/middleware/large_context/heuristics.rs:139
↓ 3 callersFunctionresolved_response_cost
( _model_info: Option<&ModelInfo>, _usage: &crate::types::usage_tokens::UsageTokenCounts, )
ai-gateway/src/logger/service.rs:610
↓ 3 callersFunctionresponses_body
(model: &str)
ai-gateway/src/ide_adapation/cursor_responses_openrouter_bridge.rs:1030
↓ 3 callersMethodrun
(self, token: Token)
ai-gateway/src/app.rs:511
↓ 3 callersFunctionrun_anthropic_nonstream_runtime_case
( request_payload: Value, response_payload: Value, )
ai-gateway/tests/unified_api.rs:1407
↓ 3 callersFunctionrun_gemini_nonstream_runtime_case
( request_payload: Value, response_payload: Value, )
ai-gateway/tests/unified_api.rs:1488
↓ 3 callersFunctionrun_openai_like_stream_case
( case: &UnifiedApiCase, request_payload: Value, )
ai-gateway/tests/unified_api.rs:2109
↓ 3 callersFunctionrun_sql_with_poll
(ch: &ChClient, sql_exec: &str, poll: &ChPoll)
crates/gateway-e2e-harness/src/ch.rs:168
↓ 3 callersFunctionrun_unified_case
(case: &UnifiedApiCase)
ai-gateway/tests/unified_api.rs:873
↓ 3 callersFunctionsample_entry
()
crates/alephant-llm-kv-cache/src/bucket.rs:150
↓ 3 callersFunctionscalar_to_string
(value: &Value)
ai-gateway/src/agent/tools/openapi/mapping.rs:191
↓ 3 callersMethodsend_degraded_http
(&self, log_message: &LogMessage)
ai-gateway/src/logger/transport/redis_impl.rs:58
↓ 3 callersMethodsend_http
( &self, body: String, redis_error: Option<AgentEventLogTransportError>, )
ai-gateway/src/agent/log_transport.rs:135
↓ 3 callersFunctionserve_delayed_json_response
( listener: &TcpListener, body: serde_json::Value, delay: Duration, )
ai-gateway/src/agent/tools/mcp_http.rs:985
↓ 3 callersMethodset_bare_model_expand_index
Paired with `set_providers_config` on Cloud hot reload.
ai-gateway/src/app_state.rs:187
↓ 3 callersFunctionsha256_json
(value: &T)
ai-gateway/src/agent/tools/runtime_snapshot/provider.rs:165
↓ 3 callersFunctionsleep_briefly
()
examples/agent/langgraph/alephant_adapter.py:381
↓ 3 callersFunctionspawn_json_http_fixture
()
ai-gateway/src/agent/tools/service.rs:4174
↓ 3 callersMethodstart
(events: Vec<McpSseServerEvent>)
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:98
↓ 3 callersFunctionstatic_target_hash
(_target: &AgentToolTargetConfig)
ai-gateway/src/agent/tools/service.rs:1040
↓ 3 callersMethodstore_response_with_context
( &self, mut write: SemanticWriteContext, response: &[u8], )
ai-gateway/src/semantic_cache/service.rs:327
↓ 3 callersFunctionsummarize_arguments
(arguments: &str)
ai-gateway/src/agent/tool_observer.rs:1373
↓ 3 callersFunctiontarget
(url: &str)
ai-gateway/src/agent/tools/mcp_streamable_http/target_hash.rs:117
↓ 3 callersMethodtarget_skips_model_catalog
(&self, provider: &InferenceProvider)
ai-gateway/src/middleware/mapper/model.rs:90
↓ 3 callersFunctiontest_mcp_target
(fixture: &McpHttpFixture, name: &str)
ai-gateway/src/agent/tools/mcp_http.rs:953
↓ 3 callersFunctiontest_redis_url
()
ai-gateway/tests/workspace_concurrency_redis.rs:16
↓ 3 callersFunctiontest_vk_metrics
()
ai-gateway/src/content_filter/prompt_cache.rs:478
↓ 3 callersFunctiontool_call_requested_event
( auth: &AuthContext, header_context: Option<&AgentContext>, request: &ToolCallRequest, tool_e
ai-gateway/src/agent/tools/audit.rs:68
↓ 3 callersFunctiontool_result_response_for_execution
( execution_id: &str, result: serde_json::Value, )
ai-gateway/src/agent/tools/mcp_streamable_http/test_support.rs:186
↓ 3 callersMethodtotal
(&self)
ai-gateway/src/metrics/rolling_counter.rs:59
↓ 3 callersFunctiontotal_message_chars
(payload: &ChatCompletionsPayload)
ai-gateway/src/middleware/large_context/heuristics.rs:36
↓ 3 callersFunctiontruthy
(value: object)
examples/agent/langgraph/alephant_adapter.py:321
↓ 3 callersFunctiontruthy
(value)
examples/agent/mastra/mastra_run.mjs:60
↓ 3 callersFunctionunavailable_on_failure
( app_state: &AppState, on_unavailable: OnUnavailable, message: String, )
ai-gateway/src/content_filter/evaluate.rs:150
↓ 3 callersFunctionunavailable_result
( on_unavailable: OnUnavailable, message: String, )
ai-gateway/src/x402/policy.rs:70
↓ 3 callersMethodurl
(&self)
ai-gateway/src/agent/tools/executor.rs:896
↓ 3 callersFunctionvalidate_variable_type
(value: &Value, expected_type: &str)
ai-gateway/src/middleware/prompts/templating.rs:373
↓ 3 callersFunctionvalue_with_model
(raw: &Value, model: &str)
ai-gateway/src/middleware/large_context/heuristics.rs:28
↓ 3 callersMethodvalues_url
(&self, key: &str)
crates/alephant-llm-kv-cache/src/cloudflare.rs:37
↓ 3 callersFunctionvirtual_key_owner_and_org
(vk: &DbVirtualKey)
ai-gateway/src/middleware/auth.rs:290
↓ 3 callersMethodweight
(&self)
crates/weighted-balance/src/weight.rs:156
↓ 3 callersMethodwith_resolved_snapshot
( mut self, snapshot: &X402EndpointSnapshot, snapshot_source: &str, )
ai-gateway/src/x402/service.rs:125
↓ 3 callersFunctionworkspace_id
()
ai-gateway/tests/unified_api.rs:474
↓ 3 callersFunctionwrite_json
(path: Path, value: Any)
examples/agent/tools/e2e_support.py:82
↓ 3 callersFunctionwrite_status
(stream: &mut TcpStream, status: StatusCode)
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:411
↓ 3 callersMethodx402_payment_client
( &self, )
ai-gateway/src/app_state.rs:136
↓ 3 callersMethodxadd_payload
( &self, stream_key: &str, payload: &str, )
ai-gateway/src/app_redis.rs:62
↓ 2 callersFunction_case_should_include
( failures: list[dict[str, str]], out: str, err: str, log_all: bool, )
scripts/test-archival/gate_junit_captures.py:79
↓ 2 callersMethod_debug_enabled
(self, target: str, headers: dict[str, str])
examples/agent/framework_common.py:136
↓ 2 callersFunction_failure_records
(case: ET.Element)
scripts/test-archival/gate_junit_captures.py:66
← previousnext →601–700 of 4,673, ranked by callers