Struct WorkerLease 

pub struct WorkerLease {
    pub node_id: u64,
    pub profile: WorkerProfile,
    pub acquired_unix_secs: i64,
    pub renewed_unix_secs: i64,
    pub ttl_secs: u32,
    pub grace_secs: u32,
}

A worker lease in the leader’s directory — drives liveness.

Fields

node_id: u64

profile: WorkerProfile

acquired_unix_secs: i64

Unix epoch seconds when the lease was granted.

renewed_unix_secs: i64

Unix epoch seconds of last successful heartbeat renewal.

ttl_secs: u32

Current TTL applied to this worker (adaptive).

grace_secs: u32

Grace period (seconds) applied on top of ttl_secs before the leader marks this worker as Unreachable. Stored on the lease so the value used at lease-grant time is durable even if the leader’s AdaptiveTtlConfig later changes.

Implementations

impl WorkerLease

pub fn is_expired(&self, now_unix_secs: i64, grace_secs: u32) -> bool

True if now_unix_secs - renewed_unix_secs > ttl_secs + grace.

The grace_secs argument lets callers override the lease’s stored grace value (e.g. to apply a temporarily-extended grace during a known leadership transition).

Trait Implementations

impl Clone for WorkerLease

fn clone(&self) -> WorkerLease

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerLease

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkerLease

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkerLease

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.