pgsync-core 0.1.1

Core of pgsync: job lifecycle, transaction model, LSN and checkpoint contracts, bounded backpressure
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! PGSync core: lifecycle, configuration, transaction model, checkpoint contracts, and
//! backpressure primitives. Database-specific code lives in `pgsync-postgres`.

pub mod channel;
pub mod checkpoint;
pub mod config;
pub mod engine;
pub mod error;
pub mod event;
pub mod lsn;
pub mod metrics;
pub mod progress;
pub mod retry;
pub mod state;
pub mod traits;

pub use checkpoint::{Checkpoint, CheckpointStore};
pub use config::Config;
pub use error::{Error, ErrorKind, Result, ResultExt};
pub use event::{Column, Op, Relation, ReplicaIdentity, SourceEvent, Tuple, Value};
pub use lsn::Lsn;
pub use metrics::{Metrics, MetricsSnapshot};
pub use state::JobState;