Module range_cache 

Coordinates range-result cache loads and SST retirement. No I/O or decoding runs under the coordinator lock; loaders use the shared query runtime.

Modules

shared_range 🔒

A single range scan with independently advancing readers.

Structs

CacheConcatState 🔒

CachedBatchSlice 🔒

Cached result for one range scan.

Entry 🔒

RangeCacheDelivery 🔒

Keeps completed results charged while subscribers or replay streams own them. Cache entries retain only a weak reference: after the last reader leaves, the resident value is covered solely by the cache’s capacity accounting.

RangeCacheScope 🔒

Separates active scans with different query memory reservations. Completed results are reusable across scopes. The default scope is for sources without a query-specific memory pool.

RangeLoad 🔒

Readers own the scan; the coordinator only retains a weak registration. Query-pool identity isolates active reservations, not completed cache values.

RangeRegistration 🔒

RangeResultCache 🔒

Stores completed range results and coordinates reader-owned shared scans.

RangeScanCacheValue 🔒

Compacted batches with their original stream boundaries and memory weight.

State 🔒

Enums

RangeCacheCleanup 🔒

RangeCacheLookup 🔒

Constants

RANGE_CACHE_COMPACT_THRESHOLD_BYTES 🔒

Traits

RangeCacheMetricsReport 🔒

Reports cache activity to the query that owns the reader or publication.

Functions

cached_flat_range_stream 🔒

Returns a stream that replays cached record batches.

compact_record_batches 🔒

should_compact_batches 🔒

Type Aliases

FlightKey 🔒