Struct InternalRedisStore

pub struct InternalRedisStore<'a> { /* private fields */ }

InternalRedisStore is a store implementation that uses Redis module APIs in that it’s designed to run from within a Redis runtime. This allows us to cut some corners around atomicity because we can safety assume that all operations will be atomic.

Implementations

impl<'a> InternalRedisStore<'a>

pub fn new(r: &'a Redis) -> InternalRedisStore<'a>

Trait Implementations

impl<'a> Store for InternalRedisStore<'a>

fn compare_and_swap_with_ttl( &mut self, key: &str, old: i64, new: i64, ttl: Duration, ) -> Result<bool, CellError>

Compares the value at the given key with a known old value and swaps it for a new value if and only if they’re equal. Also sets the key’s TTL until it expires.

fn get_with_time(&self, key: &str) -> Result<(i64, Tm), CellError>

Gets the given key’s value and the current time as dictated by the store (this is done so that rate limiters running on a variety of different nodes can operate with a consistent clock instead of using their own). If the key was unset, -1 is returned.

fn log_debug(&self, message: &str)

Logs a debug message to the data store.

fn set_if_not_exists_with_ttl( &mut self, key: &str, value: i64, ttl: Duration, ) -> Result<bool, CellError>

Sets the given key to the given value if and only if it doesn’t already exit. Whether or not the key existed previously it’s given a new TTL.