Struct ShardConfig 

pub struct ShardConfig {
    pub shard_count: u32,
    pub shard_by: Option<&'static str>,
}

Virtual shard settings for DeliveryMode::ConsumerGroup topics.

Fields

shard_count: u32

Number of virtual shards (hash(routing_key) % shard_count).

shard_by: Option<&'static str>

JSON payload field used for routing when publish has no explicit partition key.

Implementations

impl ShardConfig

pub const DEFAULT_SHARD_COUNT: u32 = 32

Default shard count when topic macro omits shards.

pub const fn new( shard_count: u32, shard_by: Option<&'static str>, ) -> ShardConfig

Create shard config; 0 count is replaced with Self::DEFAULT_SHARD_COUNT.

pub const fn default_count() -> ShardConfig

Default shard count with no shard_by field.

Trait Implementations

impl Clone for ShardConfig

fn clone(&self) -> ShardConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ShardConfig

impl Debug for ShardConfig

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

Formats the value using the given formatter.

impl Eq for ShardConfig

impl PartialEq for ShardConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ShardConfig