Module insert 

Structs

CreateAlterTableResult 🔒

Result of create_or_alter_tables_on_demand.

FlowMirrorTask 🔒

Inserter

InstantAndNormalInsertRequests

Split insert requests into normal and instant requests.

Enums

AutoCreateTableType

Hint for the table type to create automatically.

Constants

SPLUNK_PK_METADATA_ORDER_KEY

QueryContext extension key the Splunk HEC handler sets (to "true") on its identity path to request metadata-first primary-key ordering at table creation. It is absent for user-supplied pipelines, so their primary-key order is left untouched.

Functions

admit_row_insert_batches

Admits all database totals before dispatching any batch of a finite request. Each batch keeps its own protocol options and target database.

admit_write

Admits a finite request before it is split into internal writes. The returned context preserves accounting while preventing a second row debit.

apply_per_table_semantic_options

Folds the semantic keys of the table being created into table_options.

build_create_table_expr

convert_rows_time_unit 🔒

convert_timestamp_value_data 🔒

count_insert_rows 🔒

fill_table_options_for_create

Fill table options for a new table by create type.

parse_per_table_semantic_index

Parses the per-table semantic index off the context extension. Call once per create-planning round: a first write creating N tables would otherwise re-parse the whole index N times. None when the request carries no index (logs, traces, Prom RW v1) or it fails to parse.

reorder_splunk_primary_keys 🔒

Moves Splunk’s metadata tags (host, source, sourcetype) to the front of the primary key, keeping the relative order of the remaining tags.

request_is_native_histogram 🔒

table_is_native_histogram 🔒

table_time_index_unit 🔒

Returns the table’s time index unit, if any. A metric table without a timestamp column is left alone by the unit alignment: the metric engine rejects it anyway.

validate_column_count_match 🔒

validate_trace_table_model

Rejects writes from a different built-in trace model before schema mutation. Unstamped, explicitly created tables remain subject to normal schema validation.

Type Aliases

InserterRef

PerTableSemanticIndex

The parsed per-table semantic index: {schema -> {table -> {key -> value}}}, produced by the OTLP metrics encode path (where one metric can fan out into several tables with distinct keys) and the Prometheus remote write v2 path (where per-series metadata declares type/unit, and a series may override its target schema).