Struct CoreState 

pub struct CoreState {
    pub script_interceptor: Arc<ScriptInterceptor>,
    pub policy_tx: Sender<ProxyPolicy>,
    pub flows_dropped: Arc<AtomicUsize>,
    /* private fields */
}

Fields

script_interceptor: Arc<ScriptInterceptor>

policy_tx: Sender<ProxyPolicy>

flows_dropped: Arc<AtomicUsize>

Implementations

impl CoreState

pub async fn new(db_url: Option<String>) -> Self

pub async fn get_metrics(&self) -> CoreMetrics

pub async fn get_metrics_prometheus_text(&self) -> String

pub fn status_snapshot(&self) -> CoreStatusSnapshot

pub async fn status_report(&self) -> CoreStatusReport

pub async fn intercept_snapshot(&self) -> CoreInterceptSnapshot

pub fn audit_snapshot(&self, limit: usize) -> CoreAuditSnapshot

pub async fn query_audit_snapshot( &self, query: CoreAuditQuery, ) -> CoreAuditSnapshot

pub async fn get_flow(&self, id: String) -> Option<Flow>

pub async fn get_rules(&self) -> Vec<Rule>

pub async fn set_rules(&self, rules: Vec<Rule>)

pub async fn upsert_rule_from( &self, actor: AuditActor, operation: &str, target: String, details: Value, rule: Rule, ) -> Result<(), String>

pub async fn delete_rule_from( &self, actor: AuditActor, operation: &str, target: String, details: Value, rule_id: &str, ) -> Result<bool, String>

pub async fn create_mock_response_rule_from( &self, actor: AuditActor, target: String, details: Value, config: MockResponseRuleConfig, ) -> Result<String, String>

pub async fn create_intercept_rule_from( &self, actor: AuditActor, target: String, details: Value, config: InterceptRuleConfig, ) -> Result<String, String>

pub async fn upsert_legacy_intercept_rule_from( &self, actor: AuditActor, target: String, details: Value, rule: InterceptRule, ) -> Result<(), String>

pub async fn set_rules_from( &self, actor: AuditActor, operation: &str, target: String, details: Value, rules: Vec<Rule>, ) -> Result<(), String>

pub async fn set_legacy_rules(&self, rules: Vec<InterceptRule>)

pub async fn get_rule_engine(&self) -> Arc<RuleEngine>

pub fn update_policy(&self, policy: ProxyPolicy)

pub fn patch_policy_from( &self, actor: AuditActor, target: String, patch: ProxyPolicyPatch, )

pub fn policy_snapshot(&self) -> ProxyPolicy

pub fn update_policy_from( &self, actor: AuditActor, target: String, policy: ProxyPolicy, )

pub async fn register_intercept( &self, key: String, tx: Sender<InterceptionResult>, )

pub async fn resolve_intercept( &self, key: String, result: InterceptionResult, ) -> Result<(), String>

pub async fn get_pending_ws_message( &self, key: String, ) -> Option<WebSocketMessage>

pub async fn set_pending_ws_message( &self, key: String, message: WebSocketMessage, )

pub async fn is_intercept_pending(&self, key: String) -> bool

pub async fn is_flow_intercepted(&self, flow_id: String) -> bool

pub fn upsert_flow(&self, flow: Box<Flow>)

pub fn append_ws_message(&self, flow_id: String, message: WebSocketMessage)

pub fn update_http_body( &self, flow_id: String, body: BodyData, direction: Direction, )

pub fn subscribe_flow_updates(&self) -> Receiver<FlowUpdate>

订阅 FlowUpdate 广播。调用者获得独立 Receiver，lag 时自动跳过过期消息。

pub fn subscribe_audit_events(&self) -> Receiver<AuditEvent>

pub fn record_flow_events_lagged(&self, skipped: u64)

pub fn record_audit_events_lagged(&self, skipped: u64)

pub fn lifecycle(&self) -> RuntimeLifecycle

pub fn subscribe_lifecycle(&self) -> Receiver<RuntimeLifecycle>

pub fn stop_proxy(&self) -> Result<ProxyStopResult, String>

pub fn recent_audit_events(&self) -> Vec<AuditEvent>

pub async fn search_flows(&self, query: FlowQuery) -> Vec<FlowSummary>

搜索内存中的 Flow 列表，返回轻量摘要。

