Struct LeaseStore 

pub struct LeaseStore { /* private fields */ }

Wraps an AtomicRemoteBackend with lease primitives. The lease object is stored under a deterministic key derived from database_key; the store reads/writes that one key.

The trait bound AtomicRemoteBackend is the type-system version of “this backend can enforce CAS” — backends that cannot (Turso, D1, plain HTTP without ETag) deliberately do not implement the trait, so wiring them into a LeaseStore becomes a compile error rather than a runtime fail-closed.

Implementations

impl LeaseStore

pub fn new(backend: Arc<dyn AtomicRemoteBackend>) -> Self

pub fn with_prefix(self, prefix: impl Into<String>) -> Self

pub fn current( &self, database_key: &str, ) -> Result<Option<WriterLease>, LeaseError>

Read whatever lease object is currently published. None means no lease has ever been written for this key.

pub fn try_acquire( &self, database_key: &str, holder_id: &str, ttl_ms: u64, ) -> Result<WriterLease, LeaseError>

Try to acquire the lease for database_key on behalf of holder_id, valid for ttl_ms. Returns the WriterLease we own on success. Errors:

• LeaseError::Held if a different holder owns a non-expired lease.
• LeaseError::LostRace if a concurrent contender beat us.

pub fn refresh( &self, lease: &WriterLease, ttl_ms: u64, ) -> Result<WriterLease, LeaseError>

Refresh lease.expires_at_ms to now + ttl_ms. Fails with Stale if the holder/generation no longer matches what’s currently published. The returned lease is the new in-effect record.

pub fn release(&self, lease: &WriterLease) -> Result<(), LeaseError>

Release the lease. Only succeeds when the published lease matches lease.holder_id + lease.generation. A stolen or already-replaced lease returns Stale.