Struct LiveOwnershipRow 

pub struct LiveOwnershipRow {

    pub id: i64,
    pub run_id: Option<i64>,
    pub operation_kind: LiveOperationKind,
    pub database_key: String,
    pub resource_key: String,
    pub owner_pid: i64,
    pub acquired_at: DateTime<Utc>,
    pub heartbeat_at: DateTime<Utc>,
    pub released_at: Option<DateTime<Utc>>,
    pub state: LiveOwnershipState,
    pub restore_intent_json: Option<String>,
    pub orphan_eligible: bool,
    pub orphan_evidence_json: Option<String>,
}

Fields

id: i64

run_id: Option<i64>

operation_kind: LiveOperationKind

database_key: String

resource_key: String

owner_pid: i64

acquired_at: DateTime<Utc>

heartbeat_at: DateTime<Utc>

released_at: Option<DateTime<Utc>>

state: LiveOwnershipState

restore_intent_json: Option<String>

orphan_eligible: bool

orphan_evidence_json: Option<String>

Implementations

impl LiveOwnershipRow

pub async fn create_and_claim( pool: &SqlitePool, new: NewLiveOwnership, claim_key: &str, ) -> DbResult<Option<Self>>

Inserts an owner and conditionally claims its canonical database/resource key in one transaction. Recovery claim transfer is handled atomically by TuneRecoveryAttemptRow::start_with_claim.

pub async fn heartbeat( pool: &SqlitePool, owner_id: i64, now: DateTime<Utc>, ) -> DbResult<()>

pub async fn release( pool: &SqlitePool, owner_id: i64, now: DateTime<Utc>, ) -> DbResult<()>

pub async fn get(pool: &SqlitePool, id: i64) -> DbResult<Option<Self>>

pub async fn has_claim( pool: &SqlitePool, owner_id: i64, expected_claim_key: &str, ) -> DbResult<bool>

pub async fn list_for_run(pool: &SqlitePool, run_id: i64) -> DbResult<Vec<Self>>

pub async fn stale_active_owners( pool: &SqlitePool, stale_before: DateTime<Utc>, ) -> DbResult<Vec<Self>>

pub async fn set_restore_intent( pool: &SqlitePool, owner_id: i64, intent_json: &str, ) -> DbResult<()>

pub async fn mark_orphaned( pool: &SqlitePool, update: OrphanOwnerUpdate<'_>, ) -> DbResult<bool>

pub async fn mark_orphaned_unrecoverable( pool: &SqlitePool, update: UnrecoverableOwnerUpdate<'_>, ) -> DbResult<bool>

Retires a stale owner only after its caller has exported the exact affected rows. Any still-running row attached to the orphaned operation is failed closed rather than made automatically recoverable.

Trait Implementations

impl Clone for LiveOwnershipRow

fn clone(&self) -> LiveOwnershipRow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LiveOwnershipRow

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

Formats the value using the given formatter.

impl PartialEq for LiveOwnershipRow

fn eq(&self, other: &LiveOwnershipRow) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for LiveOwnershipRow

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for LiveOwnershipRow