Module leader_lease 

Durable, append-only leader fencing.

Structs

AssignmentDrainDecision

Immutable settlement of one exact assignment-drain transition.

AssignmentRecoveryDecision

Immutable authorization to install one staged failure-recovery assignment.

ClusterArtifactCleanupCursor

Exact, crash-resumable cluster checkpoint artifact cleanup position.

ClusterOutcomeInventory

Live cluster outcomes and their retention horizons from one audited authority head.

ClusterOutcomeRetentionBoundary

Exact continuity retained when old cluster checkpoint outcomes are compacted.

LeaderCandidacy

Coalescing-safe local candidacy state. A generation change means a published grant was lost and must never reuse its fencing token, even when the current state is eligible again.

LeaderLease

Durable leader lease record.

LeaderLeaseConfig

Renewal timings for the leader lease.

LeaderLeaseManager

Acquires and renews leadership while candidacy remains true.

LeaderLeaseObservation

Candidate-local proof that one rival liveness identity remained current for a full TTL.

LeaderLeaseOwner

Exact process incarnation eligible to hold the leader lease.

LeaderLeaseStore

Append-only object-store authority for the cluster leader.

SubscriptionReplayPin

Exact internal lease protecting one stream generation’s replay start epoch.

Enums

AssignmentDrainVerdict

Terminal result for an assignment-drain transition.

ClusterArtifactCleanupPhase

Destructive phase authorized by the cluster leader authority.

ClusterAttemptStatus

Durable settlement state for one exact cluster checkpoint attempt.

ClusterCheckpointAuthorityError

Failure while using the leader sequence as the cluster checkpoint-decision authority.

LeaseError

Leader lease storage or validation failure.

LeaseOutcome

Result of an acquisition or renewal attempt.

RecordAssignmentDrainDecisionResult

Result of admitting a drain decision through the shared authority sequence.

RecordAssignmentRecoveryDecisionResult

Result of admitting a recovery decision through the shared authority sequence.

SubscriptionReplayPinAcquire

Result of atomically attaching a replay pin to the shared retention floor.

Constants

SUBSCRIPTION_REPLAY_PIN_RENEW_INTERVAL

Interval at which an active gateway must renew a durable replay pin.

Functions

lease_grants_leadership

Whether the exact owner has a durable record and a live process-local deadline.

lease_grants_proof

Whether a captured proof still matches the current exact grant and local deadline.