Enum Connection 

pub enum Connection {
    Embedded(Store),
    Remote(RespClient),
}

One open connection to a kevy backend, opaque about whether the backend is in-process or over TCP.

Variants

Embedded(Store)

In-process kevy_embedded::Store.

Remote(RespClient)

TCP kevy_resp_client::RespClient.

Implementations

impl Connection

pub fn open(url: &str) -> Result<Self>

Open a backend chosen by URL scheme.

See the crate-level docs for the supported URL forms.

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

PING. Returns () on +PONG, propagates any IO or RESP error. The first thing every healthcheck calls.

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

SET key value. Unconditional set (no NX/XX). Returns () on success.

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

GET key. None if absent or expired.

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

DEL key [key ...]. Returns the count of keys that were actually removed (existing + dropped). Missing keys don’t contribute.

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

EXISTS key [key ...]. Count of keys present (a single key can contribute >1 if passed multiple times, matching Redis semantics).

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

INCR key. Returns the post-increment value. Errors on non-integer stored value.

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

INCRBY key delta. Negative delta is DECRBY. Returns post-value.

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

PEXPIRE key ttl_ms. Returns whether the key existed and got a TTL.

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

PERSIST key. Returns whether a TTL was actually removed.

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

PTTL key. Returns ms remaining, -2 if no key, -1 if key has no TTL.

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

TYPE key. Returns the value’s type as a Redis-style string (e.g. "string", "hash", "list", "set", "zset", or "none" if the key doesn’t exist).

pub fn dbsize(&mut self) -> Result<usize>

DBSIZE. Total live keys at the time of the call.

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

FLUSHDB. Drops every key. Persistence remains opted-in; embedded with_persist will rewrite the AOF on its next sync cycle.

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

SET key value PX ttl_ms. Convenience for the common “cache with expiry” pattern; equivalent to set + expire but atomic.

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

HSET key field value [field value ...]. Returns the number of fields that were newly added (not overwrites).

pub fn hget(&mut self, key: &[u8], field: &[u8]) -> Result<Option<Vec<u8>>>

HGET key field. None when the key or field is absent.

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

HDEL key field [field ...]. Returns the number of fields actually removed.

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

HLEN key. Number of fields in the hash (0 if absent).

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

HGETALL key. Returns a flat [f0, v0, f1, v1, ...] matching the Redis wire shape; empty when the key is absent.

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

HKEYS key. Returns the hash’s field names (empty if absent).

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

HVALS key. Returns the hash’s values (empty if absent).

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

LPUSH key value [value ...]. Returns the new list length.

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

RPUSH key value [value ...]. Returns the new list length.

pub fn lpop(&mut self, key: &[u8], count: usize) -> Result<Vec<Vec<u8>>>

LPOP key count. Returns up to count values from the head; empty when the key is absent or already drained.

pub fn rpop(&mut self, key: &[u8], count: usize) -> Result<Vec<Vec<u8>>>

RPOP key count. Symmetric to Self::lpop from the tail.

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

LLEN key. 0 when the key is absent.

pub fn lrange( &mut self, key: &[u8], start: i64, stop: i64, ) -> Result<Vec<Vec<u8>>>

LRANGE key start stop. Redis-style indexing — negative offsets count from the tail (-1 = last element).

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

SADD key member [member ...]. Returns count of newly added members.

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

SREM key member [member ...]. Returns count of removed members.

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

SMEMBERS key. Order is implementation-defined; empty if absent.

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

SCARD key. 0 when the key is absent.

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

SISMEMBER key member. false when key or member absent.

pub fn zadd(&mut self, key: &[u8], pairs: &[(f64, &[u8])]) -> Result<usize>

ZADD key score member [score member ...]. Returns count of newly added members (overwrites don’t count).

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

ZREM key member [member ...]. Returns count of removed members.

pub fn zscore(&mut self, key: &[u8], member: &[u8]) -> Result<Option<f64>>

ZSCORE key member. None if absent.

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

ZCARD key. Number of members; 0 if absent.

pub fn zrange( &mut self, key: &[u8], start: i64, stop: i64, ) -> Result<Vec<Vec<u8>>>

ZRANGE key start stop. Ascending-score order; negative indices count from the tail.

pub fn publish(&mut self, channel: &[u8], message: &[u8]) -> Result<usize>

PUBLISH channel message. Returns the count of subscribers that received the message.

On the embedded backend there are no subscribers (single process, no reactor), so this returns Ok(0) — matching Redis’s “publish to a channel with no listeners” semantic.

The pub/sub consumer side lives in Subscriber, which takes its own dedicated TCP connection: a subscribed connection cannot send normal commands per the Redis/RESP spec, so it can’t share a socket with this Connection.