Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Implementations

impl ConnectionPool

pub fn new() -> Self

pub fn with_tls(tls: ClientTlsConfig) -> Self

pub fn with_tls_and_auth(tls: ClientTlsConfig, token: String) -> Self

pub fn with_auth(token: String) -> Self

pub fn authorized_request<T>(&self, inner: T) -> Request<T>

Wrap a value in a tonic::Request with the auth token attached (if configured).

pub async fn get_transport( self: &Arc<Self>, endpoint: &str, ) -> Result<GrainTransportClient<Channel>, ClusterError>

pub async fn get_membership( self: &Arc<Self>, endpoint: &str, ) -> Result<MembershipClient<Channel>, ClusterError>

pub async fn get_gateway( self: &Arc<Self>, endpoint: &str, ) -> Result<ClusterGatewayClient<Channel>, ClusterError>

pub fn remove(&self, endpoint: &str)

Remove cached connections for an endpoint.

Called automatically when SWIM declares a member dead. Callers should also call this after persistent connection errors to force reconnection.

Note: tonic Channel handles reconnection internally for transient failures — this method is for permanent removals (dead silos) or forcing a fresh connection after repeated errors.

Trait Implementations

impl Default for ConnectionPool

fn default() -> Self

Returns the “default value” for a type.