Struct mz_balancerd::PgwireBalancer

pub(crate) struct PgwireBalancer {
    pub(crate) tls: Option<ReloadingTlsConfig>,
    pub(crate) internal_tls: bool,
    pub(crate) cancellation_resolver: Arc<CancellationResolver>,
    pub(crate) resolver: Arc<Resolver>,
    pub(crate) metrics: ServerMetrics,
}

Fields

tls: Option<ReloadingTlsConfig>

internal_tls: bool

cancellation_resolver: Arc<CancellationResolver>

resolver: Arc<Resolver>

metrics: ServerMetrics

Implementations

impl PgwireBalancer

pub(crate) async fn run<'a, A>( conn: &'a mut FramedConn<A>, version: i32, params: BTreeMap<String, String>, resolver: &Resolver, tls_mode: Option<TlsMode>, internal_tls: bool, metrics: &ServerMetrics, ) -> Result<(), Error>

where A: AsyncRead + AsyncWrite + AsyncReady + Send + Sync + Unpin,

pub(crate) async fn init_stream<'a, A>( conn: &'a mut FramedConn<A>, envd_addr: SocketAddr, password: Option<String>, params: BTreeMap<String, String>, internal_tls: bool, ) -> Result<Conn<TcpStream>, Error>

where A: AsyncRead + AsyncWrite + AsyncReady + Send + Sync + Unpin,

Trait Implementations

impl Server for PgwireBalancer

const NAME: &'static str = "pgwire_balancer"

Returns the name of the connection handler for use in e.g. log messages.

fn handle_connection(&self, conn: Connection) -> ConnectionHandler

Handles a single connection.