Struct RedisPersistence

pub struct RedisPersistence { /* private fields */ }

The MQTT Redis persistence object. An instance of this stuct can be residtered with an MQTT client to hold messgaes in a Redis server until they are properly acknowledged by the remote MQTT server. An instance of this object maps to a single hash on a specific Redis server.

Implementations

impl RedisPersistence

pub fn new() -> Self

Create a new persistence object to connect to a local Redis server.

Trait Implementations

impl ClientPersistence for RedisPersistence

fn open(&mut self, client_id: &str, server_uri: &str) -> Result<()>

Opena the connection to the Redis client.

fn close(&mut self) -> Result<()>

Close the connection to the Redis client.

fn put(&mut self, key: &str, buffers: Vec<&[u8]>) -> Result<()>

Store a persistent value to Redis. We get a vector of buffer references for the data to store, which we can concatenate into a single byte buffer to send to the server.

fn get(&mut self, key: &str) -> Result<Vec<u8>>

Get the data buffer for the requested key. Although the value sent to the server was a collection of buffers, we can return them as a single, concatenated buffer.

fn remove(&mut self, key: &str) -> Result<()>

Remove the value with the specified key from the store.

fn keys(&mut self) -> Result<Vec<String>>

Return a collection of all the keys in the store for this client.

fn clear(&mut self) -> Result<()>

Remove all the data for this client from the store.

fn contains_key(&mut self, key: &str) -> bool

Determines if the store for this client contains the specified key.

impl Default for RedisPersistence

fn default() -> Self

Create a new persistence object to connect to the Redis server on localhost.