Module loki 

Structs

JsonStreamItem 🔒

LOKI_INIT_SCHEMAS 🔒

LokiJsonParser 🔒

LokiMiddleItem

This is the holder of the loki lines parsed from json or protobuf. The generic here is either [VrlValue] or Vec. Depending on the target destination, this can be converted to LokiRawItem or LokiPipeline.

LokiPbParser

LokiPipeline

This is the line item prepared for the pipeline engine.

LokiPipelineContextReq 🔒

LokiRawItem

This is the line item for the Loki raw ingestion. We’ll persist the line in its whole, set labels into tags, and structured metadata into a big JSON.

PbStreamItem

Constants

LABEL_KEY 🔒

LINES_KEY 🔒

LOKI_LINE_COLUMN 🔒

LOKI_LINE_COLUMN_NAME 🔒

LOKI_PIPELINE_LABEL_PREFIX 🔒

LOKI_PIPELINE_METADATA_PREFIX 🔒

LOKI_STRUCTURED_METADATA_COLUMN 🔒

LOKI_TABLE_NAME 🔒

STREAMS_KEY 🔒

Functions

append_label_pair_pipeline_metadata 🔒

append_pipeline_labels 🔒

append_vrl_pipeline_metadata 🔒

build_loki_context_req 🔒

build_loki_pipeline_context_req 🔒

build_loki_raw_insert_request 🔒

extract_item 🔒

Extract Loki entries from the supported wire format into the caller’s destination type.

init_row 🔒

label_pair_metadata_to_jsonb 🔒

loki_ingest

new_loki_pipeline_map 🔒

parse_loki_labels

since we’re hand-parsing the labels, if any error is encountered, we’ll just skip the label note: pub here for bench usage ref:

process_labels 🔒

prost_ts_to_nano 🔒

snappy_decompress_loki_request 🔒

vrl_metadata_to_jsonb 🔒

Type Aliases

LokiPipelineMap 🔒