Struct Cache 

pub struct Cache { /* private fields */ }

Implementations

impl Cache

pub fn new(config: Config) -> Self

pub fn create(name: &str, connection: Connection) -> Self

pub fn connections(&mut self) -> JsonValue

pub fn connection(&mut self, name: &str) -> Self

pub fn none() -> Self

pub fn is_none(&self) -> bool

pub fn is_redis(&self) -> bool

pub fn is_kafka(&self) -> bool

pub fn mode(&self) -> &'static str

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

pub fn redis_ping(&mut self) -> Result<bool, String>

pub fn redis_publish( &mut self, key: &str, value: JsonValue, ) -> Result<bool, String>

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

impl Cache

pub fn db(&mut self, db: i8) -> &mut Self

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

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

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

pub fn key_set_expireat( &mut self, key: &str, timestamp: i64, ) -> Result<bool, String>

pub fn key_set_seconds(&mut self, key: &str, s: i64) -> Result<bool, String>

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

pub fn key_query(&mut self, key: &str) -> Result<JsonValue, String>

pub fn add( &mut self, key: &str, value: JsonValue, expiration_date: u64, ) -> Result<bool, String>

pub fn get(&mut self, key: &str) -> Result<JsonValue, String>

pub fn set_add( &mut self, key: &str, value: JsonValue, expiry_s: i64, ) -> Result<bool, String>

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

pub fn set_get(&mut self, key: &str) -> Result<JsonValue, String>

pub fn set_delete( &mut self, key: &str, value: JsonValue, ) -> Result<bool, String>

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

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

pub fn list_add( &mut self, key: &str, value: JsonValue, expiry_s: i64, ) -> Result<bool, String>

pub fn list_del(&mut self, key: &str, value: JsonValue) -> Result<bool, String>

pub fn list_lpush( &mut self, key: &str, value: JsonValue, expiry_s: i64, ) -> Result<bool, String>

pub fn list_rpush( &mut self, key: &str, value: JsonValue, expiry_s: i64, ) -> Result<bool, String>

pub fn list_lpop( &mut self, key: &str, count: usize, ) -> Result<Vec<JsonValue>, String>

pub fn list_rpop( &mut self, key: &str, count: usize, ) -> Result<Vec<JsonValue>, String>

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

pub fn list_range( &mut self, key: &str, start: isize, stop: isize, ) -> Result<Vec<JsonValue>, String>

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

pub fn list_get(&mut self, key: &str, index: isize) -> Result<JsonValue, String>

pub fn list_trim( &mut self, key: &str, start: isize, stop: isize, ) -> Result<bool, String>

pub fn list_set( &mut self, key: &str, index: isize, value: JsonValue, ) -> Result<bool, String>

pub fn list_remove( &mut self, key: &str, value: JsonValue, count: isize, ) -> Result<isize, String>

pub fn hash_get(&mut self, key: &str) -> Result<JsonValue, String>

pub fn hash_add( &mut self, key: &str, field: &str, value: JsonValue, ) -> Result<bool, String>

pub fn hash_get_field_value( &mut self, key: &str, field: &str, ) -> Result<JsonValue, String>

pub fn hash_get_fields(&mut self, key: &str) -> Result<JsonValue, String>

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

pub fn hash_get_values(&mut self, key: &str) -> Result<JsonValue, String>

pub fn geo_add( &mut self, key: &str, longitude: f64, latitude: f64, value: JsonValue, ) -> Result<bool, String>

pub fn geo_get( &mut self, key: &str, value: JsonValue, ) -> Result<JsonValue, String>

pub fn geo_dist( &mut self, key: &str, value1: JsonValue, value2: JsonValue, ) -> Result<JsonValue, String>

pub fn geo_radius( &mut self, key: &str, value: JsonValue, radius: &str, ) -> Result<JsonValue, String>

pub fn stream_add( &mut self, key: &str, msg_id: &str, field: &str, value: JsonValue, ) -> Result<String, String>

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

pub fn stream_get(&mut self, key: &str) -> Result<JsonValue, String>

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

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

pub fn stream_group_add_user( &mut self, key: &str, group: &str, user: &str, ) -> Result<bool, String>

pub fn stream_group_del_user( &mut self, key: &str, group: &str, user: &str, ) -> Result<bool, String>

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

pub fn stream_group_msg( &mut self, key: &str, group: &str, user: &str, ) -> Result<JsonValue, String>

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

pub fn stream_get_stream(&mut self, key: &str) -> Result<JsonValue, String>

pub fn subscribe( &mut self, key: &str, tx: Sender<JsonValue>, ) -> Result<(), String>

pub fn subscribe_with_reconnect( &self, key: &str, tx: Sender<JsonValue>, ) -> Result<(), String>

pub fn publish(&mut self, key: &str, value: JsonValue) -> Result<bool, String>

impl Cache

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

pub fn kafka_create_topic(&self, topic: &str) -> Result<bool, String>

pub fn kafka_consume( &self, topic: &str, key: &str, only_one: bool, ) -> Result<JsonValue, String>

pub fn kafka_publish_with_key( &self, topic: &str, key: &str, data: JsonValue, ) -> Result<bool, String>

Trait Implementations

impl Clone for Cache

fn clone(&self) -> Cache

Returns a duplicate of the value.

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

Performs copy-assignment from source.