micromegas/servers/mod.rs
1pub mod axum_utils;
2
3/// connection info utilities for Tonic services
4pub mod connect_info_layer;
5
6/// http utilities
7pub mod http_utils;
8
9/// scheduled task for daemon
10pub mod cron_task;
11
12/// routes for ingestion server based on axum
13pub mod ingestion;
14
15/// OTLP/HTTP routes (logs, metrics, traces) for the ingestion server
16pub mod otlp;
17
18/// generic header-described webhook ingestion route
19pub mod webhook;
20
21/// Kinesis Data Firehose HTTP Endpoint Delivery route for OTLP metrics (CloudWatch Metric
22/// Streams)
23pub mod firehose;
24
25/// shared auth/response/request-id plumbing for every Firehose-backed ingestion route
26pub mod firehose_common;
27
28/// resolving the authenticated write audience at the HTTP edge
29pub mod write_audience;
30
31/// Kinesis Data Firehose HTTP Endpoint Delivery route for CloudWatch Logs subscription
32/// filters
33pub mod firehose_cloudwatch_logs;
34
35/// shared body-limit / decompression layers for ingestion routers (OTLP, webhook)
36pub(crate) mod ingestion_limits;
37
38/// implementation of maintenance daemon keeping the lakehouse updated
39pub mod maintenance;
40
41/// periodic self-observability collector for the metadata Postgres's pg_stat_* views
42pub mod pg_stats;
43
44/// minimal FlightSQL protocol implementation
45pub mod flight_sql_service_impl;
46
47/// structured per-query audit record emitted by the FlightSQL service
48pub mod query_audit;
49
50/// FlightSQL server builder
51pub mod flight_sql_server;
52
53/// web server for perfetto traces
54pub mod perfetto;
55
56/// metadata about this implementation of FlightSQL
57pub mod sqlinfo;
58
59/// log uris of http requests
60pub mod log_uri_service;
61
62/// http server that redirects queries to the analytics server translating the response into json
63pub mod http_gateway;
64
65/// authentication for the gRPC stack
66pub mod tonic_auth_interceptor;
67
68/// health check service for gRPC servers
69pub mod grpc_health_service;
70
71/// SIGTERM-driven graceful shutdown primitives shared by all services
72pub mod shutdown;
73
74/// shared readiness probe logic (DB + blob, 1 s success cache)
75pub mod readiness;
76
77/// `CREATE [OR REPLACE] MATERIALIZED VIEW` / `DROP MATERIALIZED VIEW` DDL: parsing and the
78/// admin gate.
79pub mod view_ddl;