Struct ShardCacheDirectShardClient 

pub struct ShardCacheDirectShardClient { /* private fields */ }

Blocking SCNP client pinned to one shard-owned port.

This is useful for thread-per-shard clients that pre-partition work.

Implementations

impl ShardCacheDirectShardClient

pub fn shard_id(&self) -> usize

Returns the shard this client is connected to.

pub fn get_into(&mut self, key: &[u8], out: &mut Vec<u8>) -> Result<bool>

Reads key into out, returning true on hit.

pub fn set(&mut self, key: &[u8], value: &[u8]) -> Result<()>

Sets key to value.

pub fn set_ex(&mut self, key: &[u8], value: &[u8], ttl_ms: u64) -> Result<()>

Sets key to value with a millisecond TTL.

pub fn get_ex_into( &mut self, key: &[u8], ttl_ms: u64, out: &mut Vec<u8>, ) -> Result<bool>

Reads key into out and sets a millisecond TTL, returning true on hit.

pub fn del(&mut self, key: &[u8]) -> Result<bool>

Deletes key, returning true when an entry was removed.

pub fn exists(&mut self, key: &[u8]) -> Result<bool>

Returns whether key exists.

pub fn ttl(&mut self, key: &[u8]) -> Result<i64>

Returns Redis-compatible TTL seconds for key.

pub fn expire(&mut self, key: &[u8], ttl_ms: u64) -> Result<bool>

Sets a millisecond TTL on key, returning true when the TTL changed.

pub fn scan_resp_into( &mut self, cursor: u64, count: usize, out: &mut Vec<u8>, ) -> Result<bool>

Runs a shard-local SCNP scan on this shard-owned connection.

pub fn begin_pipeline_get(&mut self, key: &[u8]) -> Result<()>

Writes a routed GET request without flushing or reading its response.

pub fn begin_pipeline_set(&mut self, key: &[u8], value: &[u8]) -> Result<()>

Writes a routed SET request without flushing or reading its response.

pub fn begin_pipeline_set_ex( &mut self, key: &[u8], value: &[u8], ttl_ms: u64, ) -> Result<()>

Writes a routed SETEX request without flushing or reading its response.

pub fn begin_pipeline_get_ex(&mut self, key: &[u8], ttl_ms: u64) -> Result<()>

Writes a routed GETEX request without flushing or reading its response.

pub fn begin_pipeline_del(&mut self, key: &[u8]) -> Result<()>

Writes a routed DEL request without flushing or reading its response.

pub fn begin_pipeline_exists(&mut self, key: &[u8]) -> Result<()>

Writes a routed EXISTS request without flushing or reading its response.

pub fn begin_pipeline_ttl(&mut self, key: &[u8]) -> Result<()>

Writes a routed TTL request without flushing or reading its response.

pub fn begin_pipeline_expire(&mut self, key: &[u8], ttl_ms: u64) -> Result<()>

Writes a routed EXPIRE request without flushing or reading its response.

pub fn flush_pipeline(&mut self) -> Result<()>

Flushes all queued pipelined requests.

pub fn finish_pipeline_get_into(&mut self, out: &mut Vec<u8>) -> Result<bool>

Reads the next pipelined GET response.

pub fn finish_pipeline_set(&mut self) -> Result<()>

Reads the next pipelined SET response.

pub fn finish_pipeline_set_ex(&mut self) -> Result<()>

Reads the next pipelined SETEX response.

pub fn finish_pipeline_get_ex_into(&mut self, out: &mut Vec<u8>) -> Result<bool>

Reads the next pipelined GETEX response.

pub fn finish_pipeline_del(&mut self) -> Result<bool>

Reads the next pipelined DEL response.

pub fn finish_pipeline_exists(&mut self) -> Result<bool>

Reads the next pipelined EXISTS response.

pub fn finish_pipeline_ttl(&mut self) -> Result<i64>

Reads the next pipelined TTL response.

pub fn finish_pipeline_expire(&mut self) -> Result<bool>

Reads the next pipelined EXPIRE response.

Trait Implementations

impl Debug for ShardCacheDirectShardClient

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

Formats the value using the given formatter.