Crate fsqlite_mvcc 

MVCC page-level versioning for concurrent writers.

This crate is intentionally small in early phases: it defines the core MVCC primitives and the cross-process witness/lock-table coordination types.

Re-exports

pub use begin_concurrent::ConcurrentHandle;

pub use begin_concurrent::ConcurrentPageState;

pub use begin_concurrent::ConcurrentRegistry;

pub use begin_concurrent::ConcurrentSavepoint;

pub use begin_concurrent::FcwResult;

pub use begin_concurrent::MAX_CONCURRENT_WRITERS;

pub use begin_concurrent::PreparedConcurrentCommit;

pub use begin_concurrent::SharedConcurrentHandle;

pub use begin_concurrent::SsiResult;

pub use begin_concurrent::concurrent_abort;

pub use begin_concurrent::concurrent_clear_page_state;

pub use begin_concurrent::concurrent_commit;

pub use begin_concurrent::concurrent_commit_with_ssi;

pub use begin_concurrent::concurrent_free_page;

pub use begin_concurrent::concurrent_page_is_freed;

pub use begin_concurrent::concurrent_page_state;

pub use begin_concurrent::concurrent_prepare_write_page;

pub use begin_concurrent::concurrent_read_page;

pub use begin_concurrent::concurrent_restore_page_state;

pub use begin_concurrent::concurrent_rollback_to_savepoint;

pub use begin_concurrent::concurrent_savepoint;

pub use begin_concurrent::concurrent_stage_prepared_write_page;

pub use begin_concurrent::concurrent_track_write_conflict_page;

pub use begin_concurrent::concurrent_write_page;

pub use begin_concurrent::finalize_prepared_concurrent_commit_with_ssi;

pub use begin_concurrent::is_concurrent_mode;

pub use begin_concurrent::prepare_concurrent_commit_with_ssi;

pub use begin_concurrent::validate_first_committer_wins;

pub use bocpd::BocpdConfig;

pub use bocpd::BocpdMonitor;

pub use bocpd::ConjugateModel;

pub use bocpd::HazardFunction;

pub use bocpd::RegimeStats;

pub use cache_aligned::CACHE_LINE_BYTES;

pub use cache_aligned::CLAIMING_TIMEOUT_NO_PID_SECS;

pub use cache_aligned::CLAIMING_TIMEOUT_SECS;

pub use cache_aligned::CacheAligned;

pub use cache_aligned::RcriEntry;

pub use cache_aligned::RcriOverflowError;

pub use cache_aligned::RecentlyCommittedReadersIndex;

pub use cache_aligned::SLOT_PAYLOAD_MASK;

pub use cache_aligned::SLOT_TAG_MASK;

pub use cache_aligned::SLOT_TAG_SHIFT;

pub use cache_aligned::SharedTxnSlot;

pub use cache_aligned::SlotAcquireError;

pub use cache_aligned::TAG_CLAIMING;

pub use cache_aligned::TAG_CLEANING;

pub use cache_aligned::TxnSlotArray;

pub use cache_aligned::decode_payload;

pub use cache_aligned::decode_tag;

pub use cache_aligned::encode_claiming;

pub use cache_aligned::encode_cleaning;

pub use cache_aligned::is_sentinel;

pub use cache_aligned::rcri_bloom;

pub use cache_aligned::slot_mode;

pub use cache_aligned::slot_state;

pub use cell_delta_wal::CELL_DELTA_CHECKSUM_SIZE;

pub use cell_delta_wal::CELL_DELTA_FRAME_TYPE;

pub use cell_delta_wal::CELL_DELTA_HEADER_SIZE;

pub use cell_delta_wal::CELL_DELTA_MAX_DATA_LEN;

pub use cell_delta_wal::CELL_DELTA_MIN_FRAME_SIZE;

pub use cell_delta_wal::CellDeltaOp;

pub use cell_delta_wal::CellDeltaRecoverySummary;

pub use cell_delta_wal::CellDeltaWalFrame;

pub use cell_delta_wal::deserialize_cell_delta_batch;

pub use cell_delta_wal::serialize_cell_delta_batch;

pub use cell_routing::CellMvccMode;

pub use cell_routing::EscalationResult;

pub use cell_routing::PageTrackingState;

pub use cell_routing::RoutingContext;

pub use cell_routing::RoutingDecision;

pub use cell_routing::RoutingReason;

