Struct torn_key_pool::KeyPoolExecutor

pub struct KeyPoolExecutor<'a, C, S>
where
    S: KeyPoolStorage,
{ /* private fields */ }

Implementations

impl<'a, C, S> KeyPoolExecutor<'a, C, S>

where S: KeyPoolStorage,

pub fn new( storage: &'a S, selector: KeySelector<S::Key, S::Domain>, options: Arc<PoolOptions> ) -> Self

Trait Implementations

impl<'a, C: Clone, S> Clone for KeyPoolExecutor<'a, C, S>

where S: KeyPoolStorage + Clone, S::Key: Clone, S::Domain: Clone,

fn clone(&self) -> KeyPoolExecutor<'a, C, S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a, C: Debug, S> Debug for KeyPoolExecutor<'a, C, S>

where S: KeyPoolStorage + Debug, S::Key: Debug, S::Domain: Debug,

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

Formats the value using the given formatter.

impl<'client, C, S> RequestExecutor<C> for KeyPoolExecutor<'client, C, S>

where C: ApiClient, S: KeyPoolStorage + Send + Sync + 'static,

type Error = KeyPoolError<<S as KeyPoolStorage>::Error, <C as ApiClient>::Error>

fn execute<'life0, 'life1, 'async_trait, A>( &'life0 self, client: &'life1 C, request: ApiRequest<A>, id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<A::Response, Self::Error>> + Send + 'async_trait>>

where A: ApiSelection + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn execute_many<'life0, 'life1, 'async_trait, A, I>( &'life0 self, client: &'life1 C, request: ApiRequest<A>, ids: Vec<I> ) -> Pin<Box<dyn Future<Output = HashMap<I, Result<A::Response, Self::Error>>> + Send + 'async_trait>>

where A: ApiSelection + 'async_trait, I: ToString + Hash + Eq + Send + Sync + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,