liminal_protocol/wire/
mod.rs

1//! Participant message discriminants, schemas, and deterministic wire codec.
2
3mod authority;
4mod closure;
5mod codec;
6mod envelope;
7mod primitives;
8mod push;
9mod request;
10mod response;
11mod sequence_budget;
12mod server_codec;
13mod tags;
14
15#[cfg(test)]
16mod authority_tests;
17#[cfg(test)]
18mod codec_tests;
19#[cfg(test)]
20mod credential_debug_tests;
21#[cfg(test)]
22mod registry_fixture_tests;
23#[cfg(test)]
24mod server_codec_tests;
25#[cfg(test)]
26mod settlement_fixture_tests;
27#[cfg(test)]
28mod tags_tests;
29#[cfg(test)]
30mod transport_reasons_fixture_tests;
31
32pub use authority::{
33    CredentialAttachResponse, DetachResponse, EnrollmentResponse, LeaveResponse, MarkerAckResponse,
34    ObserverRecoveryResponse, ParticipantAckResponse, RecordAdmissionResponse,
35};
36pub use closure::{
37    ClosureCapacityReason, ClosureCheckedEnvelope, ClosureRefusalReason, ClosureSnapshot,
38    MarkerClosureCapacityExceeded, ParticipantCursorProgressEdge, RepaymentEdge,
39};
40pub use codec::{
41    AuthenticationState, CodecError, FRAME_MAX, GENERIC_HEADER_LEN, InboundGateContext,
42    InboundGateError, MIN_PARTICIPANT_FRAME_MAX, NegotiatedParticipantCapability,
43    PARTICIPANT_FRAME_OVERHEAD, PARTICIPANT_FRAME_TYPE, PARTICIPANT_PREFIX_LEN,
44    PRECAP_PARTICIPANT_FRAME_MAX, ParticipantCapabilityState, ParticipantFrame, ReceiverDirection,
45    ValidatedFrameLimit, complete_frame_bytes, decode, encode, encoded_len, gate_inbound,
46};
47pub use envelope::{
48    AttachEnvelope, DetachEnvelope, EnrollmentEnvelope, LeaveEnvelope, MarkerAckEnvelope,
49    ParticipantAckEnvelope, RecordAdmissionEnvelope, ResponseEnvelope,
50};
51pub use primitives::{
52    AttachAttemptToken, AttachSecret, BindingEpoch, ConnectionIncarnation, ConversationId,
53    CredentialDigest, DeliverySeq, DetachAttemptToken, EnrollmentToken, Generation,
54    LeaveAttemptToken, ObserverEpoch, ParticipantId, ParticipantIndex, ProtocolVersion,
55    RecordAdmissionAttemptToken, SettlementEpoch, TransactionOrder,
56};
57pub use push::{DetachedCause, DiedCause, ParticipantDelivery, ParticipantRecord, ServerPush};
58pub use request::{
59    ClientRequest, CredentialAttachRequest, DetachRequest, EnrollmentRequest, LeaveRequest,
60    MarkerAck, ObserverRecoveryHandshake, ObserverRefusal, ParticipantAck, RecordAdmission,
61    SettlementQuery,
62};
63pub use response::*;
64pub use sequence_budget::SequenceBudget;
65pub use server_codec::{decode_server_value_body, encode_server_value_body};
66pub(crate) use server_codec::{encode_attach_committed_body, encode_enrollment_committed_body};
67pub use tags::{
68    AckGapReason, AckRegressionReason, AttemptConflict, AttemptOperation, AuthorityStateTag,
69    BindingStateTag, ClientDiscriminant, CloseCause, CloseCauseTag, ClosureScope, Counter,
70    DecodeClass, IdentityCapacityScope, InvalidObserverEpochListReason, InvalidObserverEpochReason,
71    MarkerMismatchReason, MarkerNotDeliveredReason, PushDiscriminant, ReceiptCapacityScope,
72    ReceiptExpiryReason, RecordAdmissionFaultClassTag, RecordKind, RepaymentEdgeTag,
73    ServerDiscriminant, TagError, TransportReasonTag,
74};
liminal_protocol/wire/mod.rs

liminal_protocol/wire/
mod.rs