pub fn redact_flow_update_for_output(&self, update: FlowUpdate) -> FlowUpdate

pub async fn resolve_intercept_with_modifications( &self, key: String, action: &str, mods: Option<FlowModification>, ) -> Result<(), String>

解除截获并可选地应用修改。

action 为 "drop" 时直接丢弃；其他值（含 "continue"）则：

• 若 mods 为 None，直接 Continue；
• 若 mods 存在，根据 key 格式决定修改请求/响应还是 WebSocket 消息。

key 格式约定：

• "<flow_id>:<phase>" — 修改请求或响应（phase 以 “request”/“response” 开头）
• "<flow_id>:ws_msg:<msg_id>" — 修改 WebSocket 消息

pub async fn resolve_intercept_with_modifications_from( &self, actor: AuditActor, key: String, action: &str, mods: Option<FlowModification>, ) -> Result<(), String>

pub async fn load_script_from( &self, actor: AuditActor, target: String, script: &str, ) -> Result<(), String>

pub fn spawn_proxy( self: &Arc<Self>, config: ProxyConfig, sink: Sender<FlowUpdate>, extra_interceptor: Option<Arc<dyn Interceptor>>, ) -> Result<ProxySpawnResult, String>

pub async fn start_proxy( self: &Arc<Self>, config: ProxyConfig, sink: Sender<FlowUpdate>, extra_interceptor: Option<Arc<dyn Interceptor>>, ) -> Result<(), String>

Trait Implementations

impl AuditService for CoreState

fn audit_snapshot(&self, limit: usize) -> CoreAuditSnapshot

fn query_audit_snapshot<'life0, 'async_trait>( &'life0 self, query: CoreAuditQuery, ) -> Pin<Box<dyn Future<Output = CoreAuditSnapshot> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_audit_events(&self) -> Receiver<AuditEvent>

fn record_audit_events_lagged(&self, skipped: u64)

impl FlowEventHub for CoreState

fn subscribe_flow_updates(&self) -> Receiver<FlowUpdate>

fn redact_flow_update_for_output(&self, update: FlowUpdate) -> FlowUpdate

fn record_flow_events_lagged(&self, skipped: u64)

impl FlowReadService for CoreState

fn get_flow<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<Flow>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn search_flows<'life0, 'async_trait>( &'life0 self, query: FlowQuery, ) -> Pin<Box<dyn Future<Output = Vec<FlowSummary>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl InterceptService for CoreState

fn register_intercept<'life0, 'async_trait>( &'life0 self, key: String, tx: Sender<InterceptionResult>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn resolve_intercept_with_modifications_from<'life0, 'life1, 'async_trait>( &'life0 self, actor: AuditActor, key: String, action: &'life1 str, mods: Option<FlowModification>, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn is_flow_intercepted<'life0, 'async_trait>( &'life0 self, flow_id: String, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn intercept_snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreInterceptSnapshot> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl PolicyService for CoreState

fn policy_snapshot(&self) -> ProxyPolicy

fn update_policy_from( &self, actor: AuditActor, target: String, policy: ProxyPolicy, )

fn patch_policy_from( &self, actor: AuditActor, target: String, patch: ProxyPolicyPatch, )

impl RuleService for CoreState

fn get_rules<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<Rule>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_rule_engine<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Arc<RuleEngine>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn upsert_rule_from<'life0, 'life1, 'async_trait>( &'life0 self, actor: AuditActor, operation: &'life1 str, target: String, details: Value, rule: Rule, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete_rule_from<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, actor: AuditActor, operation: &'life1 str, target: String, details: Value, rule_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn create_mock_response_rule_from<'life0, 'async_trait>( &'life0 self, actor: AuditActor, target: String, details: Value, config: MockResponseRuleConfig, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn create_intercept_rule_from<'life0, 'async_trait>( &'life0 self, actor: AuditActor, target: String, details: Value, config: InterceptRuleConfig, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl RuntimeStatusService for CoreState

fn status_snapshot(&self) -> CoreStatusSnapshot

fn status_report<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreStatusReport> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_metrics<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CoreMetrics> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_metrics_prometheus_text<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = String> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_lifecycle(&self) -> Receiver<RuntimeLifecycle>

impl ScriptService for CoreState

fn load_script_from<'life0, 'life1, 'async_trait>( &'life0 self, actor: AuditActor, target: String, script: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,