pub use cell_routing::TxnEscalationTracker;

pub use cell_routing::escalate_to_page_level;

pub use cell_routing::get_cell_mvcc_mode;

pub use cell_routing::set_cell_mvcc_mode;

pub use cell_routing::should_use_cell_path;

pub use cell_visibility::CellConflict;

pub use cell_visibility::CellDelta;

pub use cell_visibility::CellDeltaArena;

pub use cell_visibility::CellDeltaIdx;

pub use cell_visibility::CellDeltaKind;

pub use cell_visibility::CellGcStats;

pub use cell_visibility::CellKey;

pub use cell_visibility::CellVisibilityLog;

pub use cell_visibility::MutationOutcome;

pub use cell_visibility::can_be_logical_insert;

pub use cell_visibility::will_be_logical_delete;

pub use compat::CompatMode;

pub use compat::CoordinatorProbeResult;

pub use compat::HybridShmState;

pub use compat::ReadLockOutcome;

pub use compat::RecoveryPlan;

pub use compat::UpdatedLegacyShm;

pub use compat::begin_concurrent_check;

pub use compat::choose_reader_slot;

pub use conflict_model::AMS_SKETCH_VERSION;

pub use conflict_model::AmsEvidenceLedger;

pub use conflict_model::AmsSketch;

pub use conflict_model::AmsSketchConfig;

pub use conflict_model::AmsWindowCollector;

pub use conflict_model::AmsWindowCollectorConfig;

pub use conflict_model::AmsWindowEstimate;

pub use conflict_model::DEFAULT_AMS_R;

pub use conflict_model::DEFAULT_HEAVY_HITTER_K;

pub use conflict_model::DEFAULT_NITRO_PRECISION;

pub use conflict_model::DEFAULT_ZIPF_MAX_ITERS;

pub use conflict_model::HeadTailDecomposition;

pub use conflict_model::HeavyHitterLedgerEntry;

pub use conflict_model::InstrumentationCounters;

pub use conflict_model::MAX_AMS_R;

pub use conflict_model::MAX_HEAVY_HITTER_K;

pub use conflict_model::MAX_NITRO_PRECISION;

pub use conflict_model::MIN_AMS_R;

pub use conflict_model::MIN_HEAVY_HITTER_K;

pub use conflict_model::MIN_NITRO_PRECISION;

pub use conflict_model::NITRO_SKETCH_VERSION;

pub use conflict_model::NitroSketch;

pub use conflict_model::NitroSketchConfig;

pub use conflict_model::SpaceSavingEntry;

pub use conflict_model::SpaceSavingSummary;

pub use conflict_model::WindowCloseReason;

pub use conflict_model::ZIPF_S_MAX;

pub use conflict_model::ZIPF_S_MIN;

pub use conflict_model::ZipfMleResult;

pub use conflict_model::ams_sign;

pub use conflict_model::birthday_conflict_probability_m2;

pub use conflict_model::birthday_conflict_probability_uniform;

pub use conflict_model::compute_head_tail_decomposition;

pub use conflict_model::dedup_write_set;

pub use conflict_model::effective_collision_pool;

pub use conflict_model::effective_w_index_multiplier;

pub use conflict_model::effective_w_leaf_split;

pub use conflict_model::effective_w_root_split;

pub use conflict_model::exact_m2;

pub use conflict_model::mix64;

pub use conflict_model::p_abort_attempt;

pub use conflict_model::p_drift;

pub use conflict_model::pairwise_conflict_probability;

pub use conflict_model::policy_collision_mass_input;

pub use conflict_model::tps_estimate;

pub use conflict_model::validate_ams_r;

pub use conflict_model::validate_heavy_hitter_k;

pub use conflict_model::validate_nitro_precision;

pub use conflict_model::zipf_mle_from_ranked_counts;

pub use conformal_martingale::ConformalMartingaleConfig;

pub use conformal_martingale::ConformalMartingaleMonitor;

pub use core_types::CommitIndex;

pub use core_types::CommitLog;

pub use core_types::CommitRecord;

pub use core_types::DrainProgress;

pub use core_types::DrainResult;

pub use core_types::GcHorizonResult;

pub use core_types::InProcessPageLockTable;

pub use core_types::LOCK_TABLE_SHARDS;

pub use core_types::OrphanedSlotCleanupStats;

pub use core_types::RebuildError;

