Enum KeySpec 

pub enum KeySpec {
    Columns(Vec<String>),
    ColumnIndices(Vec<usize>),
    RoundRobin,
    AllColumns,
}

Specifies how to extract routing keys from events.

The key determines which core processes an event. All events with the same key are guaranteed to go to the same core.

Variants

Columns(Vec<String>)

Use specific column names as the key.

The columns are concatenated in order to form the key.

ColumnIndices(Vec<usize>)

Use column indices as the key.

Useful when column names are not known or for performance.

RoundRobin

Round-robin distribution (no key).

Events are distributed evenly across cores without regard to content. Use this when state locality is not required.

AllColumns

Use all columns as the key.

The entire row is hashed to determine routing.

Trait Implementations

impl Clone for KeySpec

fn clone(&self) -> KeySpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KeySpec

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

Formats the value using the given formatter.

impl Default for KeySpec

fn default() -> KeySpec

Returns the “default value” for a type.