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
↓ 13 callersMethodfrom_env
( cls, *, agent_id: str, run_id: str | None = None, default_agent_name
examples/agent/langgraph/alephant_adapter.py:71
↓ 13 callersMethodget_or_init
(&self, key: String, init: F)
ai-gateway/src/agent/tools/mcp_streamable_http/session.rs:154
↓ 13 callersMethodis_stream
(&self)
ai-gateway/src/endpoints/openai/mod.rs:112
↓ 13 callersFunctionobserve_chat_completion_stream_tool_calls
( request_id: uuid::Uuid, body: &[u8], )
ai-gateway/src/agent/tool_observer.rs:204
↓ 13 callersMethodparse
(headers: &HeaderMap)
crates/alephant-llm-kv-cache/src/settings.rs:13
↓ 13 callersFunctionput_sse_data_json
(buf: &mut BytesMut, val: &T)
ai-gateway/src/ide_adapation/cursor_responses_openrouter_bridge.rs:47
↓ 13 callersMethodregister_converter
(&mut self, key: RegistryKey, converter: C)
ai-gateway/src/middleware/mapper/registry.rs:279
↓ 13 callersFunctionrequest
(arguments: serde_json::Value)
ai-gateway/src/agent/tools/openapi/executor.rs:1187
↓ 13 callersFunctionresolve_mapper_metadata
( provider: &InferenceProvider, model: Option<&str>, )
ai-gateway/src/middleware/mapper/profile_resolver.rs:28
↓ 13 callersMethodrouter_store
(&self)
ai-gateway/src/app_state.rs:143
↓ 13 callersFunctiontest_egress_policy
()
ai-gateway/src/agent/tools/openapi/executor.rs:1197
↓ 13 callersFunctionwith_env_overrides
(vars: &[(&str, Option<&str>)], f: impl FnOnce() -> T)
ai-gateway/src/config/mod.rs:770
↓ 12 callersMethod_json_rpc_error
( self, request_id: Any, code: int, message: str, *, status: int = HTTPStatus.OK )
examples/agent/tools/mcp_mock_server.py:31
↓ 12 callersFunctionbuild_from_db
( db_providers: &[DbGatewayProvider], db_models: &[DbGatewayProviderModel], )
ai-gateway/src/discover/router/provider_db_config.rs:31
↓ 12 callersFunctionenvelope
(metadata: serde_json::Value)
ai-gateway/src/agent/policy.rs:875
↓ 12 callersFunctionmapping_failed
(message: impl Into<String>)
ai-gateway/src/agent/tools/openapi/mapping.rs:278
↓ 12 callersFunctionobserve_responses_stream_agent_items
( request_id: uuid::Uuid, body: &[u8], )
ai-gateway/src/agent/tool_observer.rs:589
↓ 12 callersMethodor_non_empty
(self)
ai-gateway/src/agent/log_payload.rs:395
↓ 12 callersFunctionparse_chat_completions_payload
( body: &[u8], )
ai-gateway/src/middleware/large_context/parse.rs:40
↓ 12 callersFunctionreserve_port
()
ai-gateway/tests/unified_api.rs:492
↓ 12 callersMethodurl
(&self, path: &str)
ai-gateway/src/agent/tools/openapi/executor.rs:1267
↓ 12 callersMethodwith_sse_used
(mut self, sse_used: bool)
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:1436
↓ 11 callersMethod_log
(self, msg: str)
examples/agent/tools/mcp_mock_server.py:51
↓ 11 callersFunctionagent_events_request
(event: AgentEventInput)
ai-gateway/src/agent/service.rs:1794
↓ 11 callersMethodas_str
(self)
ai-gateway/src/types/extensions.rs:244
↓ 11 callersFunctionassert_openai_chat_completion_shape
(body: &str)
ai-gateway/tests/unified_api.rs:2418
↓ 11 callersFunctionbuild_request_plan
( method: &str, target: &RuntimeOpenApiTarget, arguments: &Value, )
ai-gateway/src/agent/tools/openapi/mapping.rs:35
↓ 11 callersFunctioncleanup_case
( pool: &PgPool, case: &UnifiedApiCase, seed: SeedSnapshot, )
ai-gateway/tests/unified_api.rs:782
↓ 11 callersFunctiondb_pool
()
ai-gateway/tests/unified_api.rs:548
↓ 11 callersFunctionemit_agent_event
( app_state: &AppState, auth_ctx: &AuthContext, event: &AgentEventEnvelope, )
ai-gateway/src/agent/sink.rs:15
↓ 11 callersFunctionenvelope_from_response
( request: &ToolCallRequest, response: &ToolCallResponse, )
ai-gateway/src/agent/tools/service.rs:1344
↓ 11 callersFunctionfill_option
(target: &mut Option<String>, value: Option<String>)
ai-gateway/src/agent/adapter.rs:707
↓ 11 callersFunctionmap_unified_body_passthrough
( source_endpoint: ApiEndpoint, target_endpoint: ApiEndpoint, path: &'static str,
ai-gateway/src/middleware/mapper/service.rs:1286
↓ 11 callersFunctionmetadata_string
(metadata: &serde_json::Value, key: &str)
ai-gateway/src/agent/policy.rs:364
↓ 11 callersFunctionnormalize_event
( event: &AgentEventInput, auth_ctx: &AuthContext, redaction: AgentMetadataRedaction, header_c
ai-gateway/src/agent/service.rs:395
↓ 11 callersFunctionoptional_u32
(value: Option<&Value>)
ai-gateway/src/agent/tool_observer.rs:1360
↓ 11 callersFunctionregistry
()
ai-gateway/src/ide_adapation/cursor_responses_openrouter_bridge.rs:1010
↓ 11 callersFunctionresponse_json
(response: Response)
ai-gateway/src/agent/service.rs:2232
↓ 11 callersFunctionrun_openai_large_context_runtime_case
( request_payload: Value, response_payload: Value, extra_headers: &[(&str, &str)], extra_model
ai-gateway/tests/unified_api.rs:1886
↓ 11 callersFunctionsample_vk
(key_hash: &str, workspace_id: Uuid)
ai-gateway/src/app_state.rs:662
↓ 11 callersFunctionseed_case
( pool: &PgPool, case: &UnifiedApiCase, base_url: &str, )
ai-gateway/tests/unified_api.rs:763
↓ 11 callersFunctionspawn_agent_log_http_fixture
(status_code: u16)
ai-gateway/src/agent/tools/service.rs:4033
↓ 11 callersFunctionspawn_redis_fixture
()
ai-gateway/src/agent/service.rs:2119
↓ 11 callersMethodwith_protocol_version
(mut self, protocol_version: String)
ai-gateway/src/agent/tools/mcp_streamable_http/lifecycle.rs:1431
↓ 10 callersFunctionapply_prompt_inputs_to_body
(mut body: Value)
ai-gateway/src/middleware/prompts/templating.rs:12
↓ 10 callersFunctionauth_context
(org_id: Uuid)
ai-gateway/src/agent/tools/audit.rs:984
↓ 10 callersFunctionauth_ctx_with_base_url
(base_url: Option<&str>)
ai-gateway/src/dispatcher/target_endpoint.rs:231
↓ 10 callersFunctionbase_target
()
ai-gateway/src/agent/tools/openapi/mapping.rs:290
↓ 10 callersFunctionenv_non_empty
(key: &str)
ai-gateway/src/config/mod.rs:220
↓ 10 callersFunctionexecute_mcp_streamable_http_tool
( ctx: &crate::agent::tools::executor::ToolExecutionContext, target: &crate::config::agent::AgentToolT
ai-gateway/src/agent/tools/mcp_streamable_http.rs:10
↓ 10 callersMethodfinish
(mut self, session: Option<T>)
ai-gateway/src/agent/tools/mcp_streamable_http/session.rs:235
↓ 10 callersMethodget
(&self)
ai-gateway/src/content_filter/client.rs:70
↓ 10 callersMethodget_providers_config
(&self)
ai-gateway/src/app_state.rs:155
↓ 10 callersFunctionheader_string
(headers: &HeaderMap, name: &str)
ai-gateway/src/x402/service.rs:1207
↓ 10 callersFunctionjson_i64
(obj: &Value, key: &str)
ai-gateway/src/logger/usage_parse.rs:245
↓ 10 callersFunctionjson_response
( status: StatusCode, value: &T, )
ai-gateway/src/agent/tools/service.rs:1478
↓ 10 callersFunctionkv_key_sha256_hex
( cache_seed: &str, url: &str, body: &str, cache_ignore_keys: &[String], bucket_index: u8,
crates/alephant-llm-kv-cache/src/key.rs:19
↓ 10 callersFunctionmake_request
(v: serde_json::Value)
ai-gateway/src/middleware/mapper/responses_to_chat_request.rs:390
↓ 10 callersMethodplan
(&self, request: UnifiedRouteRequest)
ai-gateway/src/router/unified_route_planner.rs:159
↓ 10 callersFunctionpreferred_test_db_url
(default_url: &str)
ai-gateway/src/store/router.rs:1595
↓ 10 callersMethodprovider_gateway_fingerprint
Returns a stable fingerprint for the enabled provider gateway catalog. Used during startup to decide whether the DB listener's first poll can skip a
ai-gateway/src/store/router.rs:877
↓ 10 callersMethodpush_and_try_find
( &mut self, chunk: &[u8], expected_id: &str, limits: &SseLimits, )
ai-gateway/src/agent/tools/mcp_streamable_http/sse.rs:30
↓ 10 callersFunctionready
()
examples/agent/tools/e2e_tool_event_loop.py:159
↓ 10 callersMethodreconnect_lock
(&self)
ai-gateway/src/content_filter/client.rs:74
↓ 10 callersMethodrequests
(&self)
ai-gateway/src/agent/tools/mcp_sse/test_support.rs:206
↓ 10 callersFunctionresolve_client_profile
(headers: &http::HeaderMap)
ai-gateway/src/ide_adapation/client_profile.rs:53
↓ 10 callersFunctionresolve_unified_target_provider
( compat: bool, compat_fallback: InferenceProvider, model: &str, master_key_allowed_providers:
ai-gateway/src/router/target_provider_resolve.rs:38
↓ 10 callersFunctiontest_context
(target: &AgentToolTargetConfig)
ai-gateway/src/agent/tools/mcp_streamable_http/test_support.rs:268
↓ 10 callersMethodurl
(&self)
ai-gateway/src/agent/log_transport.rs:438
↓ 10 callersFunctionusage_counts_from_response_body
(body: &[u8])
ai-gateway/src/logger/usage_parse.rs:39
↓ 10 callersFunctionvalidate_openapi_egress
( target: &RuntimeOpenApiTarget, plan: &OpenApiRequestPlan, policy: &AgentToolEgressPolicyConfig,
ai-gateway/src/agent/tools/openapi/egress.rs:31
↓ 9 callersFunctionassert_response
(spec: &AssertionsSpec, cap: &CapturedResponse)
crates/gateway-e2e-harness/src/assert.rs:14
↓ 9 callersFunctioncanonical_mcp_sse_target_hash
( target: &AgentToolTargetConfig, tools_cfg: &AgentToolsConfig, )
ai-gateway/src/agent/tools/mcp_sse/target_hash.rs:6
↓ 9 callersFunctionclone_nonempty
(value: &Option<String>)
ai-gateway/src/logger/service.rs:548
↓ 9 callersFunctiondefault_policy
()
ai-gateway/src/agent/tools/openapi/egress.rs:111
↓ 9 callersFunctionencrypt
Encrypt plaintext (for tests and tooling); returns `(ciphertext, nonce)`.
ai-gateway/src/crypto/master_key.rs:50
↓ 9 callersFunctionenv_filter
(config: &Config)
crates/telemetry/src/lib.rs:279
↓ 9 callersFunctionexecute_openapi_tool
( target: &AgentToolTargetConfig, request: &ToolCallRequest, egress_policy: &AgentToolEgressPolicy
ai-gateway/src/agent/tools/openapi/executor.rs:27
↓ 9 callersFunctionjson_text_field
(v: Option<&Value>)
ai-gateway/src/ide_adapation/responses_ingress_normalize.rs:205
↓ 9 callersFunctionload_master_key_encryption_key
Reads `MASTER_KEY_ENCRYPTION_KEY` from the environment, Base64-decodes it and validates that it is exactly 32 bytes. Returns an `Arc<[u8; 32]>` suitab
ai-gateway/src/crypto/master_key_config.rs:16
↓ 9 callersFunctionmap_request
( app_state: AppState, converter_registry: EndpointConverterRegistry, source_endpoint: ApiEndpoint
ai-gateway/src/middleware/mapper/service.rs:160
↓ 9 callersFunctionnested_metadata_string
(metadata: Option<&serde_json::Value>, key: &str)
ai-gateway/src/agent/log_payload.rs:408
↓ 9 callersFunctionopenapi_response
( target: &RuntimeOpenApiTarget, request: &ToolCallRequest, options: &OpenApiExecutionOptions,
ai-gateway/src/agent/tools/openapi/executor.rs:500
↓ 9 callersFunctionpayload_fixture
()
ai-gateway/src/agent/log_transport.rs:389
↓ 9 callersFunctionplan
(url: &str)
ai-gateway/src/agent/tools/openapi/egress.rs:101
↓ 9 callersFunctionplanner
()
ai-gateway/src/router/unified_route_planner.rs:240
↓ 9 callersFunctionpolicy_validating_event_input
()
ai-gateway/src/agent/service.rs:1896
↓ 9 callersFunctionpost
(path: string, payload: unknown, stepId: string, toolCallId?: string)
examples/agent/mastra/openapi_tool_run.ts:52
↓ 9 callersFunctionprint_json
(label: str, value: Any)
examples/agent/framework_common.py:231
↓ 9 callersFunctionprint_json
(label: str, value: Any)
examples/agent/langgraph/alephant_adapter.py:371
↓ 9 callersMethodpublish
Publish a health event if not within the dedup window.
ai-gateway/src/discover/monitor/health/broadcast.rs:56
↓ 9 callersFunctionput_sse_json
(buf: &mut BytesMut, val: &T)
ai-gateway/src/ide_adapation/unified_responses_chat_compat.rs:86
↓ 9 callersMethodregister_provider_metadata
(&mut self, provider: InferenceProvider)
ai-gateway/src/middleware/mapper/registry.rs:308
↓ 9 callersFunctionsample_vk
( entity_id: Option<Uuid>, expires_at: Option<chrono::DateTime<Utc>>, )
ai-gateway/src/middleware/auth.rs:400
↓ 9 callersFunctionstart_mock
( stub_path: &str, global_delay: Option<u64>, stubs: Option<&HashMap<&'static str, Times>>, ve
ai-gateway/src/tests/mock.rs:388
↓ 9 callersFunctiontarget
()
ai-gateway/src/agent/tools/openapi/egress.rs:90
↓ 9 callersFunctiontruncate_chars
(s: &str, max_chars: usize)
ai-gateway/src/middleware/mapper/anthropic_error_lenient.rs:120
↓ 9 callersFunctionvalidate_body_against_schema
( body: &Bytes, schema: &Value, )
ai-gateway/src/x402/body_schema.rs:21
↓ 9 callersFunctionwait_for_agent_log_requests
( fixture: &AgentLogHttpFixture, expected_len: usize, )
ai-gateway/src/agent/tools/service.rs:4132
↓ 8 callersFunctionadd_prop
(k: str, v: str)
scripts/test-archival/enrich_junit_libtest.py:94
← previousnext →101–200 of 4,673, ranked by callers