Struct EntHandler 

pub struct EntHandler { /* private fields */ }

Implementations

impl EntHandler

pub fn new( db: Arc<Database>, max_statement_bytes: usize, query_timeout_ms: u64, metrics: Arc<ServerMetrics>, await_durable: bool, ) -> Self

Trait Implementations

impl ExtendedQueryHandler for EntHandler

type Statement = String

type QueryParser = NoopQueryParser

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

Get a reference to associated QueryParser implementation

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

where C: ClientInfo + Unpin + Send + Sync + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: '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, stmt: &'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 = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: '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 = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + ClientPortalStore + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as ClientPortalStore>::PortalStore: PortalStore<Statement = Self::Statement>, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: '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 = Result<(), PgWireError>> + Send + 'async_trait>>

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

Called when client sends execute command.

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

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

Called when client sends describe command.

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

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

Called when client sends flush command.

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

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: '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 = Result<(), PgWireError>> + Send + 'async_trait>>

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

Called when client sends close command.

impl SimpleQueryHandler for EntHandler

fn do_query<'a, 'life0, 'life1, 'async_trait, C>( &'life0 self, _client: &'life1 mut C, query: &'a str, ) -> Pin<Box<dyn Future<Output = PgWireResult<Vec<Response<'a>>>> + 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, 'a: 'async_trait, 'life0: 'async_trait, 'life1: '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 = Result<(), PgWireError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send + Sync + 'async_trait, <C as Sink<PgWireBackendMessage>>::Error: Debug, PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>, Self: '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.