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/// Kinesis Data Firehose HTTP Endpoint Delivery route for CloudWatch Logs subscription
29/// filters
30pub mod firehose_cloudwatch_logs;
31
32/// shared body-limit / decompression layers for ingestion routers (OTLP, webhook)
33pub(crate) mod ingestion_limits;
34
35/// implementation of maintenance daemon keeping the lakehouse updated
36pub mod maintenance;
37
38/// periodic self-observability collector for the metadata Postgres's pg_stat_* views
39pub mod pg_stats;
40
41/// minimal FlightSQL protocol implementation
42pub mod flight_sql_service_impl;
43
44/// structured per-query audit record emitted by the FlightSQL service
45pub mod query_audit;
46
47/// FlightSQL server builder
48pub mod flight_sql_server;
49
50/// web server for perfetto traces
51pub mod perfetto;
52
53/// metadata about this implementation of FlightSQL
54pub mod sqlinfo;
55
56/// named keys for authentication
57pub mod key_ring;
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;