Struct RuntimeLeaseDbStore 

pub struct RuntimeLeaseDbStore { /* private fields */ }

SeaORM-backed implementation of [RuntimeLeaseStore].

Implementations

impl RuntimeLeaseDbStore

pub const fn new(db: DatabaseConnection) -> Self

Creates a runtime lease store from a SeaORM database connection.

pub const fn db(&self) -> &DatabaseConnection

Returns the underlying database connection.

Trait Implementations

impl Clone for RuntimeLeaseDbStore

fn clone(&self) -> RuntimeLeaseDbStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RuntimeLeaseStore for RuntimeLeaseDbStore

type Error = DbError

Store error type.

fn try_acquire<'life0, 'life1, 'async_trait>( &'life0 self, claim: RuntimeLeaseClaim<'life1>, ) -> Pin<Box<dyn Future<Output = Result<RuntimeLeaseAcquire, Self::Error>> + Send + 'async_trait>>

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

Attempts to acquire the lease for the caller.

fn renew<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, lease_id: &'life1 str, owner_id: &'life2 str, now: DateTime<Utc>, expires_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

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

Renews an owned lease and returns whether ownership was still held.

fn release<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, lease_id: &'life1 str, owner_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Releases an owned lease during cooperative shutdown.