Struct TaskLeaseGuard 

pub struct TaskLeaseGuard { /* private fields */ }

Shared in-memory lease guard observed by task code and heartbeat code.

Implementations

impl TaskLeaseGuard

pub fn new(lease: TaskLease, renewal_timeout: Duration) -> Self

Creates a guard with the provided renewal timeout.

pub fn with_shutdown_token( lease: TaskLease, renewal_timeout: Duration, shutdown_token: CancellationToken, ) -> Self

Creates a guard that also observes worker shutdown.

pub const fn lease(&self) -> TaskLease

Returns the persisted lease represented by this guard.

pub fn record_renewed(&self)

Records a successful persistent lease renewal.

pub fn mark_lost(&self) -> TaskCoreError

Marks the lease as lost and returns the corresponding error.

pub fn mark_shutdown_requested(&self) -> TaskCoreError

Marks worker shutdown and returns the corresponding error.

pub fn ensure_active(&self) -> Result<()>

Returns success only while the lease is still safe for writes.

Trait Implementations

impl Clone for TaskLeaseGuard

fn clone(&self) -> TaskLeaseGuard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskLeaseGuard

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

Formats the value using the given formatter.