Struct ShardCacheDirectRouter 

pub struct ShardCacheDirectRouter { /* private fields */ }

Router for shard-owned SCNP direct ports.

The base address is the first shard-owned port. Shard n is expected at base_port + n; when the server also exposes a fanout port, this base is usually SHARDCACHE_DIRECT_SHARD_BASE_PORT or the fanout port + 1.

Implementations

impl ShardCacheDirectRouter

pub fn connect_shard( &self, shard_id: usize, ) -> Result<ShardCacheDirectShardClient>

Connects directly to one shard-owned port.

pub fn connect_shard_with_timeouts( &self, shard_id: usize, connect_timeout: Duration, operation_timeout: Duration, ) -> Result<ShardCacheDirectShardClient>

Connects directly to one shard-owned port with explicit deadlines.

pub fn connect_shard_with_timeouts_and_auth( &self, shard_id: usize, connect_timeout: Duration, operation_timeout: Duration, auth_token: Option<&[u8]>, ) -> Result<ShardCacheDirectShardClient>

Connects to one shard-owned port with deadlines and SCNP authentication.

impl ShardCacheDirectRouter

pub fn new(addr: impl ToSocketAddrs, shard_count: usize) -> Result<Self>

Creates a direct router for shard_count server shards.

pub fn with_route_mode(self, route_mode: ShardCacheRouteMode) -> Self

Sets how direct shard routing chooses the owning shard.

FullKey is the normal point-key mode. SessionPrefix routes keys of the form s:<session>:c:<chunk> by s:<session> while preserving the full-key hash used for lookup within that shard.

pub fn shard_count(&self) -> usize

Returns the number of direct shard ports.

pub fn route_key(&self, key: &[u8]) -> ShardCacheRoute

Computes the routed SCNP metadata for key.

pub fn shard_addr(&self, shard_id: usize) -> Result<SocketAddr>

Returns the socket address for shard_id.

Trait Implementations

impl Clone for ShardCacheDirectRouter

fn clone(&self) -> ShardCacheDirectRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ShardCacheDirectRouter

impl Debug for ShardCacheDirectRouter

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

Formats the value using the given formatter.