Expand description
PGSync core: lifecycle, configuration, transaction model, checkpoint contracts, and
backpressure primitives. Database-specific code lives in pgsync-postgres.
Re-exports§
pub use checkpoint::Checkpoint;pub use checkpoint::CheckpointStore;pub use config::Config;pub use error::Error;pub use error::ErrorKind;pub use error::Result;pub use error::ResultExt;pub use event::Column;pub use event::Op;pub use event::Relation;pub use event::ReplicaIdentity;pub use event::SourceEvent;pub use event::Tuple;pub use event::Value;pub use lsn::Lsn;pub use metrics::Metrics;pub use metrics::MetricsSnapshot;pub use state::JobState;
Modules§
- channel
- Bounded, byte-accounted channel between the reader and the applier.
- checkpoint
- Durable replication progress.
- config
- Job configuration: YAML schema, defaults, and validation.
- engine
- The replication engine: reader task, applier loop, and reconnect policy.
- error
- Structured, categorised errors.
- event
- The logical change model shared by decoders, transformers (Beta 2) and sinks.
- lsn
- PostgreSQL Log Sequence Numbers.
- metrics
- Process-wide counters, cheap to update from any task and snapshot-able as JSON.
- progress
- Human-facing progress reporting, decoupled from logging.
- retry
- Exponential backoff for transient failures.
- state
- Job lifecycle states.
- traits
- Boundaries between the engine and database-specific adapters.