pub use core_types::RebuildResult;

pub use core_types::SlotCleanupResult;

pub use core_types::Transaction;

pub use core_types::TransactionMode;

pub use core_types::TransactionState;

pub use core_types::VersionArena;

pub use core_types::VersionIdx;

pub use core_types::cleanup_and_raise_gc_horizon;

pub use core_types::cleanup_orphaned_slots;

pub use core_types::raise_gc_horizon;

pub use core_types::try_cleanup_orphaned_slot;

pub use core_types::try_cleanup_sentinel_slot;

pub use deterministic_rebase::BaseRowReader;

pub use deterministic_rebase::RebaseEligibility;

pub use deterministic_rebase::RebaseError;

pub use deterministic_rebase::RebaseResult;

pub use deterministic_rebase::RebaseSchemaLookup;

pub use deterministic_rebase::ReplayResult;

pub use deterministic_rebase::TableConstraints;

pub use deterministic_rebase::UpdateExpressionCandidate;

pub use deterministic_rebase::can_emit_update_expression;

pub use deterministic_rebase::check_rebase_eligibility;

pub use deterministic_rebase::check_schema_epoch;

pub use deterministic_rebase::deterministic_rebase;

pub use deterministic_rebase::replay_update_expression;

pub use differential_privacy::DpEngine;

pub use differential_privacy::DpError;

pub use differential_privacy::DpMetrics;

pub use differential_privacy::DpQueryResult;

pub use differential_privacy::NoiseMechanism;

pub use differential_privacy::PrivacyBudget;

pub use differential_privacy::dp_metrics;

pub use differential_privacy::reset_dp_metrics;

pub use differential_privacy::sensitivity;

pub use ebr::EbrMetrics;

pub use ebr::EbrMetricsSnapshot;

pub use ebr::EbrRetireQueue;

pub use ebr::GLOBAL_EBR_METRICS;

pub use ebr::ReaderPinSnapshot;

pub use ebr::StaleReaderConfig;

pub use ebr::VersionGuard;

pub use ebr::VersionGuardRegistry;

pub use ebr::VersionGuardTicket;

pub use flat_combining::FcHandle;

pub use flat_combining::FlatCombiner;

pub use flat_combining::FlatCombiningMetrics;

pub use flat_combining::MAX_FC_THREADS;

pub use flat_combining::OP_ADD;

pub use flat_combining::OP_READ;

pub use flat_combining::flat_combining_metrics;

pub use flat_combining::reset_flat_combining_metrics;

pub use gc::GC_F_MAX_HZ;

pub use gc::GC_F_MIN_HZ;

pub use gc::GC_PAGES_BUDGET;

pub use gc::GC_TARGET_CHAIN_LENGTH;

pub use gc::GC_VERSIONS_BUDGET;

pub use gc::GcScheduler;

pub use gc::GcTickResult;

pub use gc::GcTodo;

pub use gc::PruneResult;

pub use gc::gc_tick;

pub use gc::prune_page_chain;

pub use history_compression::CertificateVerificationError;

pub use history_compression::CircuitBreakerEvent;

pub use history_compression::CompressedPageHistory;

pub use history_compression::CompressedPageVersion;

pub use history_compression::CompressedVersionData;

pub use history_compression::HistoryCompressionError;

pub use history_compression::MergeCertificate;

pub use history_compression::MergeCertificatePostState;

pub use history_compression::MergeKind;

pub use history_compression::VERIFIER_VERSION;

pub use history_compression::are_intent_ops_independent;

pub use history_compression::circuit_breaker_check;

pub use history_compression::collapse_join_max_updates;

pub use history_compression::compress_page_history;

pub use history_compression::compute_footprint_digest;

pub use history_compression::compute_op_digest;

pub use history_compression::extract_join_max_constant;

pub use history_compression::foata_normal_form;

pub use history_compression::generate_merge_certificate;

pub use history_compression::is_join_max_int_update;

pub use history_compression::is_mergeable_intent;

pub use history_compression::verify_merge_certificate;

pub use hot_witness_index::ColdPlaneMode;

pub use hot_witness_index::ColdWitnessStore;

pub use hot_witness_index::HotWitnessBucketEntry;

pub use hot_witness_index::HotWitnessIndex;

pub use hot_witness_index::bitset_to_slot_ids;

pub use index_regen::Collation;

pub use index_regen::IndexDef;

