Struct merino_cache::redis::SimpleRedisLock

pub struct SimpleRedisLock {
    connection: ConnectionManager,
}

Very simple Redis Lock mechanism.

Fields

connection: ConnectionManager

connection handler

Implementations

impl SimpleRedisLock

fn lock_key(key: &str) -> String

Generate a lock identifier key.

This is a VERY simple locking mechanism. The only bit of fancy is that it will expire, allowing for “stuck” queries to eventually resolve.

async fn is_locked(&mut self, key: &str) -> Result<bool, SuggestError>

See if a record update is locked for pending update.

This does not check lock value, only if a lock exists.

async fn lock(
    &mut self,
    key: &str,
    default_lock_timeout: Duration
) -> Result<Option<String>, SuggestError>

Generate a lock, this returns a unique Lock value string to ensure that only the thread with the most recent “lock” can write to this key.

This will return a None if the lock could not be created.

async fn write_if_locked(
    &mut self,
    key: &str,
    lock: &str,
    to_store: RedisSuggestions,
    ttl: Duration
) -> Result<(), SuggestError>

Only write a given item if the lock matches the value we have on hand.

Silently fails and discards if the lock is invalid.

Trait Implementations

impl Clone for SimpleRedisLock

fn clone(&self) -> SimpleRedisLock

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl From<&ConnectionManager> for SimpleRedisLock

fn from(connection: &ConnectionManager) -> Self

Converts to this type from the input type.