pub struct ConnectionPool { /* private fields */ }Expand description
Connection pool for managing gRPC connections
Implementations§
Source§impl ConnectionPool
impl ConnectionPool
Sourcepub fn new(config: PoolConfig) -> Self
pub fn new(config: PoolConfig) -> Self
Create a new connection pool with default health check and no adaptive sizing
Sourcepub fn with_tls(config: PoolConfig, tls_config: ClientTlsConfig) -> Self
pub fn with_tls(config: PoolConfig, tls_config: ClientTlsConfig) -> Self
Create a new connection pool with TLS configuration
Sourcepub fn with_health_and_adaptive(
config: PoolConfig,
health_check_config: HealthCheckConfig,
adaptive_config: Option<AdaptiveConfig>,
) -> Self
pub fn with_health_and_adaptive( config: PoolConfig, health_check_config: HealthCheckConfig, adaptive_config: Option<AdaptiveConfig>, ) -> Self
Create a new connection pool with custom health check and optional adaptive sizing
Sourcepub fn with_full_config(
config: PoolConfig,
health_check_config: HealthCheckConfig,
adaptive_config: Option<AdaptiveConfig>,
tls_config: Option<ClientTlsConfig>,
) -> Self
pub fn with_full_config( config: PoolConfig, health_check_config: HealthCheckConfig, adaptive_config: Option<AdaptiveConfig>, tls_config: Option<ClientTlsConfig>, ) -> Self
Create a new connection pool with full configuration including optional TLS
Sourcepub fn add_endpoint(&self, id: EndpointId, address: String)
pub fn add_endpoint(&self, id: EndpointId, address: String)
Add an endpoint to the connection pool
Sourcepub fn add_endpoint_with_weight(
&self,
id: EndpointId,
address: String,
weight: u32,
)
pub fn add_endpoint_with_weight( &self, id: EndpointId, address: String, weight: u32, )
Add an endpoint with weight
Sourcepub fn remove_endpoint(&self, endpoint_id: &str) -> bool
pub fn remove_endpoint(&self, endpoint_id: &str) -> bool
Remove an endpoint from the connection pool
Sourcepub async fn get_connection(&self) -> NetResult<PooledConnection>
pub async fn get_connection(&self) -> NetResult<PooledConnection>
Get a connection from the pool
Sourcepub fn utilization(&self) -> f64
pub fn utilization(&self) -> f64
Get current pool utilization ratio (0.0 to 1.0)
Sourcepub fn scale_down(&self, count: usize)
pub fn scale_down(&self, count: usize)
Scale down the pool by the given number of connection slots
Sourcepub fn metrics(&self) -> PoolMetrics
pub fn metrics(&self) -> PoolMetrics
Get comprehensive pool metrics
Sourcepub fn effective_max_size(&self) -> usize
pub fn effective_max_size(&self) -> usize
Get the current effective maximum pool size
Sourcepub fn circuit_breaker_stats(&self) -> Option<CircuitBreakerStats>
pub fn circuit_breaker_stats(&self) -> Option<CircuitBreakerStats>
Get circuit breaker statistics
Auto Trait Implementations§
impl !RefUnwindSafe for ConnectionPool
impl !UnwindSafe for ConnectionPool
impl Freeze for ConnectionPool
impl Send for ConnectionPool
impl Sync for ConnectionPool
impl Unpin for ConnectionPool
impl UnsafeUnpin for ConnectionPool
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> 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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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::RequestSource§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.