reddb-io-wire 1.12.0

RedDB wire protocol vocabulary: connection-string parser, RedWire frames, payload codecs, topology, sanitizers, and replication messages.
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

//! Replication protocol payload contracts.
//!
//! These structs describe the transport-agnostic payloads used by
//! primary/replica exchange. Applying WAL, creating base backups,
//! staging rebootstrap, and failover policy stay in `reddb-server`
//! and `reddb-file`.

mod util;

pub mod basebackup;
pub mod bookmark;
pub mod catchup;
pub mod change_record;
pub mod range_stream;
pub mod timeline;
pub mod wal_stream;

pub use basebackup::{
    BaseBackupChunk, BaseBackupChunkPart, BaseBackupManifestChunk, BaseBackupRequest,
    BASEBACKUP_CHUNK_HEX_FIELD, BASEBACKUP_CHUNK_ORDINAL_FIELD, BASEBACKUP_CHUNK_PAIR_FIELD,
    BASEBACKUP_MANIFEST_HEX_FIELD,
};
pub use bookmark::{BookmarkDecodeError, CausalBookmark};
pub use catchup::{CatchupMode, CatchupModeReply};
pub use change_record::{
    change_record_json_value_to_string, parse_change_record_json_value, public_item_kind,
    ChangeOperation, ChangeRecord, ChangeRecordJsonValue, RangeAdmitError, RangeAuthority,
    DEFAULT_REPLICATION_TERM,
};
pub use range_stream::{
    classify_range_record, plan_range_catchup, RangeCatchupPlan, RangeProgressTracker,
    RangeStreamDecision, RangeStreamPosition, RangeStreamProgress, RangeStreamReject,
};
pub use timeline::{
    FailoverPromotionReply, FailoverPromotionRequest, RejoinPlanNotice, RejoinRewindConfirmation,
    RejoinRewindConfirmationReply, TimelineForkNotice,
};
pub use util::ReplicationPayloadError;
pub use wal_stream::{
    WalStreamAck, WalStreamAckReply, WalStreamChunk, WalStreamOpen, WalStreamRecord,
};