haematite 0.6.2

Content-addressed, branchable, actor-native storage engine
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

//! Carrier-neutral framing, lifecycle, and bounded-queue core.

mod counters;
mod framing;
mod machine;
mod queue;
mod types;

pub use counters::{CarrierCounterSnapshot, CarrierCounters};
pub use framing::{FrameDecoder, MAX_CARRIER_FRAME_BYTES, decode_envelope, encode_frame};
pub use machine::{
    AttemptSlot, CarrierAction, CarrierMachine, CarrierMachineInput, CarrierState,
    CarrierTransition, step,
};
pub use queue::{
    BoundedFrameQueue, MAX_QUEUED_CARRIER_BYTES, MAX_QUEUED_CARRIER_FRAMES, QueueEnqueueResult,
};
pub use types::{
    AttemptGeneration, AuthenticatedPeerBinding, Carrier, CarrierCloseCause,
    CarrierConnectFailureCause, CarrierConnectFailureDisposition, CarrierConnectFailureStage,
    CarrierEstablishedCause, CarrierEvent, CarrierLostCause, CarrierParkedCause, CarrierRefusal,
    CarrierSendOutcome, CarrierSendRefusal, CarrierStoppedCause, ConnectionId, ConnectionKey,
    EpisodeId, Incarnation, OpaqueBytes,
};

#[cfg(test)]
mod adapters;
#[cfg(test)]
mod tests;