Struct RedisObjects

pub struct RedisObjects { /* private fields */ }

Handle for a pool of connections to a redis server.

Implementations

impl RedisObjects

pub fn open_host( host: &str, port: u16, db: i64, ) -> Result<Arc<Self>, ErrorTypes>

Open given more limited connection info

pub fn open_host_native_tls( host: &str, port: u16, db: i64, ) -> Result<Arc<Self>, ErrorTypes>

Open a connection using the local tls configuration

pub fn open(config: ConnectionInfo) -> Result<Arc<Self>, ErrorTypes>

Open a connection pool

pub fn priority_queue<T: Serialize + DeserializeOwned>( self: &Arc<Self>, name: String, ) -> PriorityQueue<T>

Open a priority queue under the given key

pub fn queue<T: Serialize + DeserializeOwned>( self: &Arc<Self>, name: String, ttl: Option<Duration>, ) -> Queue<T>

Open a FIFO queue under the given key

pub fn multiqueue<T: Serialize + DeserializeOwned>( self: &Arc<Self>, prefix: String, ) -> MultiQueue<T>

an object that represents a set of queues with a common prefix

pub fn hashmap<T: Serialize + DeserializeOwned>( self: &Arc<Self>, name: String, ttl: Option<Duration>, ) -> Hashmap<T>

Open a hash map under the given key

pub fn publisher(self: &Arc<Self>, channel: String) -> Publisher

Create a sink to publish messages to a named channel

pub async fn publish( &self, channel: &str, data: &[u8], ) -> Result<u32, ErrorTypes>

Write a message directly to the channel given

pub async fn publish_json<T: Serialize>( &self, channel: &str, value: &T, ) -> Result<u32, ErrorTypes>

Write a json message directly to the channel given

pub fn auto_exporting_metrics<T: MetricMessage>( self: &Arc<Self>, name: String, counter_type: String, ) -> AutoExportingMetricsBuilder<T>

Start building a metrics exporter

pub fn pubsub_json_listener<T: DeserializeOwned + Send + 'static>( self: &Arc<Self>, ) -> JsonListenerBuilder<T>

Start building a json listener that produces a stream of events

pub fn subscribe_json<T: DeserializeOwned + Send + 'static>( self: &Arc<Self>, channel: String, ) -> Receiver<Option<T>>

Build a json listener that produces a stream of events using the default configuration

pub fn pubsub_listener(self: &Arc<Self>) -> ListenerBuilder

Start building a raw data listener that produces a stream of events

pub fn subscribe(self: &Arc<Self>, channel: String) -> Receiver<Option<Msg>>

Build a raw data listener that produces a stream of events using the default configuration

pub fn user_quota_tracker(self: &Arc<Self>, prefix: String) -> UserQuotaTracker

Open an interface for tracking user quotas on redis

pub fn set<T: Serialize + DeserializeOwned>( self: &Arc<Self>, name: String, ) -> Set<T>

Open a set of values

pub fn expiring_set<T: Serialize + DeserializeOwned>( self: &Arc<Self>, name: String, ttl: Option<Duration>, ) -> Set<T>

Open a set of values with an expiration policy

pub async fn wipe(&self) -> Result<(), ErrorTypes>

Erase all data on the redis server

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

List all keys on the redis server that satisfies the given pattern