pub use index_regen::IndexKeyPart;

pub use index_regen::IndexRegenError;

pub use index_regen::IndexRegenOps;

pub use index_regen::NoOpUniqueChecker;

pub use index_regen::UniqueChecker;

pub use index_regen::apply_column_updates;

pub use index_regen::compute_index_key;

pub use index_regen::discard_stale_index_ops;

pub use index_regen::eval_rebase_expr;

pub use index_regen::regenerate_index_ops;

pub use invariants::CHAIN_HEAD_EMPTY;

pub use invariants::CHAIN_HEAD_SHARDS;

pub use invariants::CasInstallResult;

pub use invariants::ChainHeadTable;

pub use invariants::SerializedWriteMutex;

pub use invariants::SnapshotResolveTrace;

pub use invariants::TxnManager;

pub use invariants::VersionStore;

pub use invariants::VersionVisibilityRange;

pub use invariants::idx_to_version_pointer;

pub use invariants::visible;

pub use left_right::LeftRight;

pub use left_right::LeftRightMetrics;

pub use left_right::LeftRightPair;

pub use left_right::LeftRightTriple;

pub use left_right::leftright_metrics;

pub use left_right::reset_leftright_metrics;

pub use lifecycle::BeginKind;

pub use lifecycle::CommitResponse;

pub use lifecycle::MvccError;

pub use lifecycle::Savepoint;

pub use lifecycle::TransactionManager;

pub use materialize::DEFAULT_MATERIALIZATION_THRESHOLD;

pub use materialize::MaterializationError;

pub use materialize::MaterializationResult;

pub use materialize::MaterializationTrigger;

pub use materialize::materialize_page;

pub use materialize::should_materialize_eagerly;

pub use observability::CasMetricsSnapshot;

pub use observability::CasRetriesHistogram;

pub use observability::SharedObserver;

pub use observability::SnapshotReadMetricsSnapshot;

pub use observability::SsiMetricsSnapshot;

pub use observability::VersionsTraversedHistogram;

pub use observability::cas_metrics_snapshot;

pub use observability::emit_conflict_resolved;

pub use observability::emit_fcw_base_drift;

pub use observability::emit_page_lock_contention;

pub use observability::emit_ssi_abort;

pub use observability::mvcc_snapshot_established;

pub use observability::mvcc_snapshot_metrics_snapshot;

pub use observability::mvcc_snapshot_released;

pub use observability::record_cas_attempt;

pub use observability::record_snapshot_read_versions_traversed;

pub use observability::record_ssi_abort;

pub use observability::record_ssi_commit;

pub use observability::reset_cas_metrics;

pub use observability::reset_mvcc_snapshot_metrics;

pub use observability::reset_ssi_metrics;

pub use observability::ssi_metrics_snapshot;

pub use physical_merge::CellOp;

pub use physical_merge::CellOpKind;

pub use physical_merge::FreeSpaceOp;

pub use physical_merge::HeaderOp;

pub use physical_merge::MergeError;

pub use physical_merge::MergeLadderResult;

pub use physical_merge::ParsedCell;

pub use physical_merge::ParsedPage;

pub use physical_merge::RangeXorPatch;

pub use physical_merge::StructuredPagePatch;

pub use physical_merge::apply_patch;

pub use physical_merge::diff_parsed_pages;

pub use physical_merge::evaluate_merge_ladder;

pub use physical_merge::merge_structured_patches;

pub use physical_merge::parse_btree_page;

pub use physical_merge::repack_btree_page;

pub use provenance::ProvenanceAnnotation;

pub use provenance::ProvenanceMetrics;

pub use provenance::ProvenanceMode;

pub use provenance::ProvenanceReport;

pub use provenance::ProvenanceToken;

pub use provenance::ProvenanceTracker;

pub use provenance::TupleId;

pub use provenance::WhyNotResult;

pub use provenance::provenance_metrics;

pub use provenance::reset_provenance_metrics;

pub use provenance::why_not;

pub use rcu::MAX_RCU_THREADS;

pub use rcu::QsbrHandle;

pub use rcu::QsbrRegistry;

pub use rcu::RcuCell;

pub use rcu::RcuMetrics;

pub use rcu::RcuPair;

pub use rcu::RcuTriple;

pub use rcu::rcu_metrics;

pub use rcu::record_rcu_reclaimed;

pub use rcu::reset_rcu_metrics;

