Struct InMemoryLockBackend 

pub struct InMemoryLockBackend { /* private fields */ }

In-memory distributed lock backend.

This backend stores locks in a HashMap guarded by a tokio::sync::RwLock. It is suitable for single-process deployments or testing. For true distributed locking across multiple processes/hosts, use RedisLockBackend or DbLockBackend.

Expired locks are lazily cleaned up on each operation.

Example

use celers_beat::lock::InMemoryLockBackend;
use celers_core::lock::DistributedLockBackend;

let backend = InMemoryLockBackend::new();
let acquired = backend.try_acquire("my_task", "scheduler-1", 300).await.unwrap();
assert!(acquired);

Implementations

impl InMemoryLockBackend

pub fn new() -> Self

Create a new in-memory lock backend

pub async fn active_lock_count(&self) -> usize

Get the number of currently held (non-expired) locks

Trait Implementations

impl Clone for InMemoryLockBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryLockBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryLockBackend

fn default() -> Self

Returns the “default value” for a type.

impl DistributedLockBackend for InMemoryLockBackend

fn try_acquire<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, owner: &'life2 str, ttl_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Try to acquire a lock. Returns Ok(true) if acquired successfully.

fn release<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, owner: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Release a lock. Returns Ok(true) if released (was owned by this owner).

fn renew<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, owner: &'life2 str, ttl_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Renew/extend a lock’s TTL. Returns Ok(true) if renewed.

fn is_locked<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Check if a lock is currently held by anyone.

fn owner<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Get the current owner of a lock, if any.

fn release_all<'life0, 'life1, 'async_trait>( &'life0 self, owner: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Release all locks owned by a specific owner.