Struct ChannelManager 

pub struct ChannelManager { /* private fields */ }

ChannelManager implements Manager to manage a pool of Channels.

ChannelManager keeps an internal ConnectionPool in order to reuse connections across channels.

Implementations

impl ChannelManager

pub fn new(connection_pool: ConnectionPool) -> Self

Construct ChannelManager for a Channel.

By default, all channels will have publisher confirmations enabled, but you can opt out using ChannelManager::without_publisher_confirmations

pub fn without_publisher_confirmations(self) -> Self

Disable publisher confirmations.

By default, we enable publisher confirmations, but you can opt out using this flag

Trait Implementations

impl Manager for ChannelManager

Implements Manager for Channel with publisher confirms enabled.

type Type = Channel

Type of Objects that this Manager creates and recycles.

type Error = Error

Error that this Manager can return when creating and/or recycling Objects.

fn create<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Channel, Error>> + Send + 'async_trait>>

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

Creates a new instance of Manager::Type.

fn recycle<'life0, 'life1, 'async_trait>( &'life0 self, obj: &'life1 mut Channel, ) -> Pin<Box<dyn Future<Output = RecycleResult<Error>> + Send + 'async_trait>>

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

Tries to recycle an instance of Manager::Type.

fn detach(&self, _obj: &mut Self::Type)

Detaches an instance of Manager::Type from this Manager.