pub use regime_monitor::RegimeMonitor;

pub use regime_monitor::RegimeMonitorConfig;

pub use retry_policy::BetaPosterior;

pub use retry_policy::ContentionBucketKey;

pub use retry_policy::DEFAULT_CANDIDATE_WAITS_MS;

pub use retry_policy::DEFAULT_STARVATION_THRESHOLD;

pub use retry_policy::HazardModelParams;

pub use retry_policy::MAX_CONTENTION_BUCKETS;

pub use retry_policy::RetryAction;

pub use retry_policy::RetryController;

pub use retry_policy::RetryCostParams;

pub use retry_policy::RetryEvidenceEntry;

pub use retry_policy::expected_loss_failnow;

pub use retry_policy::expected_loss_retry;

pub use retry_policy::gittins_index_approx;

pub use retry_policy::gittins_threshold;

pub use rowid_alloc::AllocatorKey;

pub use rowid_alloc::ConcurrentRowIdAllocator;

pub use rowid_alloc::DEFAULT_RANGE_SIZE;

pub use rowid_alloc::LocalRowIdCache;

pub use rowid_alloc::RangeReservation;

pub use rowid_alloc::RowIdAllocError;

pub use rowid_alloc::SQLITE_FULL;

pub use rowid_alloc::SQLITE_SCHEMA;

pub use seqlock::SeqLock;

pub use seqlock::SeqLockPair;

pub use seqlock::SeqLockTriple;

pub use seqlock::SeqlockMetrics;

pub use seqlock::reset_seqlock_metrics;

pub use seqlock::seqlock_metrics;

pub use shared_lock_table::AcquireResult;

pub use shared_lock_table::DEFAULT_TABLE_CAPACITY;

pub use shared_lock_table::DrainStatus;

pub use shared_lock_table::RebuildLeaseError;

pub use shared_lock_table::RebuildResult as SharedRebuildResult;

pub use shared_lock_table::SharedPageLockTable;

pub use sheaf_conformal::ConformalCalibratorConfig;

pub use sheaf_conformal::ConformalOracleCalibrator;

pub use sheaf_conformal::ConformalPrediction;

pub use sheaf_conformal::InvariantScore;

pub use sheaf_conformal::OpportunityScore;

pub use sheaf_conformal::OracleReport;

pub use sheaf_conformal::PredictionSetEntry;

pub use sheaf_conformal::Section;

pub use sheaf_conformal::SheafObstruction;

pub use sheaf_conformal::SheafResult;

pub use sheaf_conformal::check_sheaf_consistency;

pub use sheaf_conformal::check_sheaf_consistency_with_chains;

pub use shm::SharedMemoryLayout;

pub use shm::ShmSnapshot;

pub use sketch_telemetry::CMS_VERSION;

pub use sketch_telemetry::CountMinSketch;

pub use sketch_telemetry::CountMinSketchConfig;

pub use sketch_telemetry::DEFAULT_ALLOC_SIZE_BUCKETS;

pub use sketch_telemetry::DEFAULT_CMS_DEPTH;

pub use sketch_telemetry::DEFAULT_CMS_WIDTH;

pub use sketch_telemetry::DEFAULT_LATENCY_BUCKETS_US;

pub use sketch_telemetry::HISTOGRAM_VERSION;

pub use sketch_telemetry::HistogramSnapshot;

pub use sketch_telemetry::MemoryAllocationTracker;

pub use sketch_telemetry::MemoryTrackerSnapshot;

pub use sketch_telemetry::NITROSKETCH_STREAMING_VERSION;

pub use sketch_telemetry::SketchTelemetryMetrics;

pub use sketch_telemetry::SlidingWindowCms;

pub use sketch_telemetry::SlidingWindowConfig;

pub use sketch_telemetry::SlidingWindowHistogram;

pub use sketch_telemetry::SlidingWindowHistogramSnapshot;

pub use sketch_telemetry::StreamingHistogram;

pub use sketch_telemetry::reset_sketch_telemetry_metrics;

pub use sketch_telemetry::sketch_telemetry_metrics;

pub use ssi_abort_policy::AbortDecision;

pub use ssi_abort_policy::AbortDecisionEnvelope;

pub use ssi_abort_policy::ConformalCalibrator;

pub use ssi_abort_policy::ConformalConfig;

pub use ssi_abort_policy::CycleStatus;

