Struct RemoteCacheClient 

pub struct RemoteCacheClient { /* private fields */ }

A client that connects to a remote pylon cache server.

Uses raw HTTP/1.1 over TCP to avoid pulling in heavy HTTP client dependencies. Each request opens a new connection (Connection: close). This keeps the client simple and dependency-free.

Implementations

impl RemoteCacheClient

pub fn new(base_url: &str) -> Self

Create a new client pointing at the given base URL.

The URL should be of the form http://host:port. Any trailing slash or path component is stripped.

pub fn set( &self, key: &str, value: &str, ttl: Option<u64>, ) -> Result<(), String>

SET key value [EX seconds]

pub fn get_key(&self, key: &str) -> Result<Option<String>, String>

GET key

pub fn del(&self, key: &str) -> Result<bool, String>

DEL key

pub fn exists(&self, key: &str) -> Result<bool, String>

EXISTS key

pub fn incr(&self, key: &str) -> Result<i64, String>

INCR key

pub fn decr(&self, key: &str) -> Result<i64, String>

DECR key

pub fn incrby(&self, key: &str, amount: i64) -> Result<i64, String>

INCRBY key amount

pub fn setnx( &self, key: &str, value: &str, ttl: Option<u64>, ) -> Result<bool, String>

SETNX key value [EX seconds]

pub fn getset(&self, key: &str, value: &str) -> Result<Option<String>, String>

GETSET key value

pub fn lpush(&self, key: &str, value: &str) -> Result<usize, String>

LPUSH key value

pub fn rpush(&self, key: &str, value: &str) -> Result<usize, String>

RPUSH key value

pub fn lpop(&self, key: &str) -> Result<Option<String>, String>

LPOP key

pub fn rpop(&self, key: &str) -> Result<Option<String>, String>

RPOP key

pub fn lrange( &self, key: &str, start: i64, stop: i64, ) -> Result<Vec<String>, String>

LRANGE key start stop

pub fn llen(&self, key: &str) -> Result<usize, String>

LLEN key

pub fn sadd(&self, key: &str, member: &str) -> Result<bool, String>

SADD key member

pub fn srem(&self, key: &str, member: &str) -> Result<bool, String>

SREM key member

pub fn smembers(&self, key: &str) -> Result<Vec<String>, String>

SMEMBERS key

pub fn sismember(&self, key: &str, member: &str) -> Result<bool, String>

SISMEMBER key member

pub fn scard(&self, key: &str) -> Result<usize, String>

SCARD key

pub fn hset(&self, key: &str, field: &str, value: &str) -> Result<(), String>

HSET key field value

pub fn hget(&self, key: &str, field: &str) -> Result<Option<String>, String>

HGET key field

pub fn hdel(&self, key: &str, field: &str) -> Result<bool, String>

HDEL key field

pub fn hgetall(&self, key: &str) -> Result<HashMap<String, String>, String>

HGETALL key

pub fn hexists(&self, key: &str, field: &str) -> Result<bool, String>

HEXISTS key field

pub fn hlen(&self, key: &str) -> Result<usize, String>

HLEN key

pub fn hkeys(&self, key: &str) -> Result<Vec<String>, String>

HKEYS key

pub fn hincrby( &self, key: &str, field: &str, amount: i64, ) -> Result<i64, String>

HINCRBY key field amount

pub fn zadd(&self, key: &str, score: f64, member: &str) -> Result<(), String>

ZADD key score member

pub fn zrem(&self, key: &str, member: &str) -> Result<bool, String>

ZREM key member

pub fn zscore(&self, key: &str, member: &str) -> Result<Option<f64>, String>

ZSCORE key member

pub fn zrank(&self, key: &str, member: &str) -> Result<Option<usize>, String>

ZRANK key member

pub fn zrange( &self, key: &str, start: usize, stop: usize, ) -> Result<Vec<(String, f64)>, String>

ZRANGE key start stop

pub fn zcard(&self, key: &str) -> Result<usize, String>

ZCARD key

pub fn keys(&self, pattern: &str) -> Result<Vec<String>, String>

KEYS pattern

pub fn ttl(&self, key: &str) -> Result<Option<u64>, String>

TTL key

pub fn expire(&self, key: &str, seconds: u64) -> Result<bool, String>

EXPIRE key seconds

pub fn persist(&self, key: &str) -> Result<bool, String>

PERSIST key

pub fn key_type(&self, key: &str) -> Result<String, String>

TYPE key

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

DBSIZE

pub fn flushall(&self) -> Result<(), String>

FLUSHALL

pub fn info(&self) -> Result<Value, String>

INFO

pub fn publish(&self, channel: &str, message: &str) -> Result<usize, String>

Publish a message to a channel on the remote cache server. Returns the number of subscribers notified.

pub fn channels(&self) -> Result<Vec<(String, usize)>, String>

List channels with subscriber counts.

pub fn history(&self, channel: &str, limit: usize) -> Result<Vec<Value>, String>

Get message history for a channel.

pub fn health(&self) -> Result<Value, String>

Health check – returns the server’s health response.