Struct MemoryLeaseStore 

pub struct MemoryLeaseStore { /* private fields */ }

In-process lease coordination, correct for a single service instance.

Workers within the process still gate children on parents and checkpoint, but nothing survives a restart. Multiple instances need a shared store such as the DynamoDB one.

Implementations

impl MemoryLeaseStore

pub fn new() -> Self

Creates an empty store.

Trait Implementations

impl Debug for MemoryLeaseStore

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

Formats the value using the given formatter.

impl Default for MemoryLeaseStore

fn default() -> MemoryLeaseStore

Returns the “default value” for a type.

impl LeaseStore for MemoryLeaseStore

fn acquire<'a>( &'a self, shard: &'a str, owner: &'a str, ttl: Duration, ) -> BoxFuture<'a, Result<bool, LeaseError>>

Attempts to take the shard’s lease for owner, valid for ttl. Returns false when another live owner holds it.

fn renew<'a>( &'a self, shard: &'a str, owner: &'a str, ttl: Duration, ) -> BoxFuture<'a, Result<bool, LeaseError>>

Heartbeats the lease. Returns false when the lease is no longer held (fenced).

fn checkpoint<'a>( &'a self, shard: &'a str, owner: &'a str, sequence: &'a str, ) -> BoxFuture<'a, Result<bool, LeaseError>>

Records sequence as the shard’s checkpoint, conditional on owner holding the lease. Returns false when fenced.

fn read<'a>( &'a self, shard: &'a str, ) -> BoxFuture<'a, Result<LeaseState, LeaseError>>

Reads the shard’s persisted state (regardless of ownership).

fn release<'a>( &'a self, shard: &'a str, owner: &'a str, ) -> BoxFuture<'a, Result<(), LeaseError>>

Releases the lease so another owner can take it without waiting for expiry.