pub use ssi_abort_policy::DroHotPathDecision;

pub use ssi_abort_policy::DroLossMatrix;

pub use ssi_abort_policy::DroObservedRateKind;

pub use ssi_abort_policy::DroRadiusCertificate;

pub use ssi_abort_policy::DroRiskTolerance;

pub use ssi_abort_policy::DroVolatilityTracker;

pub use ssi_abort_policy::DroVolatilityTrackerConfig;

pub use ssi_abort_policy::DroVolatilityTrackerError;

pub use ssi_abort_policy::DroWindowObservation;

pub use ssi_abort_policy::LossMatrix;

pub use ssi_abort_policy::SsiDecisionCard;

pub use ssi_abort_policy::SsiDecisionCardDraft;

pub use ssi_abort_policy::SsiDecisionQuery;

pub use ssi_abort_policy::SsiDecisionType;

pub use ssi_abort_policy::SsiEvidenceLedger;

pub use ssi_abort_policy::SsiFpMonitor;

pub use ssi_abort_policy::SsiFpMonitorConfig;

pub use ssi_abort_policy::SsiReadSetSummary;

pub use ssi_abort_policy::TxnCost;

pub use ssi_abort_policy::Victim;

pub use ssi_abort_policy::VictimDecision;

pub use ssi_abort_policy::dro_wasserstein_radius;

pub use ssi_abort_policy::select_victim;

pub use ssi_validation::ActiveTxnView;

pub use ssi_validation::CommittedReaderInfo;

pub use ssi_validation::CommittedWriterInfo;

pub use ssi_validation::DiscoveredEdge;

pub use ssi_validation::EvidenceRecordMetricsSnapshot;

pub use ssi_validation::SsiAbortReason;

pub use ssi_validation::SsiBusySnapshot;

pub use ssi_validation::SsiEvidenceBudgetConfig;

pub use ssi_validation::SsiEvidenceRecordingMode;

pub use ssi_validation::SsiState;

pub use ssi_validation::SsiValidationOk;

pub use ssi_validation::discover_incoming_edges;

pub use ssi_validation::discover_outgoing_edges;

pub use ssi_validation::reset_ssi_evidence_metrics;

pub use ssi_validation::set_ssi_evidence_budget_config;

pub use ssi_validation::set_ssi_evidence_recording_mode;

pub use ssi_validation::ssi_evidence_budget_config;

pub use ssi_validation::ssi_evidence_metrics_snapshot;

pub use ssi_validation::ssi_evidence_query;

pub use ssi_validation::ssi_evidence_recording_mode;

pub use ssi_validation::ssi_evidence_snapshot;

pub use ssi_validation::ssi_validate_and_publish;

pub use time_travel::TimeTravelError;

pub use time_travel::TimeTravelSnapshot;

pub use time_travel::TimeTravelTarget;

pub use time_travel::create_time_travel_snapshot;

pub use time_travel::resolve_page_at_commit;

pub use time_travel::resolve_timestamp_via_commit_log;

pub use time_travel::resolve_timestamp_via_markers;

pub use two_phase_commit::COMMIT_MARKER_MAGIC;

pub use two_phase_commit::COMMIT_MARKER_MIN_SIZE;

pub use two_phase_commit::DatabaseId;

pub use two_phase_commit::GlobalCommitMarker;

pub use two_phase_commit::MAIN_DB_ID;

pub use two_phase_commit::MAX_TOTAL_DATABASES;

pub use two_phase_commit::ParticipantState;

pub use two_phase_commit::PrepareResult;

pub use two_phase_commit::RecoveryAction;

pub use two_phase_commit::SQLITE_MAX_ATTACHED;

pub use two_phase_commit::TEMP_DB_ID;

pub use two_phase_commit::TwoPhaseCoordinator;

pub use two_phase_commit::TwoPhaseError;

pub use two_phase_commit::TwoPhaseState;

pub use witness_hierarchy::HotWitnessIndexDerivationV1;

pub use witness_hierarchy::HotWitnessIndexSizingV1;

pub use witness_hierarchy::WitnessHierarchyConfigV1;

pub use witness_hierarchy::WitnessHotIndexManifestV1;

pub use witness_hierarchy::WitnessSizingError;

pub use witness_hierarchy::derive_range_keys;

pub use witness_hierarchy::extract_prefix;

