Struct ConsumerGroup 

pub struct ConsumerGroup { /* private fields */ }

A consumer group modeled as a routing function over a mutable consumer set.

Implementations

impl ConsumerGroup

pub fn new(routing_function: RoutingFunction) -> Self

Creates a consumer group with no active consumers.

pub fn routing_function(&self) -> RoutingFunction

Returns the routing function associated with this group.

pub fn consumers(&self) -> Vec<ConsumerId>

Returns the ordered, deduplicated active consumer identifiers.

pub fn snapshot(&self) -> ConsumerGroupSnapshot

Returns a stable dispatch-boundary snapshot of the group.

pub fn add_consumer(&self, registration: ConsumerRegistration) -> bool

Adds or updates a consumer, returning true when the id was newly inserted.

pub fn remove_consumer(&self, consumer: &ConsumerId) -> bool

Removes a consumer from future group snapshots.

Trait Implementations

impl Clone for ConsumerGroup

fn clone(&self) -> ConsumerGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerGroup

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

Formats the value using the given formatter.