liminal-protocol 0.3.2

Shared participant-lifecycle protocol types for liminal
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

use crate::lifecycle::AdmissionOrder;
use crate::wire::{
    BindingEpoch, CloseCause, ConversationId, DeliverySeq, ParticipantId, ParticipantIndex,
    RepaymentEdge, TransactionOrder,
};

/// The only close cause admitted by startup binding recovery.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub struct UncleanServerRestartCause {
    /// Server incarnation that previously owned the recovered binding.
    pub prior_server_incarnation: u64,
}

impl UncleanServerRestartCause {
    /// Returns the corresponding shared close-cause value.
    #[must_use]
    pub const fn as_close_cause(self) -> CloseCause {
        CloseCause::UncleanServerRestart {
            prior_server_incarnation: self.prior_server_incarnation,
        }
    }
}

/// Durable finalization selected by startup binding recovery.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum BindingRecoveryFinalization {
    /// Binding terminal was appended in the recovery transaction.
    Appended {
        /// Assigned durable delivery sequence.
        delivery_seq: DeliverySeq,
    },
    /// Capacity-backed terminal remains pending for later append.
    Pending {
        /// Immutable ordering key retained by pending finalization.
        admission_order: AdmissionOrder,
    },
}

/// Internal durable success from server-startup binding recovery.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub struct BindingRecoveryCommitted {
    /// Participant whose dead binding was recovered.
    pub participant_id: ParticipantId,
    /// Conversation that owned the recovered binding.
    pub conversation_id: ConversationId,
    /// Exact old binding epoch terminalized by recovery.
    pub recovered_binding_epoch: BindingEpoch,
    /// Exact unclean-restart cause and prior incarnation.
    pub cause: UncleanServerRestartCause,
    /// Assigned conversation transaction-order major.
    pub assigned_transaction_order: TransactionOrder,
    /// Appended or bounded-pending terminalization.
    pub finalization: BindingRecoveryFinalization,
    /// Exact stored closure-debt repayment edge after recovery.
    pub repayment_edge: RepaymentEdge,
}

/// Canonical candidate phase in transaction ordering.
#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord)]
#[repr(u8)]
pub enum CandidatePhase {
    /// Pending or direct binding terminal.
    BindingTerminal = 0,
    /// Membership exit record.
    MembershipExit = 1,
    /// Attached lifecycle record.
    AttachLifecycle = 2,
    /// Admitted ordinary application record.
    OrdinaryRecord = 3,
    /// Induced history-compaction marker.
    CompactionMarker = 4,
}

/// Counter whose movable-claim frontier is invalid.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum ClaimCounter {
    /// Conversation delivery-sequence frontier.
    DeliverySeq,
    /// Conversation transaction-order frontier.
    TransactionOrder,
}

/// Exact retained-state corruption reasons that remain after Fix 2.
///
/// `docs/design/LP-EXTRACTION-GOAL.md` Fix 2 removes fixed occurrence slots,
/// so occurrence-array placement, churn-block, duplicate-successor, and
/// unbacked-occurrence reasons are intentionally not constructible here.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum ParticipantStateCorruptReason {
    /// Two live candidates share one complete ordering key.
    DuplicateCandidateKey {
        /// Candidate transaction-order major.
        transaction_order: TransactionOrder,
        /// Candidate phase within the major.
        candidate_phase: CandidatePhase,
        /// Permanent participant-index tie-breaker.
        participant_index: ParticipantIndex,
    },
    /// Numeric or logical movable-claim frontier is malformed.
    ClaimFrontierInvalid {
        /// First counter in fixed validation order that failed.
        counter: ClaimCounter,
        /// Deterministic checked-u128 position of the first fault.
        first_bad_position: u128,
    },
}

/// Candidate validation or startup decoding found corrupt participant state.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub struct ParticipantStateCorrupt {
    /// Conversation whose durable bytes remain preserved and fail closed.
    pub conversation_id: ConversationId,
    /// First exact corruption reason in validation order.
    pub reason: ParticipantStateCorruptReason,
}