pub use witness_hierarchy::range_key_bucket_index;

pub use witness_hierarchy::witness_key_canonical_bytes;

pub use witness_hierarchy::witness_key_hash;

pub use witness_objects::AbortPolicy;

pub use witness_objects::AbortReason;

pub use witness_objects::AbortWitness;

pub use witness_objects::ColdPlaneRefinementResult;

pub use witness_objects::DependencyEdgeKind;

pub use witness_objects::EcsCommitProof;

pub use witness_objects::EcsDependencyEdge;

pub use witness_objects::EcsReadWitness;

pub use witness_objects::EcsWriteWitness;

pub use witness_objects::EdgeKeyBasis;

pub use witness_objects::HotPlaneCandidates;

pub use witness_objects::KeySummary;

pub use witness_objects::KeySummaryChunk;

pub use witness_objects::LogicalTime;

pub use witness_objects::WitnessDelta;

pub use witness_objects::WitnessDeltaKind;

pub use witness_objects::WitnessParticipation;

pub use witness_objects::WriteKind;

pub use witness_objects::cold_plane_refine;

pub use witness_objects::hot_plane_discover;

pub use witness_plane::WitnessSet;

pub use witness_plane::validate_txn_token;

pub use witness_plane::witness_keys_overlap;

pub use witness_publication::ActiveSlotSnapshot;

pub use witness_publication::CommitMarkerStore;

pub use witness_publication::CommittedPublication;

pub use witness_publication::DefaultProofValidator;

pub use witness_publication::GcEligibility;

pub use witness_publication::ProofCarryingCommit;

pub use witness_publication::ProofCarryingValidator;

pub use witness_publication::PublicationError;

pub use witness_publication::PublicationPhase;

pub use witness_publication::ReservationId;

pub use witness_publication::ReservationToken;

pub use witness_publication::ValidationVerdict;

pub use witness_publication::WitnessGcCoordinator;

pub use witness_publication::WitnessPublisher;

pub use witness_refinement::RefinementBudget;

pub use witness_refinement::RefinementDecision;

pub use witness_refinement::RefinementPriority;

pub use witness_refinement::RefinementResult;

pub use witness_refinement::VoiMetrics;

pub use witness_refinement::refine_edges;

pub use write_coordinator::CommitWriteSet;

pub use write_coordinator::CompatCommitRequest;

pub use write_coordinator::CompatCommitResponse;

pub use write_coordinator::CoordinatorLease;

pub use write_coordinator::CoordinatorMode;

pub use write_coordinator::DEFAULT_MAX_BATCH_SIZE;

pub use write_coordinator::DEFAULT_SPILL_THRESHOLD;

pub use write_coordinator::NativePublishRequest;

pub use write_coordinator::NativePublishResponse;

pub use write_coordinator::SpillHandle;

pub use write_coordinator::SpillLoc;

pub use write_coordinator::SpilledWriteSet;

pub use write_coordinator::WriteCoordinator;

pub use xor_delta::DEFAULT_DELTA_THRESHOLD_PCT;

pub use xor_delta::DELTA_FIXED_OVERHEAD_BYTES;

pub use xor_delta::DELTA_HEADER_BYTES;

pub use xor_delta::DELTA_MAGIC;

pub use xor_delta::DELTA_RUN_HEADER_BYTES;

pub use xor_delta::DELTA_SPARSE_OVERHEAD_PCT;

pub use xor_delta::DELTA_VERSION;

pub use xor_delta::DeltaEncoding;

pub use xor_delta::DeltaError;

pub use xor_delta::DeltaThresholdConfig;

pub use xor_delta::SparseXorDeltaObject;

pub use xor_delta::count_nonzero_xor;

pub use xor_delta::decode_sparse_xor_delta;

pub use xor_delta::encode_page_delta;

pub use xor_delta::encode_sparse_xor_delta;

pub use xor_delta::estimate_sparse_delta_size;

pub use xor_delta::max_delta_bytes;

pub use xor_delta::reconstruct_chain_from_newest;

pub use xor_delta::use_delta;

Modules

begin_concurrent

BEGIN CONCURRENT transaction protocol (§12.10).

bocpd

Bayesian Online Change-Point Detection (§4.8, Adams & MacKay 2007).

cache_aligned

Cache-line-aware wrappers and shared-memory structures (§1.5, bd-22n.3).

cell_delta_wal

