Struct RedisStore

pub struct RedisStore { /* private fields */ }

Defines a context that uses redis for the back-end storage.

Implementations

impl RedisStore

pub async fn new( cfg: &Config, name: Option<String>, pword: Option<String>, ) -> Result<Self>

Builds a new backend context which interacts with redis. The parameters in cfg will be used to locate the redis instance. If name and pword are not None, they will be used for credentials when connecting to redis.

Trait Implementations

impl Store for RedisStore

fn register_read_only_device<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, driver_name: &'life1 str, name: &'life2 Name, units: &'life3 Option<String>, max_history: &'life4 Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<(ReportReading<Value>, Option<Value>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Registers a device in the redis backend.

fn register_read_write_device<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, driver_name: &'life1 str, name: &'life2 Name, units: &'life3 Option<String>, max_history: &'life4 Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<(ReportReading<Value>, RxDeviceSetting, Option<Value>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Called when a read-write device is to be registered with the back-end.

fn get_device_info<'life0, 'life1, 'async_trait>( &'life0 mut self, pattern: &'life1 Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<DevInfoReply>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when information from a device is requested.

fn set_device<'life0, 'async_trait>( &'life0 self, name: Name, value: Value, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends a request to a driver to set its device to the specified value.

fn get_setting_chan<'life0, 'async_trait>( &'life0 self, name: Name, _own: bool, ) -> Pin<Box<dyn Future<Output = Result<TxDeviceSetting>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Obtains the mpsc::Sender<> handle associated with the specified device. This handle can be used to send settings to the device. If ’ownis set totrue, the requester will be the only one that can send settings to the device. NOTE: own` is currently unsupported and should always be set to ‘false’. When it gets supported, requesters can decide whether they should set it to true.

fn monitor_device<'life0, 'async_trait>( &'life0 mut self, name: Name, start: Option<DateTime<Utc>>, end: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<DataStream<Reading>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates a stream that yields values of a device as it updates.