Struct InMemoryGroupStore 

pub struct InMemoryGroupStore { /* private fields */ }

Default in-process group store (one Mutex<HashMap>).

Implementations

impl InMemoryGroupStore

pub fn new() -> InMemoryGroupStore

Trait Implementations

impl Default for InMemoryGroupStore

fn default() -> InMemoryGroupStore

Returns the “default value” for a type.

impl GroupStore for InMemoryGroupStore

fn append(&self, key: &str, msg: Message) -> (Vec<Message>, Instant)

Append msg to the group keyed by key, returning a snapshot of the group (post-append) and the Instant the group was first seen.

fn take(&self, key: &str) -> Option<Vec<Message>>

Remove and return the group keyed by key. Called once completion fires.

fn clear(&self)

Drop every in-progress group. Primarily a test utility.