Struct PoolBuilder 

pub struct PoolBuilder<D: Deliverable> { /* private fields */ }

Implementations

impl<D: Deliverable> PoolBuilder<D>

pub fn build(self) -> Result<Pool<D>, SpawnError>

pub fn build_with_adaptor<A>(self) -> Result<Pool<D>, SpawnError>

where A: ConnectorAdaptor<GaiResolver>, A::Connect: 'static + Clone + Send + Sync,

Create the pool with a ConnectorAdaptor, a type that is used to wrap the hyper::Client’s connector

pub fn build_with_adaptor_and_resolver<A, CR>( self, ) -> Result<Pool<D>, SpawnError>

where A: ConnectorAdaptor<CR::Resolver>, A::Connect: 'static + Clone + Send + Sync, CR: CreateResolver, CR::Resolver: 'static + Clone + Send + Sync + Service<Name>, CR::Error: 'static + Send + Sync + Error, CR::Future: Send + Future<Output = Result<CR::Response, CR::Error>>, CR::Response: Iterator<Item = SocketAddr>,

Create the pool with a ConnectorAdaptor, a type that is used to wrap the hyper::Client’s connector

pub fn transaction_counters( self, value: Arc<RwLock<Vec<TransactionCounter>>>, ) -> Self

Pass in an synchronized Vec<Weak> that will be populated with transaction counters for each of the workers spawned.

You can check that the WeakCounter is still valid by ensuring that the Arc::strong_count on the Weak reference