Struct Group 

pub struct Group<K, T, E, S = RandomState> { /* private fields */ }

Group represents a class of work and creates a space in which units of work can be executed with duplicate suppression.

Implementations

impl<K, T, E, S> Group<K, T, E, S>

where S: Default,

pub fn new() -> Group<K, T, E, S>

Create a new Group to do work with.

impl<K, T, E, S> Group<K, T, E, S>

where T: Clone, K: Hash + Eq, S: BuildHasher,

pub async fn work<Q, F>(&self, key: &Q, fut: F) -> Result<T, Option<E>>

where Q: Hash + Eq + ?Sized + Send + Sync + ToOwned<Owned = K>, F: Future<Output = Result<T, E>> + Send, K: Borrow<Q>,

Execute and return the value for a given function, making sure that only one operation is in-flight at a given moment.

• If a duplicate call comes in, that caller will wait until the original call completes and return the same value.
• If the leader returns an error, owner call returns error, others will return Err(None).

pub async fn work_no_retry<Q, F>( &self, key: &Q, fut: F, ) -> Result<T, GroupWorkError<E>>

where Q: Hash + Eq + ?Sized + Send + Sync + ToOwned<Owned = K>, F: Future<Output = Result<T, E>> + Send, K: Borrow<Q>,

Execute and return the value for a given function, making sure that only one operation is in-flight at a given moment.

• If a duplicate call comes in, that caller will wait until the original call completes and return the same value.
• If the leader returns an error, owner call returns error, others will return Err(GroupWorkError::LeaderFailed).
• If the leader drops, the call will return Err(GroupWorkError::LeaderDropped).

Trait Implementations

impl<K, T, E, S> Debug for Group<K, T, E, S>

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

Formats the value using the given formatter.

impl<K, T, E, S> Default for Group<K, T, E, S>

where S: Default,

fn default() -> Self

Returns the “default value” for a type.