mcpr-core 0.4.54

Core types, traits, protocol, and proxy engine for mcpr crates
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

//! [`ProxyState`] — everything one running proxy instance needs to serve
//! traffic: upstream client, rewrite config, sessions, schema manager,
//! per-proxy health, event bus handle. Request handlers take
//! `Arc<ProxyState>`.

use std::sync::Arc;

use arc_swap::ArcSwap;

use crate::event::EventBus;
use crate::protocol::schema_manager::{MemorySchemaStore, SchemaManager};
use crate::protocol::session::MemorySessionStore;

use super::RewriteConfig;
use super::forwarding::UpstreamClient;
use super::health::SharedProxyHealth;
use super::widgets::WidgetSource;

/// Everything one running proxy needs to serve a request end-to-end.
pub struct ProxyState {
    /// Proxy name used to tag events and look up per-proxy resources.
    pub name: String,

    // ── forwarding ──
    pub mcp_upstream: String,
    pub upstream: UpstreamClient,
    pub max_request_body: usize,
    pub max_response_body: usize,

    // ── response shaping ──
    /// Lock-free: readers call `.load()` (sync, ~5 ns); a writer
    /// wanting to swap config does `.store(Arc::new(new))`.
    pub rewrite_config: Arc<ArcSwap<RewriteConfig>>,
    pub widget_source: Option<WidgetSource>,

    // ── runtime tracking ──
    pub sessions: MemorySessionStore,
    pub schema_manager: Arc<SchemaManager<MemorySchemaStore>>,

    // ── per-proxy health display + tunnel callbacks ──
    pub health: SharedProxyHealth,

    // ── observability (cloned handle, cheap to clone) ──
    pub event_bus: EventBus,
}