feat: Support compressing HTTP contents (#74)

* Support compressing HTTP contents

* Apply suggestions from code review

Co-authored-by: Malte Sander <[email protected]>

---------

Co-authored-by: Malte Sander <[email protected]>

Author: sbernauer

CHANGELOG.md

@@ -8,6 +8,9 @@ All notable changes to this project will be documented in this file.
 
 - Support configuring compression for OTEL ([#70]).
 - Improve tracing details by adding a `tower_http::trace::TraceLayer` that creates spans for every HTTP request ([#71]).
+- Support compressing HTTP contents, previously the content was always uncompressed.
+  This consumes more CPU, but also reduces the data amount sent to Trino clients.
+  E.g. `trino-cli` by default asks for `gzip` compressed content ([#74]).
 
 ### Changed
 
@@ -17,6 +20,7 @@ All notable changes to this project will be documented in this file.
 [#70]: https://github.com/stackabletech/trino-lb/pull/70
 [#71]: https://github.com/stackabletech/trino-lb/pull/71
 [#73]: https://github.com/stackabletech/trino-lb/pull/73
+[#74]: https://github.com/stackabletech/trino-lb/pull/74
 
 ## [0.4.1] - 2025-03-03
 

Cargo.lock

@@ -82,7 +82,7 @@ sqlx = { version = "0.8.2", features = [
 strum = { version = "0.27", features = ["derive"] }
 tokio = "1.39"
 tower = "0.5"
-tower-http = { version = "0.6", features = ["tracing"] }
+tower-http = { version = "0.6", features = ["compression-full", "tracing"] }
 tracing = "0.1"
 tracing-opentelemetry = "0.25"
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }

Cargo.toml

@@ -15,7 +15,7 @@ use axum_server::{tls_rustls::RustlsConfig, Handle};
 use futures::FutureExt;
 use snafu::{OptionExt, ResultExt, Snafu};
 use tokio::time::sleep;
-use tower_http::trace::TraceLayer;
+use tower_http::{compression::CompressionLayer, trace::TraceLayer};
 use tracing::info;
 use trino_lb_persistence::PersistenceImplementation;
 
@@ -124,6 +124,7 @@ pub async fn start_http_server(
         .route("/ui/index.html", get(ui::index::get_ui_index))
         .route("/ui/query.html", get(ui::query::get_ui_query))
         .layer(TraceLayer::new_for_http())
+        .layer(CompressionLayer::new())
         .with_state(app_state);
 
     if tls_config.enabled {