Struct PartitionConsumerInfo 

pub struct PartitionConsumerInfo { /* private fields */ }

Snapshot of the currently attached consumers handed to a PartitionHub partitioner. The partitioner returns a consumer_id (isize) to route to, or -1 to drop the element.

Implementations

impl PartitionConsumerInfo

pub fn size(&self) -> usize

Number of currently attached consumers.

pub fn consumer_ids(&self) -> &[u64]

IDs of the currently attached consumers.

pub fn consumer_id_by_idx(&self, idx: usize) -> u64

The consumer ID at position idx (panics if out of range — use with idx < size()).

pub fn queue_size(&self, consumer_id: u64) -> usize

Current queued (pending) element count for consumer_id; 0 if it is unknown.

Trait Implementations

impl Clone for PartitionConsumerInfo

fn clone(&self) -> PartitionConsumerInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionConsumerInfo

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

Formats the value using the given formatter.