mod client;
mod connection;
mod error;
mod mirror;
mod protocol;
#[cfg(test)]
mod test_support;
pub use client::{
block_on, key_reply, not_found, qualified_name, retraction_batch, segment_id, serve, BlockingHost, BoxFut,
FkTarget, GnitzClient, Host, IndexRow, InlineUniqueIndex, Job, Op, ParkHook, Pending, PlannedView, ViewBundle,
MAX_CHAIN_SEGMENTS, RMW_MAX_ATTEMPTS,
};
pub use connection::{
promise, DeltaCursor, Interest, Promise, RelDescriptor, Request, ScanReply, Sent, Session, Target, MAX_IN_FLIGHT,
MAX_QUEUED_BYTES,
};
pub use error::ClientError;
pub use mirror::{Invalidate, MirrorError, MirrorStore, PollOutcome, PollResult};
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;