Module prom_store 

prometheus protocol supportings handles prometheus remote_write, remote_read logic

Structs

ChargedBuffer 🔒

Decompressed bytes together with the memory permits charged for them. The permits are released when the buffer is dropped, so the aggregate memory accounting covers the whole lifetime of the decompressed data.

LabelColumn 🔒

Enums

LabelValues 🔒

Constants

DATABASE_LABEL

special label for selecting database name on remote write

DATABASE_LABEL_ALT

DATABASE_LABEL_ALT_BYTES

DATABASE_LABEL_BYTES

FIELD_NAME_LABEL

The same as FIELD_COLUMN_MATCHER in promql crate

MAX_DECOMPRESSED_REQUEST_SIZE

Hard cap on the decompressed size of a handler-decompressed request body (Prometheus remote read/write, Loki push).

METRIC_NAME_LABEL

METRIC_NAME_LABEL_BYTES

PHYSICAL_TABLE_LABEL

special label for selecting physical table name on remote write

PHYSICAL_TABLE_LABEL_ALT

PHYSICAL_TABLE_LABEL_ALT_BYTES

PHYSICAL_TABLE_LABEL_BYTES

SCHEMA_LABELDeprecated

deprecated, use DATABASE_LABEL instead

SCHEMA_LABEL_BYTESDeprecated

ZSTD_DECOMPRESS_CHUNK 🔒

Size of the chunks a zstd body is decompressed and charged in.

Functions

append_recordbatch_to_timeseries 🔒

compare_timeseries_labels 🔒

Sort timeseries by labels, matching the former BTreeMap order.

extract_schema_from_query

Extract database selector from a remote read query.

hash_timeseries 🔒

is_database_selection_label

Check if given label is a database selection label

is_physical_table_selection_label

Check if given label is a physical table selection label

is_remote_read_special_label

is_remote_write_special_label

Check if given label is a special label for remote write

label_columns 🔒

lit_timestamp_millisecond 🔒

matches_timeseries 🔒

mock_timeseries

Mock timeseries for test, it is both used in servers and frontend crate So we present it here

mock_timeseries_new_label

Add new labels to the mock timeseries.

mock_timeseries_special_labels

Add new labels to the mock timeseries.

new_label 🔒

new_timeseries 🔒

query_to_plan

Create a DataFrame from a remote Query

recordbatches_to_timeseries

row_labels 🔒

snappy_compress

snappy_decompress

Decompresses a raw Snappy body with the hard decoded-size cap enforced, without charging the aggregate request-memory limiter.

snappy_decompress_limited 🔒

Decompresses a raw Snappy body after enforcing a hard cap on the decoded size and charging the aggregate request-memory limiter.

table_name

Get table name from remote query

to_grpc_row_insert_requests

zstd_decompress_limited 🔒

Decompresses a zstd body with a hard cap on the decoded size, charging the aggregate request-memory limiter incrementally while the output is materialized (zstd streams don’t declare their decoded size up front).