Struct Redis 

pub struct Redis {
    pub url: String,
    pub client: Option<Client>,
}

Fields

url: String

client: Option<Client>

Trait Implementations

impl CacheProvider for Redis

where Redis: Connectable,

fn get( &self, cache_space: CacheSpace, key: &str, app_name: Option<String>, ) -> String

fn set( &self, cache_space: CacheSpace, key: &str, value: Value, app_name: Option<String>, )

fn delete(&self, cache_space: CacheSpace, key: &str, app_name: Option<String>)

fn get_key_name( &self, cache_space: CacheSpace, key: &str, app_name: Option<String>, ) -> String

fn get_value(&self, app_name: Option<String>, value: Value) -> CacheValue<Value>

impl Connectable for Redis

fn set_client(&mut self)

fn get_connection(&self) -> &Client

fn get_mut_connection(&mut self) -> &mut Client

impl FifoProvider for Redis

where Redis: Connectable,

fn pop( &self, channel_name: ListChannel, job_key: &str, ) -> Result<ListMessage, &'static str>

fn push(&self, channel_name: ListChannel, job_key: &str, job_payload: Value)

fn get_list_name(&self, channel_name: &str, job_key: &str) -> String

impl ProviderTrait for Redis

fn new(url: String) -> Self

impl PubSubProvider for Redis

where Redis: Connectable,

type Channels = SubscriptionChannel

fn subscribe( &self, callback: AsyncCallback<ChannelMessage>, channel: Self::Channels, ) -> Pin<Box<dyn Future<Output = Result<(), PubSubProviderError>> + Send + '_>>

fn publish(&mut self, channel: Self::Channels, message: ChannelMessage)