Module prometheus 

prom supply the prometheus HTTP API Server compliance

Macros

handle_schema_err 🔒

Handles schema errors, transforming a Result into an Option.

try_call_return_response 🔒

Helper macro which try to evaluate the expression and return its results. If the evaluation fails, return a PrometheusJsonResponse early.

Structs

BuildInfoQuery

Column

A “holder” for the reference(Arc) to a column name, to help avoiding cloning Strings when used as a HashMap key.

ColumnRef 🔒

FormatQuery

InstantQuery

LabelValueQuery

LabelsQuery

Matches 🔒

MetadataQuery

Query parameters for the Prometheus metric metadata endpoint.

MetricNameDiscovery 🔒

ParseQuery

PromData

PromMetadata

Metadata for a Prometheus metric family.

PromNativeHistogram

A native histogram sample in the Prometheus HTTP API JSON format.

PromSeriesMatrix

For [ValueType::Matrix] result type

PromSeriesVector

For [ValueType::Vector] result type

PrometheusJsonResponse

RangeQuery

RowWriter 🔒

Writer from a row in the record batch to a Prometheus time series:

SeriesQuery

Enums

PromQueryResult

Variants corresponding to [ValueType]

PromSampleValue

A sample value of the Prometheus HTTP API JSON format.

PrometheusResponse

Traits

AsColumnRef 🔒

Functions

build_info_query

collect_metric_names 🔒

Recursively collect all metric names from a PromQL expression

collect_static_promql_targets 🔒

collect_static_vector_target 🔒

current_schema_metric_targets 🔒

do_instant_query 🔒

Executes a single instant query and returns response

do_range_query 🔒

Executes a single range query and returns response

expand_metric_name_queries 🔒

extend_tag_column_names 🔒

find_metric_name_and_matchers 🔒

find_metric_name_not_equal_matchers 🔒

Finds non-equality __name__ matchers and their unambiguous schema.

format_query

get_all_column_names 🔒

Get all tag column name of the given schema

get_catalog_schema 🔒

Tries to get catalog and schema from an optional db param. And retrieves them from [QueryContext] if they don’t present.

get_target_column_names 🔒

instant_query

is_internal_physical_metric_table 🔒

is_ordinary_label_matcher 🔒

Whether a matcher constrains an ordinary label. The others name the metric, the database or the field, none of which is a column to scan.

is_prometheus_metric_table 🔒

is_prometheus_value_column 🔒

label_values_query

labels_query

metadata_query

metric_name_matches 🔒

Whether a metric name satisfies every __name__ matcher of one selector.

parse_query

prometheus_metadata_from_table 🔒

promql_expr_to_metric_name 🔒

range_query

record_batches_to_labels_name 🔒

Retrieve labels name from record batches

record_batches_to_series 🔒

resolved_promql_targets 🔒

retrieve_exact_metric_name_from_promql 🔒

retrieve_field_names 🔒

retrieve_labels_name_from_query_result 🔒

Retrieve labels name from query result

retrieve_metric_metadata 🔒

retrieve_metric_name_and_result_type 🔒

retrieve_schema_names 🔒

retrieve_series_from_query_result 🔒

retrieve_table_names 🔒

retrieve_table_names_by_labels 🔒

Resolves selectors constraining ordinary labels into metric names: the data answers the label matchers, then each selector’s __name__ matchers narrow the names it found.

series_query

split_selectors_by_label_use 🔒

Splits match[] selectors by whether they constrain an ordinary label. The first group is answerable from table metadata; the second needs the data read and is returned as parsed selectors.

static_promql_targets 🔒

table_has_native_histogram_value 🔒

take_metric_name 🔒

Take metric name from the [VectorSelector]. It takes the name in the selector or removes the name matcher.

take_metric_name_matchers 🔒

Removes every __name__ matcher from the selector and returns them, so the rest can be planned as column predicates. A name given as VectorSelector::name comes back as an equality matcher, making both spellings filter alike.

truncate_results 🔒

try_update_catalog_schema 🔒

Update catalog and schema in [QueryContext] if necessary.

update_metric_name_matcher 🔒

Update the __name__ matchers in expression into special value Returns the updated expression.