pipecircuit 0.0.18

Correct. Robust. Fast. Portable. Pick four.
Documentation
//! 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, SubscribedView, SubscriptionProgress, SubscriptionReceiveError,
    SubscriptionSession, SubscriptionStart,
};
mod protocol;
pub use protocol::{
    Answer, MutationAnswer, Receipt, StorageFailure, 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;