Module series_scan 

Per-series scan implementation.

Structs

CandidateReceiver 🔒

FlatSeriesBatch

Batches of the same series in flat format.

FlatSeriesBatchDivider 🔒

A divider to split flat record batches by time series.

SenderList 🔒

List of senders.

SeriesCandidateDistributor 🔒

Discovers metric series and sends one reader assignment to each partition.

SeriesDistributor 🔒

The distributor scans series and distributes them to different partitions.

SeriesReaderInput 🔒

Input required by a partition-local series reader.

SeriesScan

Scans a region and returns sorted rows of a series in the same partition.

Enums

SeriesBatch

Batches of the same series.

SeriesScanMode 🔒

Constants

CANDIDATE_SERIES_ASSIGNMENT_THRESHOLD 🔒

Maximum number of candidate series retained before distributing assignments.

SEND_TIMEOUT 🔒

Timeout to send a batch to a sender.

Functions

new_candidate_channel_list 🔒

new_legacy_channel_list 🔒

new_partition_metrics 🔒

primary_key_at 🔒

Helper function to extract primary key bytes at a specific index from PrimaryKeyArray.

Type Aliases

CandidateReceiverList 🔒

Candidate assignment receivers for output partitions.

CandidateSenderList 🔒

Candidate assignment senders for output partitions.

LegacyReceiverList 🔒

Legacy data receivers for output partitions.