Struct RuleInterceptor 

pub struct RuleInterceptor { /* private fields */ }

Implementations

impl RuleInterceptor

pub fn new(state: Arc<CoreState>) -> Self

Trait Implementations

impl Interceptor for RuleInterceptor

fn on_request_headers<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 mut Flow, ) -> Pin<Box<dyn Future<Output = InterceptionResult> + Send + 'async_trait>>

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

Called after request headers are parsed but before body is read. Allows early termination or modification of headers/URL.

fn on_request<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 mut Flow, body: HttpBody, ) -> Pin<Box<dyn Future<Output = Result<RequestAction, BoxError>> + Send + 'async_trait>>

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

Called after full request (including body) is received.

fn on_response_headers<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 mut Flow, ) -> Pin<Box<dyn Future<Output = InterceptionResult> + Send + 'async_trait>>

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

Called after response headers are received from upstream but before body is read.

fn on_response<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 mut Flow, body: HttpBody, ) -> Pin<Box<dyn Future<Output = Result<ResponseAction, BoxError>> + Send + 'async_trait>>

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

Called after full response (including body) is received.

fn on_websocket_message<'life0, 'life1, 'async_trait>( &'life0 self, flow: &'life1 mut Flow, message: WebSocketMessage, ) -> Pin<Box<dyn Future<Output = Result<WebSocketMessageAction, BoxError>> + Send + 'async_trait>>

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

fn on_connect<'life0, 'life1, 'async_trait>( &'life0 self, _conn: &'life1 ConnectionInfo, ) -> Pin<Box<dyn Future<Output = ConnectAction> + Send + 'async_trait>>

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

Called when a new connection is accepted, before any HTTP handling. Return ConnectAction::Drop to reject the connection.

fn on_disconnect<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _conn: &'life1 ConnectionInfo, _stats: &'life2 ConnectionStats, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a connection is closed (after all flows complete or on drop).

fn on_websocket_start<'life0, 'life1, 'async_trait>( &'life0 self, _flow: &'life1 mut Flow, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a WebSocket handshake completes (connection established).

fn on_websocket_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _flow: &'life1 mut Flow, _close_code: u16, _close_reason: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a WebSocket connection closes normally.

fn on_websocket_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _flow: &'life1 mut Flow, _error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a WebSocket connection encounters an error.