Struct ManagedChannelPool 

pub struct ManagedChannelPool { /* private fields */ }

Self-managed pool of tonic’s Channels.

Implementations

impl ManagedChannelPool

pub fn endpoint(&self) -> &EndpointTemplate

Returns a reference to the endpoint template used by the pool.

Trait Implementations

impl ChannelPool for ManagedChannelPool

fn get_channel<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<(IpAddr, Channel)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a channel from the pool.

This function will return a channel if one is available, or None if no channels are available.

Selection algorithm

Currently, the channel is selected randomly from the pool of available channels. However, this behavior may change in the future.

Additional DNS and broken connection checks

If no channels are available, the function will check the DNS and recheck connections to all servers currently marked as dead. To avoid spamming the DNS and other servers, this will be performed no more than once every 500ms.

If the above check is running while this function is called, the function will wait for the check to finish and return the result.

If the check is not running, but the last check was performed less than 500ms ago, the function will return None immediately.

The specifics of this behavior are not set in stone and may change in the future.

fn report_broken<'life0, 'async_trait>( &'life0 self, ip_address: IpAddr, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Report a broken endpoint to the pool.

This function will remove the endpoint from the pool and add it to the list of currently dead servers.

impl Clone for ManagedChannelPool

This is a shallow clone, meaning that the new pool will reference the same resources as the original pool.

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ManagedChannelPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.