Struct RequestRouter 

pub struct RequestRouter { /* private fields */ }

Request Router for partition-aware request routing

Implementations

impl RequestRouter

pub fn new(registry: Arc<NodeRegistry>) -> Self

Create new request router

Arguments

• registry: Shared node registry for cluster topology

pub fn route_for_entity(&self, entity_id: &EntityId) -> Result<Node>

Route request for an entity

Determines the partition for the entity and finds the responsible node.

Returns

• Node: Target node to send the request to

Errors

• Returns error if no healthy node is available for the partition

pub fn route_for_partition(&self, partition_key: &PartitionKey) -> Result<Node>

Route request for a specific partition

Returns

• Node: Target node responsible for this partition

Errors

• Returns error if no healthy node is available

pub fn nodes_for_read(&self) -> Vec<Node>

Get all nodes for load-balanced read operations

Returns all healthy nodes that can serve read requests. Useful for fan-out queries across multiple nodes.

pub fn can_node_handle_entity(&self, entity_id: &EntityId, node_id: u32) -> bool

Check if a specific node can handle the entity

Useful for sticky sessions or connection pooling.

pub fn partition_distribution(&self) -> HashMap<u32, Vec<u32>>

Get partition distribution for monitoring

Returns map of node_id -> partition_ids for observability.

pub fn is_available(&self) -> bool

Check if routing is available

Returns true if cluster is healthy and can handle requests.