Struct mz_pgwire_common::ConnectionCounter
source · pub struct ConnectionCounter {
inner: Arc<Mutex<ConnectionCounterInner>>,
}
Fields§
§inner: Arc<Mutex<ConnectionCounterInner>>
Implementations§
source§impl ConnectionCounter
impl ConnectionCounter
sourcepub fn allocate_connection(
&self,
metadata: impl Into<UserMetadata>,
) -> Result<Option<ConnectionHandle>, ConnectionError>
pub fn allocate_connection( &self, metadata: impl Into<UserMetadata>, ) -> Result<Option<ConnectionHandle>, ConnectionError>
Returns a ConnectionHandle
which must be kept alive for the entire duration of the
external connection.
Dropping the ConnectionHandle
decrements the connection count.
sourcepub fn update_limit(&self, new_limit: u64)
pub fn update_limit(&self, new_limit: u64)
Updates the maximum number of connections we allow.
sourcepub fn update_superuser_reserved(&self, new_reserve: u64)
pub fn update_superuser_reserved(&self, new_reserve: u64)
Updates the number of connections we reserve for superusers.
fn create_handle(&self) -> ConnectionHandle
Trait Implementations§
source§impl Clone for ConnectionCounter
impl Clone for ConnectionCounter
source§fn clone(&self) -> ConnectionCounter
fn clone(&self) -> ConnectionCounter
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ConnectionCounter
impl Debug for ConnectionCounter
Auto Trait Implementations§
impl Freeze for ConnectionCounter
impl RefUnwindSafe for ConnectionCounter
impl Send for ConnectionCounter
impl Sync for ConnectionCounter
impl Unpin for ConnectionCounter
impl UnwindSafe for ConnectionCounter
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)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<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
.