Skip to main content

Module coverage

Module coverage 

Source
Expand description

Closed nanosecond interval coverage for catalog data, empty, and deleted segments.

Structs§

CatalogCoverageRow
Durable coverage row shared by table-backed catalog implementations.
CoverageIntervals
Effective data and known-empty coverage intervals for one request key.
CoverageSegment
A data, empty, or deleted segment recorded for a catalog key.

Enums§

CoverageKind
What a coverage segment records in the catalog log.

Constants§

COVERAGE_SCHEMA_VERSION

Functions§

compare_coverage_rows_causal
Orders coverage rows causally. data_version is a monotonic ordering token derived from the writer’s base snapshot, not a snapshot handle; rows written before versioning existed carry None and order as version 0, which is correct because every versioned row postdates them. Ties (including compacted rows sharing one version) fall back to the creation timestamp, keeping the order total and transitive on mixed catalogs.
coverage_batch_schema
coverage_intervals_by_kind
Returns effective data and known-empty intervals after applying delete tombstones.
coverage_kind_to_str
coverage_rows_to_batch
Errors
covered_intervals
Returns the effective union of all data and empty segments after applying delete tombstones.
decode_coverage_batches
Errors
deduplicate_and_sort_coverage_rows
deduplicate_coverage_rows
filter_record_batch_by_ts_init_intervals
Errors
last_data_timestamp
Returns the latest timestamp still covered by data after applying deletions.
merge_closed_intervals
Merges closed intervals, treating adjacent intervals as contiguous coverage.
missing_intervals
Returns the portions of [request_start, request_end] not covered by closed intervals.
missing_segments_for_request
Returns the portions of [request_start, request_end] not covered by data or empty segments.
rows_to_segments
Converts valid durable coverage rows to closed segments, skipping inverted ranges.
subtract_interval_from_intervals
Subtracts deleted from already merged coverage intervals.