portail 2.1.0

Unified proxy/gateway: AI Gateway + MCP Gateway + CDN cache
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! Portail - Unified Proxy/Gateway
//!
//! Architecture:
//!
//!   Client -> axum router -> middleware -> handler -> upstream
//!                   |
//!                   +-- /v1/chat/*  -> hooks.inject -> gateway.forward
//!                   +-- /mcp/*     -> mcp.proxy -> unix socket
//!                   +-- /cdn/*     -> cdn.lookup -> cache/origin
//!                   +-- /events/*  -> event_log -> SSE
//!                   +-- /hooks/*   -> hook_store CRUD
//!                   +-- /a2a/*     -> task lifecycle
//!                   +-- /a2c/*     -> chat API
//!                   +-- /dns/*     -> dns.resolve
//!                   +-- /tinyurl/* -> url shortening
//!                   +-- /traces/*  -> request tracing
//!                   +-- /cache/*   -> redis cache
//!
//! Rust 2024 Edition — native async fn in traits, resolver v3, unsafe_op_in_unsafe_fn.

#![deny(unsafe_op_in_unsafe_fn)]
#![forbid(unsafe_code)]
#![allow(clippy::too_many_arguments, clippy::large_enum_variant)]
#![allow(clippy::if_same_then_else, clippy::items_after_test_module)]
#![allow(clippy::new_without_default, clippy::needless_pass_by_value)]
#![allow(clippy::should_implement_trait, clippy::len_without_is_empty)]
#![allow(clippy::needless_borrow)]

pub mod a2a;
pub mod a2c;
pub mod auth;
pub mod bow;
pub mod cdn;
pub mod ci;
pub mod cli;
pub mod config;
pub mod config_watcher;
pub mod discovery;
pub mod dns;
pub mod drift;
pub mod events;
pub mod file_cache;
pub mod gateway;
pub mod godfather;
pub mod graphql;
pub mod hooks;
pub mod local_inference;
pub mod mcp;
pub mod nats_bridge;
pub mod orchestrator;
pub mod plugin_hooks;
pub mod plugins;
pub mod proxy;
pub mod rate_limit;
pub mod release_audit;
pub mod sentinel;
pub mod sessions;
pub mod shutdown;
pub mod spec_verify;
pub mod store;
pub mod supervisor;
pub mod target_router;
pub mod telemetry;
pub mod test_utils;
pub mod types;

pub use config::Config;
use loop_state_manager::LoopStateManager;
use portail_vaked::PluginRegistry;

use std::sync::Arc;
use std::sync::RwLock;

pub struct AppState {
    pub config: RwLock<Config>,
    pub config_watcher: Arc<config_watcher::ConfigWatcher>,
    pub event_log: Arc<events::EventLog>,
    pub cdn_cache: Option<Arc<cdn::CacheManager>>,
    pub hooks: Arc<hooks::HookStore>,
    pub a2a_tasks: Arc<a2a::TaskStore>,
    pub a2a_registry: Arc<a2a::registry::AgentRegistry>,
    pub dns_store: Arc<dns::DnsStore>,
    pub doh_client: Option<Arc<dns::DohClient>>,
    pub network_isolation: Arc<dns::NetworkIsolation>,
    pub tinyurl: Arc<plugins::TinyUrlStore>,
    pub trace_store: Arc<plugins::TraceStore>,
    pub redis_cache: Arc<plugins::RedisCache>,
    pub discovery: Arc<discovery::DiscoveryStore>,
    pub ci_status: Arc<ci::CiStatusStore>,
    pub metrics_handle: metrics_exporter_prometheus::PrometheusHandle,
    pub rate_limiter: Option<rate_limit::RateLimiter>,
    pub auth_state: Option<auth::AuthState>,
    pub event_store: Option<store::EventStore>,
    pub session_store: sessions::SessionStore,
    pub file_cache: file_cache::FileCache,
    pub supervisor: Arc<supervisor::Supervisor>,
    pub plugin_registry: Arc<std::sync::Mutex<PluginRegistry>>,
    pub loop_manager: Arc<LoopStateManager>,
    pub loop_runner: loopeng::SharedLoopEngine,
    pub inference_engine: Option<Arc<local_inference::InferenceEngine>>,
    pub pkg_ctx_memory: tokio::sync::Mutex<pkg_ctx::memory::PkgCtxMemory>,
}