Enum LeaseHistoryEvent 

#[non_exhaustive]
pub enum LeaseHistoryEvent {
    Acquired {
        cursor: StreamCursor,
        execution_id: ExecutionId,
        lease_id: Option<LeaseId>,
        worker_instance_id: Option<WorkerInstanceId>,
        at: TimestampMs,
    },
    Renewed {
        cursor: StreamCursor,
        execution_id: ExecutionId,
        lease_id: Option<LeaseId>,
        worker_instance_id: Option<WorkerInstanceId>,
        at: TimestampMs,
    },
    Expired {
        cursor: StreamCursor,
        execution_id: ExecutionId,
        lease_id: Option<LeaseId>,
        prev_owner: Option<WorkerInstanceId>,
        at: TimestampMs,
    },
    Reclaimed {
        cursor: StreamCursor,
        execution_id: ExecutionId,
        new_lease_id: Option<LeaseId>,
        new_owner: Option<WorkerInstanceId>,
        at: TimestampMs,
    },
    Revoked {
        cursor: StreamCursor,
        execution_id: ExecutionId,
        lease_id: Option<LeaseId>,
        revoked_by: String,
        at: TimestampMs,
    },
}

Per-event payload of subscribe_lease_history.

Each variant carries the fence triple fields the Lua producer writes (lease_id, plus attempt/worker correlation where available) and the monotonic at timestamp derived from the backend’s native stream id / event id.

revoked_by is String today for forward compatibility; we may promote to a typed enum post-v0.10 once the revocation-source taxonomy settles. Known producers emit "operator", "reconciler", or "backend" today.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Acquired

Fields

cursor: StreamCursor

execution_id: ExecutionId

lease_id: Option<LeaseId>

Valkey populates this from the Lua producer; Postgres outbox may carry None today because the attempt row identity is (lease_epoch, attempt_index, execution_id) rather than a stable uuid (see lease_event::emit).

worker_instance_id: Option<WorkerInstanceId>

at: TimestampMs

Renewed

Fields

cursor: StreamCursor

execution_id: ExecutionId

lease_id: Option<LeaseId>

Same availability caveat as Acquired::lease_id.

worker_instance_id: Option<WorkerInstanceId>

at: TimestampMs

Expired

Fields

cursor: StreamCursor

execution_id: ExecutionId

lease_id: Option<LeaseId>

prev_owner: Option<WorkerInstanceId>

at: TimestampMs

Reclaimed

Fields

cursor: StreamCursor

execution_id: ExecutionId

new_lease_id: Option<LeaseId>

Same availability caveat as Acquired::lease_id.

new_owner: Option<WorkerInstanceId>

at: TimestampMs

Revoked

Fields

cursor: StreamCursor

execution_id: ExecutionId

lease_id: Option<LeaseId>

revoked_by: String

String today for forward compat; may promote to typed enum post-v0.10 once taxonomy settles. Known values: "operator", "reconciler", "backend".

at: TimestampMs

Implementations

impl LeaseHistoryEvent

pub fn cursor(&self) -> &StreamCursor

Position cursor to persist + replay from.

pub fn execution_id(&self) -> &ExecutionId

Execution the event pertains to.

pub fn at(&self) -> TimestampMs

Monotonic backend-stamped time of the event.

Trait Implementations

impl Clone for LeaseHistoryEvent

fn clone(&self) -> LeaseHistoryEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeaseHistoryEvent

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

Formats the value using the given formatter.

impl PartialEq for LeaseHistoryEvent

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for LeaseHistoryEvent

impl StructuralPartialEq for LeaseHistoryEvent