Method try_acquire

crates/openshell-server/src/compute/lease.rs:89–117

Attempt to create the lease record. Succeeds only if no lease exists.

(&self)

    /// Attempt to create the lease record. Succeeds only if no lease exists.
    pub async fn try_acquire(&self) -> Result<LeaseGuard, LeaseError> {
        let acquired_at_ms = now_ms();
        let payload = LeasePayload {
            holder: self.replica_id.clone(),
            acquired_at_ms,
        };
        let payload_bytes =
            serde_json::to_vec(&payload).map_err(|e| PersistenceError::Encode(e.to_string()))?;

        match self
            .store
            .put_if(
                LEASE_OBJECT_TYPE,
                LEASE_SINGLETON_ID,
                LEASE_SINGLETON_NAME,
                &payload_bytes,
                None,
                WriteCondition::MustCreate,
            )
            .await
        {
            Ok(result) => Ok(LeaseGuard {
                resource_version: result.resource_version,
                acquired_at_ms,
            }),
            Err(PersistenceError::UniqueViolation { .. }) => Err(LeaseError::AlreadyHeld),
            Err(e) => Err(LeaseError::Store(e)),
        }
    }

    /// Steal an expired lease from another replica via CAS.
    pub async fn try_steal_expired(&self) -> Result<LeaseGuard, LeaseError> {