Struct NoopHandler 

pub struct NoopHandler;

A noop implementation for ErrorHandler.

Trait Implementations

impl CancelHandler for NoopHandler

fn on_cancel_request<'life0, 'async_trait>( &'life0 self, _cancel_request: CancelRequest, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

impl CopyHandler for NoopHandler

fn on_copy_data<'life0, 'life1, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _copy_data: CopyData, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn on_copy_done<'life0, 'life1, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _done: CopyDone, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn on_copy_fail<'life0, 'life1, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, fail: CopyFail, ) -> Pin<Box<dyn Future<Output = PgWireError> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Debug for NoopHandler

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

Formats the value using the given formatter.

impl ErrorHandler for NoopHandler

fn on_error<C>(&self, _client: &C, _error: &mut PgWireError)

where C: ClientInfo,

impl ExtendedQueryHandler for NoopHandler

type Statement = String

type QueryParser = NoopQueryParser

fn query_parser(&self) -> Arc<Self::QueryParser>

Get a reference to associated QueryParser implementation

fn do_query<'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _portal: &'life2 Portal<Self::Statement>, _max_rows: usize, ) -> Pin<Box<dyn Future<Output = PgWireResult<Response>> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

This is the main implementation for query execution. Context has been provided:

fn do_describe_statement<'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _statement: &'life2 StoredStatement<Self::Statement>, ) -> Pin<Box<dyn Future<Output = PgWireResult<DescribeStatementResponse>> + Send + 'async_trait>>

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Return resultset metadata without actually executing statement

fn do_describe_portal<'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _portal: &'life2 Portal<Self::Statement>, ) -> Pin<Box<dyn Future<Output = PgWireResult<DescribePortalResponse>> + Send + 'async_trait>>

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Return resultset metadata without actually executing portal

fn on_parse<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Parse, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends parse command.

fn on_bind<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Bind, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends bind command.

fn on_execute<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Execute, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends execute command.

fn _on_execute<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Execute, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The default implementation of on_execute.

fn on_describe<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Describe, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends describe command.

fn _on_describe<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Describe, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The default implementation of on_describe

fn on_flush<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, _message: Flush, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends flush command.

fn on_sync<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, _message: PgSync, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends sync command.

fn on_close<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, message: Close, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::PortalStore: PortalStore<Statement = Self::Statement>, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when client sends close command.

impl NoopStartupHandler for NoopHandler

fn post_startup<'life0, 'life1, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _message: PgWireFrontendMessage, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl SimpleQueryHandler for NoopHandler

fn do_query<'life0, 'life1, 'life2, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, _query: &'life2 str, ) -> Pin<Box<dyn Future<Output = PgWireResult<Vec<Response>>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Provide your query implementation using the incoming query string.

fn on_query<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, query: Query, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executed on Query request arrived. This is how postgres respond to simple query. The default implementation calls do_query with the incoming query string.

fn _on_query<'life0, 'life1, 'async_trait, C>( &'life0 self, client: &'life1 mut C, query: Query, ) -> Pin<Box<dyn Future<Output = PgWireResult<()>> + Send + 'async_trait>>

where C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, C::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

This is the default implementation of on_query. If you want to override on_query with your own pre/post processing logic, you can call this function.