chronon-core 0.1.0

Portable DTOs, SchedulerStore port, StoreRouter, and identity ports for Chronon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! Distributed run lease model.

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

/// Lease for a distributed run (exactly-one claim).
///
/// Persisted by [`SchedulerStore`](crate::store::SchedulerStore) backends that track worker
/// claims separately from the [`Run`](crate::models::Run) row. Used for reclaim and failover
/// when a worker stops renewing.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Lease {
    /// Unique lease row id.
    pub lease_id: String,
    /// Run this lease protects.
    pub run_id: String,
    /// Owning job, when the run was spawned from a schedule.
    pub job_id: Option<String>,
    /// Worker or coordinator instance that holds the lease.
    pub leased_by: String,
    /// Worker pool that may claim this run.
    pub pool_id: String,
    /// Lease expiry; another worker may reclaim after this instant.
    pub lease_until: DateTime<Utc>,
    /// When the lease row was first created.
    pub created_at: DateTime<Utc>,
}