Struct LeaseGuard 

pub struct LeaseGuard { /* private fields */ }

Proof of a won round, returned by ExportLease::try_acquire.

There is nothing to release — the round runs until the lease expires (that is the round period). Call complete after the artifact is safely uploaded to publish what was exported.

Implementations

impl LeaseGuard

pub fn record(&self) -> &LeaseRecord

The record this guard wrote when it won the round.

pub async fn abandon(self)

Give the round back early: a failed export/upload should not suppress the fleet for the rest of the ttl. CAS-deletes the lease (tombstone) against this guard’s version, so the next trigger on any node can win a fresh round immediately.

Best-effort: a CAS conflict (someone already took over) or write error is logged, not surfaced — worst case the round waits out its ttl, which is the no-abandon behavior anyway.

An unawaited abandon() does nothing (and would trip the Drop warning); the future’s inherent #[must_use] plus this crate’s deny(unused_must_use) make that a compile error, not a silent leak.

pub async fn complete(self, cursor: &WatchCursor) -> Result<(), KvError>

Publish the round’s outcome: rewrite the lease value with the exported cursor and completion time (expiry unchanged — the round still runs its full period).

Best-effort observability: a CAS conflict means the lease was already taken over (this round overran its ttl) and is logged, not surfaced — the artifact is already safe wherever the caller put it.

An unawaited complete() records nothing (and would trip the Drop warning); the future’s inherent #[must_use] plus this crate’s deny(unused_must_use) make that a compile error, not a silent leak.

Trait Implementations

impl Drop for LeaseGuard

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.