Struct IdentityIntermediaryMiddleware 

pub struct IdentityIntermediaryMiddleware;

Identity forwarding-boundary middleware.

Trait Implementations

impl Clone for IdentityIntermediaryMiddleware

fn clone(&self) -> IdentityIntermediaryMiddleware

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for IdentityIntermediaryMiddleware

impl Debug for IdentityIntermediaryMiddleware

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IdentityIntermediaryMiddleware

fn default() -> IdentityIntermediaryMiddleware

Returns the “default value” for a type.

impl Eq for IdentityIntermediaryMiddleware

impl<State, ServerContext, ClientContext> IntermediaryMiddleware<State, ServerContext, ClientContext> for IdentityIntermediaryMiddleware

type Error = Infallible

Application-defined interception failure.

async fn frontend( &mut self, _server: &ServerContext, _client: &ClientContext, _state: &mut State, message: FrontendMessage, ) -> Result<FrontendMiddlewareOutput, Self::Error>

Intercepts a client-originated message after server-role middleware and before client-role middleware.

async fn frontend_operation( &mut self, server: &ServerContext, client: &ClientContext, state: &mut State, _operation: OperationId, message: FrontendMessage, ) -> Result<FrontendMiddlewareOutput, Self::Error>

Intercepts a client-originated message with the identity reserved for the operation if it is forwarded or handled locally.

async fn backend( &mut self, _server: &ServerContext, _client: &ClientContext, _state: &mut State, message: BackendMessage, ) -> Result<BackendMiddlewareOutput, Self::Error>

Intercepts a PostgreSQL-originated message after client-role middleware and before server-role middleware.

async fn backend_operation( &mut self, server: &ServerContext, client: &ClientContext, state: &mut State, _operation: Option<OperationId>, message: BackendMessage, ) -> Result<BackendMiddlewareOutput, Self::Error>

Intercepts a PostgreSQL-originated message with its frontend operation identity when the message advances an operation.

async fn flush_backend( &mut self, _server: &ServerContext, _client: &ClientContext, _state: &mut State, held: HeldBackendMessages<'_>, _reason: BackendFlushReason, ) -> Result<BackendBatchOutput, Self::Error>

Applies policy to an ordered borrowed span of retained backend messages.

async fn flush_backend_operations( &mut self, server: &ServerContext, client: &ClientContext, state: &mut State, held: AttributedBackendMessages<'_>, reason: BackendFlushReason, ) -> Result<BackendBatchOutput, Self::Error>

Applies policy to retained backend messages with operation attribution. The default preserves existing middleware by delegating to Self::flush_backend.

impl<ServerContext, ClientContext> IntermediaryMiddlewareFactory<ServerContext, ClientContext> for IdentityIntermediaryMiddleware

type Handler = IdentityIntermediaryMiddleware

Per-connection boundary handler.

fn create(&self, _server: &ServerContext, _client: &ClientContext) -> Self

Creates an isolated handler from both distinct role contexts.

impl PartialEq for IdentityIntermediaryMiddleware

fn eq(&self, other: &IdentityIntermediaryMiddleware) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for IdentityIntermediaryMiddleware