Struct MockClient 

pub struct MockClient {
    pub sent_messages: Vec<PgWireBackendMessage>,
    /* private fields */
}

Fields

sent_messages: Vec<PgWireBackendMessage>

Implementations

impl MockClient

pub fn new() -> MockClient

pub fn sent_messages(&self) -> &[PgWireBackendMessage]

Trait Implementations

impl ClientInfo for MockClient

fn socket_addr(&self) -> SocketAddr

Returns the client’s socket address.

fn is_secure(&self) -> bool

Returns whether the connection is secured (TLS).

fn protocol_version(&self) -> ProtocolVersion

Returns the protocol version negotiated with the client.

fn set_protocol_version(&mut self, _version: ProtocolVersion)

Sets the protocol version for this connection.

fn pid_and_secret_key(&self) -> (i32, SecretKey)

Returns the process ID and secret key used for cancel requests.

fn set_pid_and_secret_key(&mut self, _pid: i32, _secret_key: SecretKey)

Sets the process ID and secret key for cancel requests.

fn state(&self) -> PgWireConnectionState

Returns the current connection state.

fn set_state(&mut self, _new_state: PgWireConnectionState)

Transitions the connection to a new state.

fn transaction_status(&self) -> TransactionStatus

Returns the current transaction status.

fn set_transaction_status(&mut self, _new_status: TransactionStatus)

Updates the transaction status.

fn metadata(&self) -> &HashMap<String, String>

Returns the connection metadata key-value map.

fn metadata_mut(&mut self) -> &mut HashMap<String, String>

Returns a mutable reference to the connection metadata.

fn client_certificates<'a>(&self) -> Option<&[CertificateDer<'a>]>

Returns the client TLS certificates, if available.

fn sni_server_name(&self) -> Option<&str>

Returns the TLS SNI server name, if available.

fn session_extensions(&self) -> &SessionExtensions

Returns the per-session extension store.

impl ClientPortalStore for MockClient

type PortalStore = MemPortalStore<(String, Option<(Statement, LogicalPlan)>)>

The underlying portal store type.

fn portal_store(&self) -> &Self::PortalStore

Returns a reference to the portal store.

impl Debug for MockClient

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

Formats the value using the given formatter.

impl Default for MockClient

fn default() -> MockClient

Returns the “default value” for a type.

impl Sink<PgWireBackendMessage> for MockClient

type Error = Error

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut Self>, item: PgWireBackendMessage, ) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.