pipecircuit 0.0.23

Correct. Robust. Fast. Portable. Pick four.
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

//! Revisioned table ownership with independent visibility and durability.
//!
//! Physical completions are trusted backend evidence, not client messages. Row
//! implementations must clone independent values: interior mutation shared with
//! callers would bypass the authority, just as it would bypass ordinary indexes.
mod authority;
mod commands;
mod continuous;
mod continuous_protocol;
mod continuous_view;
mod pending_mutation;
mod subscribed_view;
pub use continuous::{
    SubscriptionError, SubscriptionId, SubscriptionLimits, Subscriptions, ViewProtocol, ViewUpdate,
};
pub use continuous_protocol::{
    ContinuousPipe, ContinuousReply, ContinuousRequest, RequestId, SubscriptionRefusal,
};
pub use continuous_view::{ContinuousView, ContinuousViewError, ContinuousViewStatus};
pub use pending_mutation::{
    MutationReceiveError, MutationStatus, PendingMutation, ReceiveMutation,
};
pub use subscribed_view::{
    ReceiveSubscription, ReceiveSubscriptionChanges, SubscribedView, SubscriptionChanges,
    SubscriptionProgress, SubscriptionReceiveError, SubscriptionSession, SubscriptionStart,
};
mod protocol;
pub use protocol::{
    Answer, MutationAnswer, Receipt, StorageFailure, TableMutation, TablePipe, TableReply,
    TableRequest,
};
mod located;
pub use commands::{ChangeSet, PrepareCommand, PreparedCommand, TableProtocol};
pub use located::{
    ColumnsError, IndexView, IndexedProtocol, IndexedRow, Located, LocatedColumns, LocatedMut,
    LocatedRef, QueryPlan, RecordLocation, Targets,
};
mod clock;
pub use clock::RevisionClock;
mod changes;
mod replay;
mod types;
pub use authority::{Authority, Complete, ReadOutcome, Submit};
pub use replay::RecoveryBuilder;
pub use types::*;

#[cfg(test)]
mod tests;