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

liminal_protocol/wire/
mod.rs
