Struct PostgresProtocol 

pub struct PostgresProtocol {}

PostgreSQL protocol adapter implementation

Implementations

impl PostgresProtocol

pub fn new() -> Self

Create a new PostgreSQL protocol adapter

Trait Implementations

impl Debug for PostgresProtocol

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

Formats the value using the given formatter.

impl Default for PostgresProtocol

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolAdapter for PostgresProtocol

fn accept_connection<'life0, 'async_trait>( &'life0 self, stream: TcpStream, ) -> Pin<Box<dyn Future<Output = NirvResult<Connection>> + Send + 'async_trait>>

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

Accept a new connection and perform initial handshake

fn authenticate<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Connection, credentials: Credentials, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

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

Authenticate a connection with provided credentials

fn handle_query<'life0, 'life1, 'async_trait>( &'life0 self, _conn: &'life1 Connection, _query: ProtocolQuery, ) -> Pin<Box<dyn Future<Output = NirvResult<ProtocolResponse>> + Send + 'async_trait>>

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

Handle a query from the client and return a response

fn get_protocol_type(&self) -> ProtocolType

Get the protocol type this adapter handles

fn parse_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _conn: &'life1 Connection, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = NirvResult<ProtocolQuery>> + Send + 'async_trait>>

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

Parse protocol-specific message into internal representation

fn format_response<'life0, 'life1, 'async_trait>( &'life0 self, _conn: &'life1 Connection, result: QueryResult, ) -> Pin<Box<dyn Future<Output = NirvResult<Vec<u8>>> + Send + 'async_trait>>

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

Format internal query result into protocol-specific response

fn terminate_connection<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Connection, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

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

Handle connection termination