Struct LeasedOwnership 

pub struct LeasedOwnership { /* private fields */ }

Clustered Ownership: a Postgres lease per stream (spec §3.3).

Implementations

impl LeasedOwnership

pub async fn connect( url: &str, replica_id: String, ttl_secs: f64, ) -> Result<Self>

Connect, ensure the lease table exists, and identify this replica. ttl_secs is the lease lifetime; call Self::heartbeat well within it.

pub fn new(pool: PgPool, replica_id: String, ttl_secs: f64) -> Self

Build on an existing pool (shared-pool wiring; the daemon uses a pool per seam today, so this is for a future single-pool setup).

pub async fn heartbeat(&self)

Renew every lease this replica holds; drop any it has lost. The daemon’s reconciliation tick calls this (Phase 2d).

Trait Implementations

impl Ownership for LeasedOwnership

fn try_acquire<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<Lease>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Claim stream_key if it is free, expired, or already held by THIS process (idempotent — re-acquiring your own live lease returns it and does not change its epoch). Returns None if another live replica owns it.

fn renew<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 Lease, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Extend a held lease. Err if the lease was lost (stolen/expired) — which is how a replica learns it is no longer the owner.

fn release<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Release a held stream so a peer may claim it immediately (graceful hand-off), rather than waiting for TTL expiry.

fn owns(&self, stream_key: &str) -> bool

Whether this process currently owns stream_key. Cheap/in-memory: it is consulted on the poll loop’s hot path.