powdb_sync/
lib.rs

1//! Sync substrate for PowDB.
2//!
3//! This crate is intentionally below the query layer. Its first responsibility is
4//! retaining durable WAL records as immutable replication-unit segments so future
5//! embedded replicas and read replicas can bootstrap from snapshot + tail without
6//! making `powdb-query` distribution-aware.
7
8pub mod apply;
9pub mod checkpoint;
10pub mod metadata;
11pub mod replica;
12pub mod retention;
13pub mod segment;
14
15pub use apply::{
16    apply_retained_tail, apply_retained_units_chunk, seed_retained_apply_boundary,
17    validate_v1_retained_tail_applyable, validate_v1_retained_units_applyable,
18    RetainedTailApplySummary,
19};
20pub use checkpoint::{
21    archive_wal_records_for_identity, checkpoint_preserving_retained_segments_if_enabled,
22    checkpoint_with_retained_segments, open_preserving_retained_segments, retained_segments_dir,
23    SyncCatalog, RETAINED_SEGMENTS_DIR,
24};
25pub use metadata::{
26    minimum_retained_lsn, open_or_create_identity, read_identity, read_identity_snapshot,
27    read_identity_snapshot_if_exists, read_replica_cursors, register_bootstrap_cursor,
28    retire_replica_cursor, sync_state_dir, upsert_replica_cursor, write_identity_snapshot,
29    write_replica_cursors, DatabaseIdentity, IdentitySnapshot, ReplicaCursor, IDENTITY_FILE,
30    REPLICA_CURSORS_FILE, SYNC_METADATA_FORMAT_VERSION, SYNC_STATE_DIR,
31};
32pub use replica::{
33    acknowledge_replica_apply, replica_sync_status, ReplicaApplyAckSummary, ReplicaSyncStatus,
34    SyncRepairAction,
35};
36pub use retention::{
37    prune_retained_segments, prune_retained_segments_for_cursors,
38    prune_retained_segments_with_policy, RetentionGcSummary, RetentionPressurePolicy,
39    RetentionPressureSummary,
40};
41pub use segment::{
42    list_segment_files, read_segment_file, read_units_since, read_units_through,
43    retained_tail_progress, segment_file_name, validate_retained_tail_available,
44    write_segment_atomic, RetainedSegment, RetainedTailAvailability, RetainedTailProgress,
45    RetainedUnit, SegmentFile, SegmentIdentity, RETAINED_SEGMENT_FORMAT_VERSION,
46};
powdb_sync/lib.rs

powdb_sync/
lib.rs
