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: TcpStream) -> ConnectionHandler
fn handle_connection(&self, conn: TcpStream) -> 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<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.
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
.