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
↓ 4 callersFunctionapp_state_with_index
( f: impl FnOnce(&mut BareModelExpandIndex), )
ai-gateway/src/default_model/choose.rs:432
↓ 4 callersFunctionapply_chat_completions
Apply the same whitespace normalization as `heuristics::normalize_text` to `chat/completions` body; when applicable store pre/post compression token e
ai-gateway/src/middleware/prompt_compression/mod.rs:43
↓ 4 callersFunctionapply_final_agent_name_to_request_log
( registered_agent_name: Option<&str>, agent_fields: &mut AgentLogFields, properties: &mut IndexMa
ai-gateway/src/logger/service.rs:578
↓ 4 callersFunctionapply_regional_retry_result
( result: &mut Result<SyncDispatchResponse, ApiError>, effective_target_url: &mut url::Url, cn_ret
ai-gateway/src/dispatcher/service.rs:1462
↓ 4 callersFunctionapply_responses_normalize
( body: Bytes, mode: ResponsesNormalizeMode, profile: ClientProfile, )
ai-gateway/src/ide_adapation/responses_ingress_normalize.rs:73
↓ 4 callersMethodas_model_name
(&self)
ai-gateway/src/types/model_id.rs:211
↓ 4 callersMethodas_str
(self)
ai-gateway/src/router/router_details.rs:73
↓ 4 callersFunctionassert_evidence_backed_openai_compatible_rule_profile
(provider_name: &str)
ai-gateway/src/middleware/mapper/rule_data.rs:20
↓ 4 callersFunctionassert_openai_compatible_passthrough_profile
(provider_name: &str)
ai-gateway/src/middleware/mapper/capability_data.rs:18
↓ 4 callersFunctionattach_sink_status_to_metadata
(metadata: &mut serde_json::Value, sink_status: &str)
ai-gateway/src/agent/service.rs:376
↓ 4 callersFunctionauth_context_from_extensions
(extensions: &http::Extensions)
ai-gateway/src/agent/service.rs:387
↓ 4 callersFunctionauth_context_with_allowed
(providers: Option<Vec<InferenceProvider>>)
ai-gateway/src/router/unified_route_planner.rs:210
↓ 4 callersFunctionblocked_before_dispatch_response
( request: &ToolCallRequest, reason: &str, tool_execution_id: String, )
ai-gateway/src/agent/tools/service.rs:601
↓ 4 callersMethodbuild_event
( self, event_type: str, *, context: AgentStepContext | None = None, s
examples/agent/langgraph/alephant_adapter.py:142
↓ 4 callersFunctionbuild_policy_headers_map
(headers: &http::HeaderMap)
ai-gateway/src/content_filter/request.rs:60
↓ 4 callersMethodcall
(&mut self, req: crate::types::request::Request)
ai-gateway/src/router/meta.rs:160
↓ 4 callersFunctioncall_tool_with_session
( ctx: &ToolExecutionContext, target: &AgentToolTargetConfig, request: &ToolCallRequest, url:
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:956
↓ 4 callersFunctioncanonical_target_hash
( target: &AgentToolTargetConfig, target_revision: u64, auth_revision: &str, tools_cfg: &Agent
ai-gateway/src/agent/tools/mcp_streamable_http/target_hash.rs:26
↓ 4 callersMethodcheck_health
(&self, provider: &InferenceProvider)
ai-gateway/src/discover/monitor/health/provider.rs:672
↓ 4 callersFunctioncheck_step_conflict
( app_state: &AppState, auth_ctx: &AuthContext, envelope: &AgentEventEnvelope, )
ai-gateway/src/agent/service.rs:551
↓ 4 callersFunctionclassify_virtual_key_update
( last_seen: Option<&DateTime<Utc>>, vk: DbVirtualKey, )
ai-gateway/src/store/db_listener.rs:624
↓ 4 callersFunctionconvert_bedrock_response
( profile: &NonStreamFormatProfile, value: ConverseResponse, )
ai-gateway/src/middleware/mapper/non_stream_response_interpreter.rs:73
↓ 4 callersMethodconvert_req_body
(&self, bytes: Bytes)
ai-gateway/src/middleware/mapper/mod.rs:310
↓ 4 callersFunctioncopy_allowlisted_raw_fields_to_metadata
(event: &mut AgentEventInput)
ai-gateway/src/agent/adapter.rs:755
↓ 4 callersMethodcopy_extensions
Copies required request extensions to response extensions.
ai-gateway/src/dispatcher/extensions.rs:22
↓ 4 callersFunctiondebug_body_preview
(body: &[u8])
ai-gateway/src/utils/debug_log.rs:105
↓ 4 callersFunctiondebug_header_lines
(headers: &http::HeaderMap)
ai-gateway/src/utils/debug_log.rs:91
↓ 4 callersFunctiondecr_floor_refresh_ttl
(client: &AppRedis, key: &str)
ai-gateway/src/middleware/workspace_concurrency/redis_ops.rs:26
↓ 4 callersFunctiondecrypt
Decrypt master key ciphertext using workspace encryption key (32 bytes).
ai-gateway/src/crypto/master_key.rs:34
↓ 4 callersFunctiondefault_agent_name
(value: str)
examples/agent/framework_common.py:173
↓ 4 callersFunctiondefault_provider_latency
()
crates/mock-server/src/lib.rs:45
↓ 4 callersFunctiondefault_run_id
(prefix: str)
examples/agent/framework_common.py:177
↓ 4 callersFunctiondeprecated_per_path_retries
(config: &Config)
ai-gateway/src/config/fallback_bridge.rs:109
↓ 4 callersFunctiondeserialize_anthropic_error_lenient
(bytes: &[u8])
ai-gateway/src/middleware/mapper/anthropic_error_lenient.rs:19
↓ 4 callersMethodemit_events
(self, *, source: str, events: list[dict[str, Any]])
examples/agent/framework_common.py:63
↓ 4 callersFunctionendpoint_secret_redis_key
(endpoint_id: Uuid)
ai-gateway/src/x402/forward_signature.rs:40
↓ 4 callersFunctionendpoint_snapshot_json_with_endpoint_type
( slug: &str, upstream_base_url: &str, body_schema: serde_json::Value, headers_policy: serde_j
ai-gateway/tests/x402_sidecar.rs:540
↓ 4 callersFunctionensure_mock_provider_configs
(config: &mut Config)
ai-gateway/tests/unified_api.rs:519
↓ 4 callersFunctionenv_s3_optional
(flat: &str, nested: &str)
ai-gateway/examples/cloud_log_bodies_real_storage.rs:437
↓ 4 callersMethoderror_for_status
(self)
ai-gateway/src/utils/mod.rs:26
↓ 4 callersFunctionerror_response
(error: AgentServiceError)
ai-gateway/src/agent/service.rs:587
↓ 4 callersFunctionestimate_input_tokens
( payload: &ChatCompletionsPayload, primary_model: &str, provider_hint: Option<&InferenceProvider>
ai-gateway/src/middleware/large_context/heuristics.rs:159
↓ 4 callersFunctionevent_execution_id
(event: dict[str, Any])
examples/agent/tools/e2e_tool_event_loop.py:201
↓ 4 callersFunctionevent_type
(event: dict[str, Any])
examples/agent/tools/e2e_tool_event_loop.py:196
↓ 4 callersFunctionexecute_mcp_sse_tool
( ctx: &crate::agent::tools::executor::ToolExecutionContext, target: &crate::config::agent::AgentToolT
ai-gateway/src/agent/tools/mcp_sse.rs:8
↓ 4 callersFunctionfailed_response
( ctx: &ToolExecutionContext, target: &AgentToolTargetConfig, request: &ToolCallRequest, execu
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:1232
↓ 4 callersFunctionfield_is_presigned_url
(s: &str)
ai-gateway/examples/cloud_log_bodies_real_storage.rs:259
↓ 4 callersFunctionfill_prompt_details_from
(details: &Value, out: &mut UsageTokenCounts)
ai-gateway/src/logger/usage_parse.rs:131
↓ 4 callersFunctionfinish_framework_event
( mut event: AgentEventInput, source: AgentEventSource, raw_event_type: &str, )
ai-gateway/src/agent/adapter.rs:197
↓ 4 callersFunctionframework_tool_name
(tool_id: &str, seen: &mut HashSet<String>)
ai-gateway/src/agent/tools/catalog.rs:236
↓ 4 callersFunctiongenerate_tool_call_id
(msg_index: usize, tc_index: usize, tool_name: &str)
ai-gateway/src/ide_adapation/ide_ingress_adjust/cursor_openai_normalize.rs:38
↓ 4 callersMethodget_all_provider_models_for_gateway
Returns all enabled provider models from the `provider_models` table. Used alongside [`get_all_providers_for_gateway`] to build the full `ProvidersCo
ai-gateway/src/store/router.rs:559
↓ 4 callersMethodget_converter
( &self, source_endpoint: &ApiEndpoint, target_endpoint: &ApiEndpoint, )
ai-gateway/src/middleware/mapper/registry.rs:32
↓ 4 callersMethodget_model_info_for_gateway_model
Returns `info` JSON for an enabled provider model, or `None` if missing / disabled / null column.
ai-gateway/src/store/router.rs:577
↓ 4 callersMethodhealth_metrics
( &self, api_endpoint: ApiEndpoint, )
ai-gateway/src/discover/monitor/metrics.rs:31
↓ 4 callersFunctionincr_refresh_ttl
(client: &AppRedis, key: &str)
ai-gateway/src/middleware/workspace_concurrency/redis_ops.rs:22
↓ 4 callersFunctioninfo_log_request_summary
Log a synthetic `/v1/log/request` payload summary (field shapes only).
ai-gateway/src/logger/cloud_bodies.rs:118
↓ 4 callersFunctioninvalid_prompt_cache
(message: String)
ai-gateway/src/content_filter/prompt_cache.rs:128
↓ 4 callersFunctionipv6_mapped_ipv4
(addr: &Ipv6Addr)
ai-gateway/src/agent/tools/egress_policy.rs:116
↓ 4 callersMethodis_observability_enabled
(&self)
ai-gateway/src/config/alephant.rs:57
↓ 4 callersFunctionis_process_alive
(pid: int)
scripts/provider_mock/manage_provider_mocks.py:75
↓ 4 callersMethodkey
(&self)
ai-gateway/src/agent/tools/mcp_streamable_http/session.rs:79
↓ 4 callersFunctionload_reusable_cached_session
( ctx: &ToolExecutionContext, cache: &dyn McpSessionCache, key: &str, )
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:573
↓ 4 callersFunctionmap_mcp_error
( tool_execution_id: &str, tool_call_id: Option<String>, error: McpJsonRpcError, )
ai-gateway/src/agent/tools/mcp_http.rs:84
↓ 4 callersFunctionmap_unified_body_passthrough_with_path
( source_endpoint: ApiEndpoint, target_endpoint: ApiEndpoint, path: &'static str,
ai-gateway/src/middleware/mapper/service.rs:1297
↓ 4 callersFunctionmapper_context_native_semantic_passthrough
Builds [`MapperContext`] on native semantic passthrough paths (e.g. Claude Code / Codex); skips semantic envelope when source/target share the same wi
ai-gateway/src/ide_adapation/mapper_service_hooks.rs:130
↓ 4 callersMethodmark
(&self)
ai-gateway/src/types/extensions.rs:304
↓ 4 callersFunctionmetadata_insert_string
(metadata: &mut serde_json::Value, key: &str, value: String)
ai-gateway/src/agent/adapter.rs:713
↓ 4 callersFunctionmetadata_u64
(metadata: &serde_json::Value, key: &str)
ai-gateway/src/agent/log_payload.rs:427
↓ 4 callersFunctionmq_test_conn
()
ai-gateway/tests/workspace_concurrency_redis.rs:70
↓ 4 callersMethodnotify
( self, notify: NN, )
ai-gateway/src/utils/retry.rs:81
↓ 4 callersFunctionobject_schema
()
ai-gateway/src/x402/body_schema.rs:45
↓ 4 callersFunctionobserve_chat_completion_tool_calls
(body: &[u8])
ai-gateway/src/agent/tool_observer.rs:138
↓ 4 callersFunctionopenapi_target_hash
(target: &AgentToolTargetConfig, request: &ToolCallRequest)
ai-gateway/src/agent/tools/service.rs:1044
↓ 4 callersFunctionoutput_text_part
(text: String)
ai-gateway/src/ide_adapation/responses_ingress_normalize.rs:339
↓ 4 callersFunctionparse_json_each_row_lines
(body: &str)
crates/gateway-e2e-harness/src/ch.rs:311
↓ 4 callersFunctionparse_money_amount
(value: &str)
ai-gateway/src/x402/service.rs:280
↓ 4 callersFunctionparse_uuid
(value: &str)
ai-gateway/tests/unified_api.rs:470
↓ 4 callersFunctionpayment_failure_message
(reason: &str, fallback: &'static str)
ai-gateway/src/x402/service.rs:1357
↓ 4 callersFunctionpick_response_model
(raw_model: str | None, config: ProviderMockConfig)
scripts/provider_mock/mock_openai_compatible_base.py:46
↓ 4 callersFunctionprepare_paid_upstream_request
( snapshot: &X402EndpointSnapshot, _slug: &str, remaining_path: &str, inbound_method: &Method,
ai-gateway/src/x402/service.rs:1081
↓ 4 callersFunctionreplace_variables
( text: &str, inputs: &HashMap<String, Value>, typed_variable_regex: &Regex, legacy_variable_r
ai-gateway/src/middleware/prompts/templating.rs:297
↓ 4 callersFunctionrequest_builder_with_effective_host
( request_builder: RequestBuilder, target_url: &url::Url, )
ai-gateway/src/dispatcher/request_builder.rs:5
↓ 4 callersFunctionrequest_hash
( tool_id: &str, idempotency_key: Option<&str>, vector: &VersionVector, arguments: &serde_json
ai-gateway/src/agent/tools/idempotency.rs:10
↓ 4 callersFunctionrequest_log_id_from_headers
(headers: &HeaderMap)
ai-gateway/src/dispatcher/service.rs:1755
↓ 4 callersFunctionresolve_master_key_target_url
( auth_ctx: Option<&AuthContext>, path_and_query: &str, )
ai-gateway/src/dispatcher/target_endpoint.rs:199
↓ 4 callersFunctionresponses_request_routing_fields
( body: &Bytes, )
ai-gateway/src/ide_adapation/responses_ingress_normalize.rs:27
↓ 4 callersFunctionresponses_stream_idempotency_key
( request_id: uuid::Uuid, event_type: &str, response_id: Option<&str>, sequence: u32, item
ai-gateway/src/agent/tool_observer.rs:1300
↓ 4 callersFunctionrewrite_model_in_body
Replace the `"model"` field in a JSON body with `new_model`, returning the re-serialized bytes. Returns `None` if the body is not valid JSON or has no
ai-gateway/src/middleware/model_support/service.rs:219
↓ 4 callersFunctionrewrite_responses_input_items_for_create_response
( root: &mut Value, )
ai-gateway/src/ide_adapation/responses_ingress_normalize.rs:453
↓ 4 callersFunctionrun_bedrock_nonstream_runtime_case
( request_payload: Value, response_payload: Value, )
ai-gateway/tests/unified_api.rs:1565
↓ 4 callersFunctionrun_openai_like_nonstream_runtime_case_with_options
( case: &UnifiedApiCase, request_payload: Value, response_payload: Value, extra_headers: &[(&s
ai-gateway/tests/unified_api.rs:1660
↓ 4 callersFunctionsample_model_mapper
()
ai-gateway/src/middleware/mapper/bedrock.rs:943
↓ 4 callersFunctionsanitize_tool_id
(id: &str)
ai-gateway/src/ide_adapation/ide_ingress_adjust/cursor_openai_normalize.rs:26
↓ 4 callersMethodsemantic_cache
(&self)
ai-gateway/src/app_state.rs:92
↓ 4 callersFunctionsemantic_headers
(model: &str)
ai-gateway/src/semantic_cache/service.rs:581
↓ 4 callersFunctionsemantic_hit
(score: f32)
ai-gateway/src/semantic_cache/service.rs:573
↓ 4 callersMethodset_ex
( &self, key: &str, value: &str, ttl_secs: u64, )
ai-gateway/src/app_redis.rs:197
↓ 4 callersMethodset_memory_openai_base_url
(&self, url: String)
ai-gateway/src/semantic_cache/base_url_resolver.rs:109
↓ 4 callersMethodset_protocol_version
(&self, protocol_version: String)
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:186
← previousnext →401–500 of 4,673, ranked by callers