Enum PartitionRange 

pub enum PartitionRange {
    Single(PartitionSelector),
    Range(u16, u16),
    List(Vec<PartitionSelector>),
    All,
}

Represents a range of partitions for multi-partition subscriptions

Variants

Single(PartitionSelector)

Single partition (backwards compatibility)

Range(u16, u16)

Range of partition IDs (inclusive): “0-127”, “50-99”

List(Vec<PartitionSelector>)

Explicit list of partitions: “0,1,5,42”

All

All partitions: “*”

Implementations

impl PartitionRange

pub fn expand(&self, num_partitions: u16) -> Vec<PartitionId>

Expand the range into a vector of concrete partition IDs

Trait Implementations

impl Clone for PartitionRange

fn clone(&self) -> PartitionRange

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionRange

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

Formats the value using the given formatter.

impl FromBytesFrame<'_> for PartitionRange

fn from_bytes_frame(frame: &BytesFrame) -> Result<Self, String>

impl PartialEq for PartitionRange

fn eq(&self, other: &PartitionRange) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PartitionRange