gnitz-core 0.1.1

Client core for the gnitz database: connection, protocol, client-side schema and batches
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

//! Unit tests live in `tests/<module>.rs`, attached with `#[path]` to the module
//! they cover, so each stays that module's own `tests` child and reaches its
//! private items.
//!
//! `src/tests/` holds those; the crate-root `tests/` beside `src/` is the
//! integration suite, gated on the `integration` feature.

mod client;
mod connection;
mod error;
mod mirror;
mod protocol;
#[cfg(test)]
mod test_support;

pub use client::{
    key_reply, not_found, qualified_name, retraction_batch, segment_id, FkTarget, GnitzClient, Held, IndexRow,
    InlineUniqueIndex, ParkHook, PlannedView, ViewBundle, MAX_CHAIN_SEGMENTS, RMW_MAX_ATTEMPTS,
};
pub use connection::{
    Completions, DeltaCursor, Encoded, Interest, RelDescriptor, Reply, Request, ScanReply, Session, SlotId, Target,
    MAX_IN_FLIGHT, MAX_QUEUED_BYTES,
};
pub use error::ClientError;
pub use mirror::{Invalidate, MirrorError, MirrorStore, PollOutcome, PollResult, Refill};
pub use protocol::error::ProtocolError;
pub use protocol::message::{encode_ddl_txn, PushFamily};
pub(crate) use protocol::message::{encode_frame, encode_push_txn};
pub(crate) use protocol::transport::ClientTransport;
pub use protocol::types::{
    push_zero_cell, sys_schema, BatchAppender, BatchMark, PayloadColumn, PkColumn, Schema, ZSetBatch,
};
pub use protocol::wal_block::append_own_regions;