diff --git a/envoy-types/Cargo.toml b/envoy-types/Cargo.toml index 85db151..4b8985d 100644 --- a/envoy-types/Cargo.toml +++ b/envoy-types/Cargo.toml @@ -20,7 +20,7 @@ futures-core = "0.3" prost = { version = "0.13", default-features = false, features = [ "prost-derive", ] } -tonic = { version = ">=0.12.3, <0.13", default-features = false, features = [ +tonic = { version = "0.13", default-features = false, features = [ "codegen", "transport", "prost", @@ -28,7 +28,7 @@ tonic = { version = ">=0.12.3, <0.13", default-features = false, features = [ [dev-dependencies] glob = "0.3" -tonic-build = { version = ">=0.12.3, <0.13", default-features = false, features = [ +tonic-build = { version = "0.13", default-features = false, features = [ "prost", "cleanup-markdown", ] } diff --git a/envoy-types/src/generated/envoy.service.accesslog.v3.rs b/envoy-types/src/generated/envoy.service.accesslog.v3.rs index 7e7c212..3b2af62 100644 --- a/envoy-types/src/generated/envoy.service.accesslog.v3.rs +++ b/envoy-types/src/generated/envoy.service.accesslog.v3.rs @@ -72,7 +72,7 @@ pub mod access_log_service_client { } impl AccessLogServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -93,13 +93,13 @@ pub mod access_log_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { AccessLogServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -267,7 +267,7 @@ pub mod access_log_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -329,7 +329,9 @@ pub mod access_log_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.auth.v3.rs b/envoy-types/src/generated/envoy.service.auth.v3.rs index fe0f171..f8268d8 100644 --- a/envoy-types/src/generated/envoy.service.auth.v3.rs +++ b/envoy-types/src/generated/envoy.service.auth.v3.rs @@ -359,7 +359,7 @@ pub mod authorization_client { } impl AuthorizationClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -380,13 +380,13 @@ pub mod authorization_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { AuthorizationClient::new(InterceptedService::new(inner, interceptor)) @@ -534,7 +534,7 @@ pub mod authorization_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -591,7 +591,9 @@ pub mod authorization_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.cluster.v3.rs b/envoy-types/src/generated/envoy.service.cluster.v3.rs index 2f41578..877bfd6 100644 --- a/envoy-types/src/generated/envoy.service.cluster.v3.rs +++ b/envoy-types/src/generated/envoy.service.cluster.v3.rs @@ -21,7 +21,7 @@ pub mod cluster_discovery_service_client { } impl ClusterDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -42,13 +42,13 @@ pub mod cluster_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { ClusterDiscoveryServiceClient::new( @@ -315,7 +315,7 @@ pub mod cluster_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -490,7 +490,9 @@ pub mod cluster_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.discovery.v3.rs b/envoy-types/src/generated/envoy.service.discovery.v3.rs index ad1dc44..2432887 100644 --- a/envoy-types/src/generated/envoy.service.discovery.v3.rs +++ b/envoy-types/src/generated/envoy.service.discovery.v3.rs @@ -462,7 +462,7 @@ pub mod aggregated_discovery_service_client { } impl AggregatedDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -483,13 +483,13 @@ pub mod aggregated_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { AggregatedDiscoveryServiceClient::new( @@ -703,7 +703,7 @@ pub mod aggregated_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -824,7 +824,9 @@ pub mod aggregated_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.endpoint.v3.rs b/envoy-types/src/generated/envoy.service.endpoint.v3.rs index e73ed59..df537e9 100644 --- a/envoy-types/src/generated/envoy.service.endpoint.v3.rs +++ b/envoy-types/src/generated/envoy.service.endpoint.v3.rs @@ -20,7 +20,7 @@ pub mod endpoint_discovery_service_client { } impl EndpointDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -41,13 +41,13 @@ pub mod endpoint_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { EndpointDiscoveryServiceClient::new( @@ -317,7 +317,7 @@ pub mod endpoint_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -492,7 +492,9 @@ pub mod endpoint_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( @@ -549,7 +551,7 @@ pub mod locality_endpoint_discovery_service_client { } impl LocalityEndpointDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -570,13 +572,13 @@ pub mod locality_endpoint_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { LocalityEndpointDiscoveryServiceClient::new( @@ -755,7 +757,7 @@ pub mod locality_endpoint_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -827,7 +829,9 @@ pub mod locality_endpoint_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.event_reporting.v3.rs b/envoy-types/src/generated/envoy.service.event_reporting.v3.rs index 7999608..c90fae4 100644 --- a/envoy-types/src/generated/envoy.service.event_reporting.v3.rs +++ b/envoy-types/src/generated/envoy.service.event_reporting.v3.rs @@ -58,7 +58,7 @@ pub mod event_reporting_service_client { } impl EventReportingServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -79,13 +79,13 @@ pub mod event_reporting_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { EventReportingServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -256,7 +256,7 @@ pub mod event_reporting_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -318,7 +318,9 @@ pub mod event_reporting_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.ext_proc.v3.rs b/envoy-types/src/generated/envoy.service.ext_proc.v3.rs index 6cde0bb..deb621d 100644 --- a/envoy-types/src/generated/envoy.service.ext_proc.v3.rs +++ b/envoy-types/src/generated/envoy.service.ext_proc.v3.rs @@ -523,7 +523,7 @@ pub mod external_processor_client { } impl ExternalProcessorClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -544,13 +544,13 @@ pub mod external_processor_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { ExternalProcessorClient::new(InterceptedService::new(inner, interceptor)) @@ -739,7 +739,7 @@ pub mod external_processor_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -800,7 +800,9 @@ pub mod external_processor_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.extension.v3.rs b/envoy-types/src/generated/envoy.service.extension.v3.rs index f40177b..86b2615 100644 --- a/envoy-types/src/generated/envoy.service.extension.v3.rs +++ b/envoy-types/src/generated/envoy.service.extension.v3.rs @@ -22,7 +22,7 @@ pub mod extension_config_discovery_service_client { } impl ExtensionConfigDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -43,13 +43,13 @@ pub mod extension_config_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { ExtensionConfigDiscoveryServiceClient::new( @@ -316,7 +316,7 @@ pub mod extension_config_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -497,7 +497,9 @@ pub mod extension_config_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.health.v3.rs b/envoy-types/src/generated/envoy.service.health.v3.rs index 4f269f8..82ef027 100644 --- a/envoy-types/src/generated/envoy.service.health.v3.rs +++ b/envoy-types/src/generated/envoy.service.health.v3.rs @@ -195,7 +195,7 @@ pub mod health_discovery_service_client { } impl HealthDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -216,13 +216,13 @@ pub mod health_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { HealthDiscoveryServiceClient::new( @@ -505,7 +505,7 @@ pub mod health_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -625,7 +625,9 @@ pub mod health_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.listener.v3.rs b/envoy-types/src/generated/envoy.service.listener.v3.rs index 2e88269..b24a263 100644 --- a/envoy-types/src/generated/envoy.service.listener.v3.rs +++ b/envoy-types/src/generated/envoy.service.listener.v3.rs @@ -24,7 +24,7 @@ pub mod listener_discovery_service_client { } impl ListenerDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -45,13 +45,13 @@ pub mod listener_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { ListenerDiscoveryServiceClient::new( @@ -321,7 +321,7 @@ pub mod listener_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -496,7 +496,9 @@ pub mod listener_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.load_stats.v3.rs b/envoy-types/src/generated/envoy.service.load_stats.v3.rs index f0d1af9..2a4f5e5 100644 --- a/envoy-types/src/generated/envoy.service.load_stats.v3.rs +++ b/envoy-types/src/generated/envoy.service.load_stats.v3.rs @@ -59,7 +59,7 @@ pub mod load_reporting_service_client { } impl LoadReportingServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -80,13 +80,13 @@ pub mod load_reporting_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { LoadReportingServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -304,7 +304,7 @@ pub mod load_reporting_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -369,7 +369,9 @@ pub mod load_reporting_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.metrics.v3.rs b/envoy-types/src/generated/envoy.service.metrics.v3.rs index b0d5813..f011806 100644 --- a/envoy-types/src/generated/envoy.service.metrics.v3.rs +++ b/envoy-types/src/generated/envoy.service.metrics.v3.rs @@ -43,7 +43,7 @@ pub mod metrics_service_client { } impl MetricsServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -64,13 +64,13 @@ pub mod metrics_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { MetricsServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -231,7 +231,7 @@ pub mod metrics_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -291,7 +291,9 @@ pub mod metrics_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.network_ext_proc.v3.rs b/envoy-types/src/generated/envoy.service.network_ext_proc.v3.rs index 2643835..9b5130a 100644 --- a/envoy-types/src/generated/envoy.service.network_ext_proc.v3.rs +++ b/envoy-types/src/generated/envoy.service.network_ext_proc.v3.rs @@ -191,7 +191,7 @@ pub mod network_external_processor_client { } impl NetworkExternalProcessorClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -212,13 +212,13 @@ pub mod network_external_processor_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { NetworkExternalProcessorClient::new( @@ -401,7 +401,7 @@ pub mod network_external_processor_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -463,7 +463,9 @@ pub mod network_external_processor_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.rate_limit_quota.v3.rs b/envoy-types/src/generated/envoy.service.rate_limit_quota.v3.rs index fec94c4..85f50b5 100644 --- a/envoy-types/src/generated/envoy.service.rate_limit_quota.v3.rs +++ b/envoy-types/src/generated/envoy.service.rate_limit_quota.v3.rs @@ -223,7 +223,7 @@ pub mod rate_limit_quota_service_client { } impl RateLimitQuotaServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -244,13 +244,13 @@ pub mod rate_limit_quota_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { RateLimitQuotaServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -417,7 +417,7 @@ pub mod rate_limit_quota_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -484,7 +484,9 @@ pub mod rate_limit_quota_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.ratelimit.v3.rs b/envoy-types/src/generated/envoy.service.ratelimit.v3.rs index 0644aa4..5e24f7d 100644 --- a/envoy-types/src/generated/envoy.service.ratelimit.v3.rs +++ b/envoy-types/src/generated/envoy.service.ratelimit.v3.rs @@ -309,7 +309,7 @@ pub mod rate_limit_service_client { } impl RateLimitServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -330,13 +330,13 @@ pub mod rate_limit_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { RateLimitServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -491,7 +491,7 @@ pub mod rate_limit_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -550,7 +550,9 @@ pub mod rate_limit_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.redis_auth.v3.rs b/envoy-types/src/generated/envoy.service.redis_auth.v3.rs index acb16ab..9d81601 100644 --- a/envoy-types/src/generated/envoy.service.redis_auth.v3.rs +++ b/envoy-types/src/generated/envoy.service.redis_auth.v3.rs @@ -42,7 +42,7 @@ pub mod redis_proxy_external_auth_client { } impl RedisProxyExternalAuthClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -63,13 +63,13 @@ pub mod redis_proxy_external_auth_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { RedisProxyExternalAuthClient::new( @@ -230,7 +230,7 @@ pub mod redis_proxy_external_auth_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -289,7 +289,9 @@ pub mod redis_proxy_external_auth_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.route.v3.rs b/envoy-types/src/generated/envoy.service.route.v3.rs index 8beb04d..97e0457 100644 --- a/envoy-types/src/generated/envoy.service.route.v3.rs +++ b/envoy-types/src/generated/envoy.service.route.v3.rs @@ -25,7 +25,7 @@ pub mod route_discovery_service_client { } impl RouteDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -46,13 +46,13 @@ pub mod route_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { RouteDiscoveryServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -217,7 +217,7 @@ pub mod virtual_host_discovery_service_client { } impl VirtualHostDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -238,13 +238,13 @@ pub mod virtual_host_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { VirtualHostDiscoveryServiceClient::new( @@ -449,7 +449,7 @@ pub mod route_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -615,7 +615,9 @@ pub mod route_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( @@ -760,7 +762,7 @@ pub mod virtual_host_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -830,7 +832,9 @@ pub mod virtual_host_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( @@ -895,7 +899,7 @@ pub mod scoped_routes_discovery_service_client { } impl ScopedRoutesDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -916,13 +920,13 @@ pub mod scoped_routes_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { ScopedRoutesDiscoveryServiceClient::new( @@ -1196,7 +1200,7 @@ pub mod scoped_routes_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -1377,7 +1381,9 @@ pub mod scoped_routes_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.runtime.v3.rs b/envoy-types/src/generated/envoy.service.runtime.v3.rs index 0875701..f0aadf8 100644 --- a/envoy-types/src/generated/envoy.service.runtime.v3.rs +++ b/envoy-types/src/generated/envoy.service.runtime.v3.rs @@ -33,7 +33,7 @@ pub mod runtime_discovery_service_client { } impl RuntimeDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -54,13 +54,13 @@ pub mod runtime_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { RuntimeDiscoveryServiceClient::new( @@ -327,7 +327,7 @@ pub mod runtime_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -502,7 +502,9 @@ pub mod runtime_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.secret.v3.rs b/envoy-types/src/generated/envoy.service.secret.v3.rs index db456f6..a947f47 100644 --- a/envoy-types/src/generated/envoy.service.secret.v3.rs +++ b/envoy-types/src/generated/envoy.service.secret.v3.rs @@ -20,7 +20,7 @@ pub mod secret_discovery_service_client { } impl SecretDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -41,13 +41,13 @@ pub mod secret_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { SecretDiscoveryServiceClient::new( @@ -313,7 +313,7 @@ pub mod secret_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -488,7 +488,9 @@ pub mod secret_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.status.v3.rs b/envoy-types/src/generated/envoy.service.status.v3.rs index 54ac909..66d3f0b 100644 --- a/envoy-types/src/generated/envoy.service.status.v3.rs +++ b/envoy-types/src/generated/envoy.service.status.v3.rs @@ -247,7 +247,7 @@ pub mod client_status_discovery_service_client { } impl ClientStatusDiscoveryServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -268,13 +268,13 @@ pub mod client_status_discovery_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { ClientStatusDiscoveryServiceClient::new( @@ -477,7 +477,7 @@ pub mod client_status_discovery_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -595,7 +595,9 @@ pub mod client_status_discovery_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/envoy-types/src/generated/envoy.service.tap.v3.rs b/envoy-types/src/generated/envoy.service.tap.v3.rs index 94a20be..59326a1 100644 --- a/envoy-types/src/generated/envoy.service.tap.v3.rs +++ b/envoy-types/src/generated/envoy.service.tap.v3.rs @@ -51,7 +51,7 @@ pub mod tap_sink_service_client { } impl TapSinkServiceClient where - T: tonic::client::GrpcService, + T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + std::marker::Send + 'static, ::Error: Into + std::marker::Send, @@ -72,13 +72,13 @@ pub mod tap_sink_service_client { F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< - http::Request, + http::Request, Response = http::Response< - >::ResponseBody, + >::ResponseBody, >, >, , + http::Request, >>::Error: Into + std::marker::Send + std::marker::Sync, { TapSinkServiceClient::new(InterceptedService::new(inner, interceptor)) @@ -236,7 +236,7 @@ pub mod tap_sink_service_server { B: Body + std::marker::Send + 'static, B::Error: Into + std::marker::Send + 'static, { - type Response = http::Response; + type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( @@ -296,7 +296,9 @@ pub mod tap_sink_service_server { } _ => { Box::pin(async move { - let mut response = http::Response::new(empty_body()); + let mut response = http::Response::new( + tonic::body::Body::default(), + ); let headers = response.headers_mut(); headers .insert( diff --git a/examples/Cargo.toml b/examples/Cargo.toml index a8c964d..96bc73c 100644 --- a/examples/Cargo.toml +++ b/examples/Cargo.toml @@ -21,5 +21,5 @@ path = "src/ext_authz/authorization_server_pb_only.rs" [dependencies] envoy-types = { path = "../envoy-types" } -tokio = { version = "1.41", features = ["macros", "rt-multi-thread"] } -tonic = "0.12.3" +tokio = { version = "1.44", features = ["macros", "rt-multi-thread"] } +tonic = "0.13"