Module servers 

Modules

axum_utils

axum-utils : observability middleware

connect_info_layer

connection info utilities for Tonic services Connection info utilities for capturing client socket addresses in Tonic services.

cron_task

scheduled task for daemon

firehose

Kinesis Data Firehose HTTP Endpoint Delivery route for OTLP metrics (CloudWatch Metric Streams) Kinesis Data Firehose HTTP Endpoint Delivery route for telemetry-ingestion-srv.

firehose_cloudwatch_logs

Kinesis Data Firehose HTTP Endpoint Delivery route for CloudWatch Logs subscription filters Kinesis Data Firehose HTTP Endpoint Delivery route for CloudWatch Logs subscription filters.

firehose_common

shared auth/response/request-id plumbing for every Firehose-backed ingestion route Shared Kinesis Data Firehose HTTP Endpoint Delivery plumbing, reused by every Firehose-backed ingestion route (metrics, CloudWatch Logs, and any future signal).

flight_sql_server

FlightSQL server builder

flight_sql_service_impl

minimal FlightSQL protocol implementation

grpc_health_service

health check service for gRPC servers

http_gateway

http server that redirects queries to the analytics server translating the response into json

http_utils

http utilities HTTP utilities for server implementations

ingestion

routes for ingestion server based on axum

log_uri_service

log uris of http requests

maintenance

implementation of maintenance daemon keeping the lakehouse updated

otlp

OTLP/HTTP routes (logs, metrics, traces) for the ingestion server OTLP/HTTP route registration for telemetry-ingestion-srv.

perfetto

web server for perfetto traces

pg_stats

periodic self-observability collector for the metadata Postgres’s pg_stat_* views Periodic self-observability collector for the metadata Postgres: samples the standard pg_stat_* catalog views (plus index/table sizes) and emits the readings as micromegas metrics through the process’s own tracing sink. This turns questions that today can only be answered by connecting to the DB (e.g. which indexes are dead weight) into hard evidence queryable via FlightSQL.

query_audit

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

readiness

shared readiness probe logic (DB + blob, 1 s success cache)

shutdown

SIGTERM-driven graceful shutdown primitives shared by all services

sqlinfo

metadata about this implementation of FlightSQL

tonic_auth_interceptor

authentication for the gRPC stack

view_ddl

CREATE [OR REPLACE] MATERIALIZED VIEW / DROP MATERIALIZED VIEW DDL: parsing and the admin gate. CREATE [OR REPLACE] MATERIALIZED VIEW ... WITH (...) / DROP MATERIALIZED VIEW ... – the DDL front end for DDL-defined eagerly materialized views.

webhook

generic header-described webhook ingestion route Generic header-described webhook ingestion route for telemetry-ingestion-srv.

write_audience

resolving the authenticated write audience at the HTTP edge Resolving the authenticated write audience at the HTTP edge.