Struct mz_balancerd::PgwireBalancer
source · pub(crate) struct PgwireBalancer {
pub(crate) tls: Option<ReloadingTlsConfig>,
pub(crate) cancellation_resolver: Option<Arc<PathBuf>>,
pub(crate) resolver: Arc<Resolver>,
pub(crate) metrics: ServerMetrics,
}
Fields§
§tls: Option<ReloadingTlsConfig>
§cancellation_resolver: Option<Arc<PathBuf>>
§resolver: Arc<Resolver>
§metrics: ServerMetrics
Implementations§
source§impl PgwireBalancer
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>, metrics: &ServerMetrics, ) -> Result<(), Error>
pub(crate) async fn init_stream<'a, A>( conn: &'a mut FramedConn<A>, envd_addr: SocketAddr, password: Option<String>, params: BTreeMap<String, String>, ) -> Result<TcpStream, Error>
Trait Implementations§
source§impl Server for PgwireBalancer
impl Server for PgwireBalancer
source§const NAME: &'static str = "pgwire_balancer"
const NAME: &'static str = "pgwire_balancer"
Returns the name of the connection handler for use in e.g. log messages.
source§fn handle_connection(&self, conn: Connection) -> ConnectionHandler
fn handle_connection(&self, conn: Connection) -> ConnectionHandler
Handles a single connection.
Auto Trait Implementations§
impl Freeze for PgwireBalancer
impl !RefUnwindSafe for PgwireBalancer
impl Send for PgwireBalancer
impl Sync for PgwireBalancer
impl Unpin for PgwireBalancer
impl !UnwindSafe for PgwireBalancer
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<Source, Target> OctetsInto<Target> for Sourcewhere
Target: OctetsFrom<Source>,
impl<Source, Target> OctetsInto<Target> for Sourcewhere
Target: OctetsFrom<Source>,
type Error = <Target as OctetsFrom<Source>>::Error
source§fn try_octets_into(
self,
) -> Result<Target, <Source as OctetsInto<Target>>::Error>
fn try_octets_into( self, ) -> Result<Target, <Source as OctetsInto<Target>>::Error>
Performs the conversion.
source§fn octets_into(self) -> Target
fn octets_into(self) -> Target
Performs an infallible conversion.
source§impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.