Cell-Delta WAL Frame Format (C4-WAL: bd-l9k8e.10)

cell_mvcc_boundary

Cell-Level MVCC Boundary Classification (C2, bd-l9k8e.2)

cell_routing

Cell-Level MVCC Dual-Path Routing (C-TRANSITION: bd-l9k8e.11)

cell_visibility

Cell-Level MVCC Visibility Log (C1: bd-l9k8e.1, C3: bd-l9k8e.3)

commit_combiner

Flat Combining for Commit Sequencing (D3 — bd-3wop3.3).

compat

Compatibility mode: legacy interop and hybrid SHM protocol (§5.6.6-5.6.7).

conflict_model

Probabilistic conflict model for MVCC concurrent writers (§18.1-18.4).

conformal_martingale

Conformal Martingale Regime Shift Detector (C-MRSD).

coordinator_ipc

§5.9.0 Coordinator IPC Transport: Unix Socket Protocol + Wire Schemas (bd-1m07).

core_types

MVCC core runtime types (§5.1).

deterministic_rebase

§5.10.2 Deterministic Rebase & Index Regeneration — bd-1h3b

differential_privacy

Differential privacy for aggregate queries (bd-19u.7, §12.5).

ebr

Epoch-based reclamation scaffolding for MVCC version-chain GC.

flat_combining

Flat Combining for sequential batching under contention (§14.2).

gc

GC coordination: scheduling, todo queue, and incremental pruning (§5.6.5).

history_compression

§5.10.6-5.10.8 History Compression, Intent Commutativity, and Merge Certificates.

hot_witness_index

§5.6.4.5 Hot Plane (Shared Memory): HotWitnessIndex.

index_regen

§5.10.2.1 Index Regeneration on Rebase — bd-zj56

invariants

MVCC invariant enforcement and visibility predicates (§5.2-5.3).

left_right

Left-Right wait-free reads for metadata (§14.3).

lifecycle

Transaction lifecycle (§5.4): Begin/Read/Write/Commit/Abort.

materialize

Page Materialization Layer (C5: bd-l9k8e.5)

observability

MVCC observability integration.

physical_merge

§5.10.3-5.10.5 Physical Merge: Structured Page Patches & Safety Ladder.

provenance

Provenance semirings for query lineage (bd-19u.3, §8.9).

rcu

RCU/QSBR for lock-free metadata hot paths (§14.8).

regime_monitor

Unified Regime Monitor interface.

retry_policy

§18.8 Retry Policy: Beta-Bernoulli Expected-Loss Controller + Starvation Fairness.

rowid_alloc

Coordinator-owned RowId allocator for BEGIN CONCURRENT mode (§5.10.1.1).

seqlock

Generic seqlock (§14.9) for optimistic metadata reads.

shared_lock_table

Cross-process shared-memory page lock table with rolling rebuild (§5.6.3).

sheaf_conformal

Sheaf consistency checking + conformal calibration (§4.6-4.7).

shm

Shared-memory header layout for cross-process MVCC coordination (§5.6.1).

sketch_telemetry

NitroSketch probabilistic telemetry (bd-19u.4).

ssi_abort_policy

Decision-theoretic SSI abort policy: victim selection + loss minimization (§5.7.3).

ssi_validation

§5.7.3 Commit-Time SSI Validation (Proof-Carrying).

time_travel

§12.17 Time Travel Queries — FOR SYSTEM_TIME AS OF support.

two_phase_commit

Cross-database two-phase commit protocol (§12.11).

witness_hierarchy

witness_objects

§5.7.1-5.7.2 SSI Witness Objects (Canonical ECS Schemas) + Hot/Cold Discovery.

witness_plane

SSI Witness Plane: Requirements, TxnToken Identity, WitnessKey Granularity (§5.6.4.1-5.6.4.3).

witness_publication

§5.6.4.7 Publication Protocol (Cancel-Safe, Crash-Resilient), §5.6.4.8 Witness GC and Bucket Epochs, §5.6.4.9 Distributed Mode: Proof-Carrying Replication (Normative Hook).

witness_refinement

§5.7.4 Witness Refinement Policy (VOI-Driven, Bounded).

write_coordinator

§5.9.1-5.9.2 Write Coordinator: Native Mode Sequencer + Compatibility WAL Path.

xor_delta

XOR-delta compression for MVCC version chains (§3.4.4, bd-1hi.16).