Struct KeyRouter 

pub struct KeyRouter { /* private fields */ }

Routes events to cores based on key hash.

Example

use laminar_core::tpc::{KeyRouter, KeySpec};

let router = KeyRouter::new(4, KeySpec::Columns(vec!["user_id".to_string()]));

let core_id = router.route(&event);
// core_id is 0, 1, 2, or 3 based on user_id hash

Implementations

impl KeyRouter

pub fn new(num_cores: usize, key_spec: KeySpec) -> Self

Creates a new key router.

Panics

Panics if num_cores is 0.

pub fn num_cores(&self) -> usize

Returns the number of cores this router distributes to.

pub fn key_spec(&self) -> &KeySpec

Returns a reference to the key specification.

pub fn route(&self, event: &Event) -> Result<usize, TpcError>

Routes an event to a core ID.

Returns the core ID (0..num_cores) that should process this event.

Errors

Returns an error if key extraction fails (e.g., column not found).

pub fn route_row( &self, batch: &RecordBatch, row: usize, ) -> Result<usize, TpcError>

Routes an event for a specific row to a core ID.

Use this when processing batches row-by-row.

Errors

Returns an error if key extraction fails.

Trait Implementations

impl Debug for KeyRouter

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

Formats the value using the given formatter.