liminal-protocol 0.2.0

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

//! Participant message discriminants, schemas, and deterministic wire codec.

mod authority;
mod closure;
mod codec;
mod envelope;
mod primitives;
mod push;
mod request;
mod response;
mod sequence_budget;
mod server_codec;
mod tags;

#[cfg(test)]
mod authority_tests;
#[cfg(test)]
mod codec_tests;
#[cfg(test)]
mod server_codec_tests;
#[cfg(test)]
mod tags_tests;

pub use authority::{
    CredentialAttachResponse, DetachResponse, EnrollmentResponse, LeaveResponse, MarkerAckResponse,
    ObserverRecoveryResponse, ParticipantAckResponse, RecordAdmissionResponse,
};
pub use closure::{
    ClosureCapacityReason, ClosureCheckedEnvelope, ClosureRefusalReason, ClosureSnapshot,
    MarkerClosureCapacityExceeded, ParticipantCursorProgressEdge, RepaymentEdge,
};
pub use codec::{
    AuthenticationState, CodecError, FRAME_MAX, GENERIC_HEADER_LEN, InboundGateContext,
    InboundGateError, MIN_PARTICIPANT_FRAME_MAX, NegotiatedParticipantCapability,
    PARTICIPANT_FRAME_OVERHEAD, PARTICIPANT_FRAME_TYPE, PARTICIPANT_PREFIX_LEN,
    PRECAP_PARTICIPANT_FRAME_MAX, ParticipantCapabilityState, ParticipantFrame, ReceiverDirection,
    ValidatedFrameLimit, complete_frame_bytes, decode, encode, encoded_len, gate_inbound,
};
pub use envelope::{
    AttachEnvelope, DetachEnvelope, EnrollmentEnvelope, LeaveEnvelope, MarkerAckEnvelope,
    ParticipantAckEnvelope, RecordAdmissionEnvelope, ResponseEnvelope,
};
pub use primitives::{
    AttachAttemptToken, AttachSecret, BindingEpoch, ConnectionIncarnation, ConversationId,
    DeliverySeq, DetachAttemptToken, EnrollmentToken, Generation, LeaveAttemptToken, ObserverEpoch,
    ParticipantId, ParticipantIndex, ProtocolVersion, RecordAdmissionAttemptToken,
    TransactionOrder,
};
pub use push::{DetachedCause, DiedCause, ParticipantDelivery, ParticipantRecord, ServerPush};
pub use request::{
    ClientRequest, CredentialAttachRequest, DetachRequest, EnrollmentRequest, LeaveRequest,
    MarkerAck, ObserverRecoveryHandshake, ObserverRefusal, ParticipantAck, RecordAdmission,
};
pub use response::*;
pub use sequence_budget::SequenceBudget;
pub use server_codec::{decode_server_value_body, encode_server_value_body};
pub use tags::{
    AckGapReason, AckRegressionReason, AttemptConflict, AttemptOperation, AuthorityStateTag,
    BindingStateTag, ClientDiscriminant, CloseCause, CloseCauseTag, ClosureScope, Counter,
    DecodeClass, IdentityCapacityScope, InvalidObserverEpochListReason, InvalidObserverEpochReason,
    MarkerMismatchReason, MarkerNotDeliveredReason, PushDiscriminant, ReceiptCapacityScope,
    ReceiptExpiryReason, RecordKind, RepaymentEdgeTag, ServerDiscriminant, TagError,
    TransportReasonTag,
};