mod context;
mod derived;
mod read_interests;
mod read_interests_codec;
mod reader;
#[allow(unused_imports)]
pub(crate) use read_interests::{
DiffInterestEndpoint, ExactReadIdentity, FilePathInterest, FilePathInterestComparison,
InterestDomain, LogicalReadInterest, MovingReadInterestSnapshot, ReadInterestOperation,
ReadInterestPublication, ReadInterestRegistry, ReadInterestSnapshot,
};
mod row_columnar_cache;
mod row_decoded_column_cache;
mod tracked_head;
#[cfg(test)]
pub(crate) use tracked_head::root_exact_profile;
#[cfg(test)]
pub(crate) use tracked_head::{head_decode_row_pk_probe, hot_decode_row_pk_probe};
#[cfg(test)]
pub(crate) use tracked_head::{hot_index_key_is_witness, hot_index_key_is_entry};
mod types;
pub(crate) mod visibility;
pub(crate) use crate::row_columnar::{RowColumnarWriteSets, row_group_set_id};
#[allow(unused_imports)]
pub(crate) use context::{
BranchHeadControlCache, GlobalKeyValueRowCache, HotStateContext, HotStateContextReader,
};
#[cfg(test)]
pub(crate) use reader::load_exact_batch_via_scan_for_test;
#[allow(unused_imports)]
pub(crate) use reader::{HotStateReadDomain, HotStateReader};
pub(crate) use row_columnar_cache::{
RowColumnarArrayBudget, RowColumnarShadowMaskCache, RowColumnarShadowMaskKey,
};
pub(crate) use row_decoded_column_cache::RowDecodedColumnCache;
#[cfg(test)]
pub(crate) use tracked_head::TrackedHeadDeltaRef;
#[cfg(test)]
pub(crate) use tracked_head::WORKING_DIFF_PATH_HITS;
#[cfg(test)]
pub(crate) use tracked_head::encode_hot_row_key_for_test;
pub(crate) use tracked_head::hot_generation_scope_prefix;
pub(crate) use tracked_head::stage_retire_hot_generation;
pub(crate) use tracked_head::{
stage_collect_stale_working_diff_indexes, stage_compact_checkpoint_tombstones,
};
#[cfg(any(test, feature = "storage-benches"))]
#[allow(unused_imports)]
pub(crate) use tracked_head::{
BROAD_CANONICAL_CREATED_AT_HITS, BROAD_CANONICAL_CREATED_AT_KEYS,
BROAD_CANONICAL_CREATED_AT_LOOKUPS, COMPACTED_TOMBSTONE_CANDIDATES,
COMPACTED_TOMBSTONE_COMPACTED, COMPACTED_TOMBSTONE_OFFERED, COMPACTED_TOMBSTONE_ROUTES,
HOT_SCAN_DECODED_ENTRIES, HOT_SCAN_MATCHED_ENTRIES, HOT_SCAN_TOMBSTONE_ENTRIES,
INTERVAL_LOCAL_TOMBSTONE_CANDIDATES, INTERVAL_LOCAL_TOMBSTONE_ELIDED,
INTERVAL_LOCAL_TOMBSTONE_OFFERED, INTERVAL_LOCAL_TOMBSTONE_ROUTES, encode_snapshot,
};
#[allow(unused_imports)]
pub(crate) use tracked_head::{
CERTIFIED_ROW_BATCH_MANIFEST_SPACE, CERTIFIED_ROW_BATCH_PAGE_SPACE, CERTIFIED_ROW_BATCH_SPACE,
COLLECTION_CONTROL_SPACE, CertifiedCurrentStatePredecessor,
CertifiedCurrentStatePredecessorRef, CertifiedRowBatchFileRef, ColumnarBaseCoordinate,
CompleteWorkingDiffMode, CurrentStateDeltaRef, DETERMINISTIC_IDENTITY_WITNESS_SPACE,
DIFF_SPACE, FILE_SPACE, HotIndexEntry, HotIndexValue,
HotTrackedSnapshot, INDEX_SPACE, PACKED_CURRENT_BASE_CONTROL_SPACE, PACKED_CURRENT_BASE_SPACE,
PACKED_CURRENT_EXCLUSIVE_SCHEMA_BASE_SPACE, PackedIdentityMembership, ROOT_CURRENT_BASE_SPACE,
ROW_SPACE, RowColumnarOverlayRow, TRACKED_WORKING_DIFF_MARKER_SPACE, TrackedHeadContext,
TrackedWorkingDiff, TrackedWorkingDiffEpoch, WorkingDiffIndexCoverage,
stage_certified_row_batches, stage_deterministic_identity_witness_migration,
stage_hot_index_entries, stage_hot_index_entries_rebuild, stage_tracked_working_diff_epoch,
};
#[allow(unused_imports)]
pub(crate) use types::{
Bound, DeclaredColumnEq, DeclaredColumnRange, HotStateExactBatchRequest,
HotStateExactRowRequest, HotStateFilter, HotStateProjection, HotStateRowFilter,
HotStateRowIdentityRef, HotStateRowRequest, HotStateScanRequest, MaterializedHotStateBatch,
MaterializedHotStateBatchBuilder, MaterializedHotStateExactBatch, MaterializedHotStateRow,
MaterializedHotStateRowRef, ScanConstraint, ScanField, ScanOperator,
};
#[allow(unused_imports)]
pub(crate) use visibility::{
StagedHotStateRows, VisibilityBranchScope, VisibilityRequest, expanded_branch_ids,
overlay_load_exact_batch, overlay_scan_batch, overlay_scan_indexed_declared_column_batch,
overlay_scan_tracked_batch, resolve_visible_batch,
};
#[cfg(test)]
pub(crate) use visibility::{blob_ref_probe_stats, reset_blob_ref_probe_stats};
pub(crate) use types::materialized_hot_state_row_with_snapshot_projection;
mod partial_scope_policy;
pub(crate) use partial_scope_policy::{PartialReadScopePolicy, PartialReadScopeSource};
pub(crate) use tracked_head::root_generation_absence_preconditions;
pub(crate) use tracked_head::stage_root_working_diff_epoch;
pub(crate) use tracked_head::verify_migrated_deterministic_witness;