diff --git a/src/handlers/http/modal/ingest_server.rs b/src/handlers/http/modal/ingest_server.rs index 215f79478..ce7ec20b2 100644 --- a/src/handlers/http/modal/ingest_server.rs +++ b/src/handlers/http/modal/ingest_server.rs @@ -249,7 +249,7 @@ impl IngestServer { web::put() .to(ingestor_logstream::put_stream) .authorize_for_stream(Action::CreateStream), - ), + ) ) .service( // GET "/logstream/{logstream}/info" ==> Get info for given log stream diff --git a/src/handlers/http/modal/query_server.rs b/src/handlers/http/modal/query_server.rs index 1f375c04b..7f58622a3 100644 --- a/src/handlers/http/modal/query_server.rs +++ b/src/handlers/http/modal/query_server.rs @@ -275,7 +275,7 @@ impl QueryServer { .to(querier_logstream::delete) .authorize_for_stream(Action::DeleteStream), ) - .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), + .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), ) .service( // GET "/logstream/{logstream}/info" ==> Get info for given log stream diff --git a/src/handlers/http/modal/server.rs b/src/handlers/http/modal/server.rs index f26723361..f9654d757 100644 --- a/src/handlers/http/modal/server.rs +++ b/src/handlers/http/modal/server.rs @@ -318,7 +318,7 @@ impl Server { .to(logstream::delete) .authorize_for_stream(Action::DeleteStream), ) - .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), + .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), ) .service( // GET "/logstream/{logstream}/info" ==> Get info for given log stream @@ -404,7 +404,7 @@ impl Server { .to(ingest::ingest) .authorize_for_stream(Action::Ingest), ) - .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)) + .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)) } // /v1/logs endpoint to be used for OTEL log ingestion only @@ -417,7 +417,7 @@ impl Server { .to(ingest::handle_otel_logs_ingestion) .authorize_for_stream(Action::Ingest), ) - .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), + .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), ) .service( web::resource("/metrics") @@ -426,7 +426,7 @@ impl Server { .to(ingest::handle_otel_metrics_ingestion) .authorize_for_stream(Action::Ingest), ) - .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), + .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), ) .service( web::resource("/traces") @@ -435,7 +435,7 @@ impl Server { .to(ingest::handle_otel_traces_ingestion) .authorize_for_stream(Action::Ingest), ) - .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), + .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)), ) }