Module query_audit 

structured per-query audit record emitted by the FlightSQL service Structured per-query audit record for the FlightSQL service.

execute_query (see flight_sql_service_impl) emits one JSON-serialized [QueryAuditRecord] per query, at completion, under the dedicated flightsql_query_audit log target. Unlike the untagged imetric! cost metrics (whose PropertySet can’t carry high-cardinality values such as SQL text), a free-text log msg has no cardinality constraint, so it can carry both attribution and cost in one self-contained, queryable record.

Structs

QueryAuditRecord

One structured record per FlightSQL query, emitted as a JSON log line under the flightsql_query_audit target when the query completes, fails, or is abandoned mid-drain (client disconnect/cancel).

ScanMetrics

Aggregated DataFusion plan metrics for one query, read after the stream drains.

Functions

aggregate_scan_metrics

Walk the physical-plan tree: output_rows from the root node (final result grain), bytes_scanned summed across every node (leaf DataSourceExec nodes carry it).