Module prom_store

Expand description

prometheus protocol supportings handles prometheus remote_write, remote_read logic

Structs§

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
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

collect_timeseries_ids 🔒: Collect each row’s timeseries id This processing is ugly, hope https://github.com/GreptimeTeam/greptimedb/issues/336 making some progress in future.
extract_schema_from_read_request: Extract schema from remote read request. Returns the first schema found from any query’s matchers.
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
lit_timestamp_millisecond 🔒
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 🔒
query_to_plan: Create a DataFrame from a remote Query
recordbatch_to_timeseries 🔒
recordbatches_to_timeseries
snappy_compress
snappy_decompress
table_name: Get table name from remote query
to_grpc_row_insert_requests
zstd_decompress