diff options
Diffstat (limited to 'src/rpc/envoy.service.secret.v3.tonic.rs')
| -rw-r--r-- | src/rpc/envoy.service.secret.v3.tonic.rs | 538 |
1 files changed, 0 insertions, 538 deletions
diff --git a/src/rpc/envoy.service.secret.v3.tonic.rs b/src/rpc/envoy.service.secret.v3.tonic.rs deleted file mode 100644 index 9b437ff5..00000000 --- a/src/rpc/envoy.service.secret.v3.tonic.rs +++ /dev/null @@ -1,538 +0,0 @@ -// @generated -/// Generated client implementations. -pub mod secret_discovery_service_client { - #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] - use tonic::codegen::*; - use tonic::codegen::http::Uri; - #[derive(Debug, Clone)] - pub struct SecretDiscoveryServiceClient<T> { - inner: tonic::client::Grpc<T>, - } - impl SecretDiscoveryServiceClient<tonic::transport::Channel> { - /// Attempt to create a new client by connecting to a given endpoint. - pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error> - where - D: TryInto<tonic::transport::Endpoint>, - D::Error: Into<StdError>, - { - let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; - Ok(Self::new(conn)) - } - } - impl<T> SecretDiscoveryServiceClient<T> - where - T: tonic::client::GrpcService<tonic::body::BoxBody>, - T::Error: Into<StdError>, - T::ResponseBody: Body<Data = Bytes> + Send + 'static, - <T::ResponseBody as Body>::Error: Into<StdError> + Send, - { - pub fn new(inner: T) -> Self { - let inner = tonic::client::Grpc::new(inner); - Self { inner } - } - pub fn with_origin(inner: T, origin: Uri) -> Self { - let inner = tonic::client::Grpc::with_origin(inner, origin); - Self { inner } - } - pub fn with_interceptor<F>( - inner: T, - interceptor: F, - ) -> SecretDiscoveryServiceClient<InterceptedService<T, F>> - where - F: tonic::service::Interceptor, - T::ResponseBody: Default, - T: tonic::codegen::Service< - http::Request<tonic::body::BoxBody>, - Response = http::Response< - <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody, - >, - >, - <T as tonic::codegen::Service< - http::Request<tonic::body::BoxBody>, - >>::Error: Into<StdError> + Send + Sync, - { - SecretDiscoveryServiceClient::new( - InterceptedService::new(inner, interceptor), - ) - } - /// Compress requests with the given encoding. - /// - /// This requires the server to support it otherwise it might respond with an - /// error. - #[must_use] - pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { - self.inner = self.inner.send_compressed(encoding); - self - } - /// Enable decompressing responses. - #[must_use] - pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { - self.inner = self.inner.accept_compressed(encoding); - self - } - /// Limits the maximum size of a decoded message. - /// - /// Default: `4MB` - #[must_use] - pub fn max_decoding_message_size(mut self, limit: usize) -> Self { - self.inner = self.inner.max_decoding_message_size(limit); - self - } - /// Limits the maximum size of an encoded message. - /// - /// Default: `usize::MAX` - #[must_use] - pub fn max_encoding_message_size(mut self, limit: usize) -> Self { - self.inner = self.inner.max_encoding_message_size(limit); - self - } - pub async fn delta_secrets( - &mut self, - request: impl tonic::IntoStreamingRequest< - Message = super::super::super::discovery::v3::DeltaDiscoveryRequest, - >, - ) -> std::result::Result< - tonic::Response< - tonic::codec::Streaming< - super::super::super::discovery::v3::DeltaDiscoveryResponse, - >, - >, - tonic::Status, - > { - self.inner - .ready() - .await - .map_err(|e| { - tonic::Status::new( - tonic::Code::Unknown, - format!("Service was not ready: {}", e.into()), - ) - })?; - let codec = tonic::codec::ProstCodec::default(); - let path = http::uri::PathAndQuery::from_static( - "/envoy.service.secret.v3.SecretDiscoveryService/DeltaSecrets", - ); - let mut req = request.into_streaming_request(); - req.extensions_mut() - .insert( - GrpcMethod::new( - "envoy.service.secret.v3.SecretDiscoveryService", - "DeltaSecrets", - ), - ); - self.inner.streaming(req, path, codec).await - } - /// - pub async fn stream_secrets( - &mut self, - request: impl tonic::IntoStreamingRequest< - Message = super::super::super::discovery::v3::DiscoveryRequest, - >, - ) -> std::result::Result< - tonic::Response< - tonic::codec::Streaming< - super::super::super::discovery::v3::DiscoveryResponse, - >, - >, - tonic::Status, - > { - self.inner - .ready() - .await - .map_err(|e| { - tonic::Status::new( - tonic::Code::Unknown, - format!("Service was not ready: {}", e.into()), - ) - })?; - let codec = tonic::codec::ProstCodec::default(); - let path = http::uri::PathAndQuery::from_static( - "/envoy.service.secret.v3.SecretDiscoveryService/StreamSecrets", - ); - let mut req = request.into_streaming_request(); - req.extensions_mut() - .insert( - GrpcMethod::new( - "envoy.service.secret.v3.SecretDiscoveryService", - "StreamSecrets", - ), - ); - self.inner.streaming(req, path, codec).await - } - /// - pub async fn fetch_secrets( - &mut self, - request: impl tonic::IntoRequest< - super::super::super::discovery::v3::DiscoveryRequest, - >, - ) -> std::result::Result< - tonic::Response<super::super::super::discovery::v3::DiscoveryResponse>, - tonic::Status, - > { - self.inner - .ready() - .await - .map_err(|e| { - tonic::Status::new( - tonic::Code::Unknown, - format!("Service was not ready: {}", e.into()), - ) - })?; - let codec = tonic::codec::ProstCodec::default(); - let path = http::uri::PathAndQuery::from_static( - "/envoy.service.secret.v3.SecretDiscoveryService/FetchSecrets", - ); - let mut req = request.into_request(); - req.extensions_mut() - .insert( - GrpcMethod::new( - "envoy.service.secret.v3.SecretDiscoveryService", - "FetchSecrets", - ), - ); - self.inner.unary(req, path, codec).await - } - } -} -/// Generated server implementations. -pub mod secret_discovery_service_server { - #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] - use tonic::codegen::*; - /// Generated trait containing gRPC methods that should be implemented for use with SecretDiscoveryServiceServer. - #[async_trait] - pub trait SecretDiscoveryService: Send + Sync + 'static { - /// Server streaming response type for the DeltaSecrets method. - type DeltaSecretsStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::super::super::discovery::v3::DeltaDiscoveryResponse, - tonic::Status, - >, - > - + Send - + 'static; - async fn delta_secrets( - &self, - request: tonic::Request< - tonic::Streaming< - super::super::super::discovery::v3::DeltaDiscoveryRequest, - >, - >, - ) -> std::result::Result< - tonic::Response<Self::DeltaSecretsStream>, - tonic::Status, - >; - /// Server streaming response type for the StreamSecrets method. - type StreamSecretsStream: tonic::codegen::tokio_stream::Stream< - Item = std::result::Result< - super::super::super::discovery::v3::DiscoveryResponse, - tonic::Status, - >, - > - + Send - + 'static; - /// - async fn stream_secrets( - &self, - request: tonic::Request< - tonic::Streaming<super::super::super::discovery::v3::DiscoveryRequest>, - >, - ) -> std::result::Result< - tonic::Response<Self::StreamSecretsStream>, - tonic::Status, - >; - /// - async fn fetch_secrets( - &self, - request: tonic::Request<super::super::super::discovery::v3::DiscoveryRequest>, - ) -> std::result::Result< - tonic::Response<super::super::super::discovery::v3::DiscoveryResponse>, - tonic::Status, - >; - } - #[derive(Debug)] - pub struct SecretDiscoveryServiceServer<T: SecretDiscoveryService> { - inner: _Inner<T>, - accept_compression_encodings: EnabledCompressionEncodings, - send_compression_encodings: EnabledCompressionEncodings, - max_decoding_message_size: Option<usize>, - max_encoding_message_size: Option<usize>, - } - struct _Inner<T>(Arc<T>); - impl<T: SecretDiscoveryService> SecretDiscoveryServiceServer<T> { - pub fn new(inner: T) -> Self { - Self::from_arc(Arc::new(inner)) - } - pub fn from_arc(inner: Arc<T>) -> Self { - let inner = _Inner(inner); - Self { - inner, - accept_compression_encodings: Default::default(), - send_compression_encodings: Default::default(), - max_decoding_message_size: None, - max_encoding_message_size: None, - } - } - pub fn with_interceptor<F>( - inner: T, - interceptor: F, - ) -> InterceptedService<Self, F> - where - F: tonic::service::Interceptor, - { - InterceptedService::new(Self::new(inner), interceptor) - } - /// Enable decompressing requests with the given encoding. - #[must_use] - pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self { - self.accept_compression_encodings.enable(encoding); - self - } - /// Compress responses with the given encoding, if the client supports it. - #[must_use] - pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self { - self.send_compression_encodings.enable(encoding); - self - } - /// Limits the maximum size of a decoded message. - /// - /// Default: `4MB` - #[must_use] - pub fn max_decoding_message_size(mut self, limit: usize) -> Self { - self.max_decoding_message_size = Some(limit); - self - } - /// Limits the maximum size of an encoded message. - /// - /// Default: `usize::MAX` - #[must_use] - pub fn max_encoding_message_size(mut self, limit: usize) -> Self { - self.max_encoding_message_size = Some(limit); - self - } - } - impl<T, B> tonic::codegen::Service<http::Request<B>> - for SecretDiscoveryServiceServer<T> - where - T: SecretDiscoveryService, - B: Body + Send + 'static, - B::Error: Into<StdError> + Send + 'static, - { - type Response = http::Response<tonic::body::BoxBody>; - type Error = std::convert::Infallible; - type Future = BoxFuture<Self::Response, Self::Error>; - fn poll_ready( - &mut self, - _cx: &mut Context<'_>, - ) -> Poll<std::result::Result<(), Self::Error>> { - Poll::Ready(Ok(())) - } - fn call(&mut self, req: http::Request<B>) -> Self::Future { - let inner = self.inner.clone(); - match req.uri().path() { - "/envoy.service.secret.v3.SecretDiscoveryService/DeltaSecrets" => { - #[allow(non_camel_case_types)] - struct DeltaSecretsSvc<T: SecretDiscoveryService>(pub Arc<T>); - impl< - T: SecretDiscoveryService, - > tonic::server::StreamingService< - super::super::super::discovery::v3::DeltaDiscoveryRequest, - > for DeltaSecretsSvc<T> { - type Response = super::super::super::discovery::v3::DeltaDiscoveryResponse; - type ResponseStream = T::DeltaSecretsStream; - type Future = BoxFuture< - tonic::Response<Self::ResponseStream>, - tonic::Status, - >; - fn call( - &mut self, - request: tonic::Request< - tonic::Streaming< - super::super::super::discovery::v3::DeltaDiscoveryRequest, - >, - >, - ) -> Self::Future { - let inner = Arc::clone(&self.0); - let fut = async move { - <T as SecretDiscoveryService>::delta_secrets( - &inner, - request, - ) - .await - }; - Box::pin(fut) - } - } - let accept_compression_encodings = self.accept_compression_encodings; - let send_compression_encodings = self.send_compression_encodings; - let max_decoding_message_size = self.max_decoding_message_size; - let max_encoding_message_size = self.max_encoding_message_size; - let inner = self.inner.clone(); - let fut = async move { - let inner = inner.0; - let method = DeltaSecretsSvc(inner); - let codec = tonic::codec::ProstCodec::default(); - let mut grpc = tonic::server::Grpc::new(codec) - .apply_compression_config( - accept_compression_encodings, - send_compression_encodings, - ) - .apply_max_message_size_config( - max_decoding_message_size, - max_encoding_message_size, - ); - let res = grpc.streaming(method, req).await; - Ok(res) - }; - Box::pin(fut) - } - "/envoy.service.secret.v3.SecretDiscoveryService/StreamSecrets" => { - #[allow(non_camel_case_types)] - struct StreamSecretsSvc<T: SecretDiscoveryService>(pub Arc<T>); - impl< - T: SecretDiscoveryService, - > tonic::server::StreamingService< - super::super::super::discovery::v3::DiscoveryRequest, - > for StreamSecretsSvc<T> { - type Response = super::super::super::discovery::v3::DiscoveryResponse; - type ResponseStream = T::StreamSecretsStream; - type Future = BoxFuture< - tonic::Response<Self::ResponseStream>, - tonic::Status, - >; - fn call( - &mut self, - request: tonic::Request< - tonic::Streaming< - super::super::super::discovery::v3::DiscoveryRequest, - >, - >, - ) -> Self::Future { - let inner = Arc::clone(&self.0); - let fut = async move { - <T as SecretDiscoveryService>::stream_secrets( - &inner, - request, - ) - .await - }; - Box::pin(fut) - } - } - let accept_compression_encodings = self.accept_compression_encodings; - let send_compression_encodings = self.send_compression_encodings; - let max_decoding_message_size = self.max_decoding_message_size; - let max_encoding_message_size = self.max_encoding_message_size; - let inner = self.inner.clone(); - let fut = async move { - let inner = inner.0; - let method = StreamSecretsSvc(inner); - let codec = tonic::codec::ProstCodec::default(); - let mut grpc = tonic::server::Grpc::new(codec) - .apply_compression_config( - accept_compression_encodings, - send_compression_encodings, - ) - .apply_max_message_size_config( - max_decoding_message_size, - max_encoding_message_size, - ); - let res = grpc.streaming(method, req).await; - Ok(res) - }; - Box::pin(fut) - } - "/envoy.service.secret.v3.SecretDiscoveryService/FetchSecrets" => { - #[allow(non_camel_case_types)] - struct FetchSecretsSvc<T: SecretDiscoveryService>(pub Arc<T>); - impl< - T: SecretDiscoveryService, - > tonic::server::UnaryService< - super::super::super::discovery::v3::DiscoveryRequest, - > for FetchSecretsSvc<T> { - type Response = super::super::super::discovery::v3::DiscoveryResponse; - type Future = BoxFuture< - tonic::Response<Self::Response>, - tonic::Status, - >; - fn call( - &mut self, - request: tonic::Request< - super::super::super::discovery::v3::DiscoveryRequest, - >, - ) -> Self::Future { - let inner = Arc::clone(&self.0); - let fut = async move { - <T as SecretDiscoveryService>::fetch_secrets( - &inner, - request, - ) - .await - }; - Box::pin(fut) - } - } - let accept_compression_encodings = self.accept_compression_encodings; - let send_compression_encodings = self.send_compression_encodings; - let max_decoding_message_size = self.max_decoding_message_size; - let max_encoding_message_size = self.max_encoding_message_size; - let inner = self.inner.clone(); - let fut = async move { - let inner = inner.0; - let method = FetchSecretsSvc(inner); - let codec = tonic::codec::ProstCodec::default(); - let mut grpc = tonic::server::Grpc::new(codec) - .apply_compression_config( - accept_compression_encodings, - send_compression_encodings, - ) - .apply_max_message_size_config( - max_decoding_message_size, - max_encoding_message_size, - ); - let res = grpc.unary(method, req).await; - Ok(res) - }; - Box::pin(fut) - } - _ => { - Box::pin(async move { - Ok( - http::Response::builder() - .status(200) - .header("grpc-status", "12") - .header("content-type", "application/grpc") - .body(empty_body()) - .unwrap(), - ) - }) - } - } - } - } - impl<T: SecretDiscoveryService> Clone for SecretDiscoveryServiceServer<T> { - fn clone(&self) -> Self { - let inner = self.inner.clone(); - Self { - inner, - accept_compression_encodings: self.accept_compression_encodings, - send_compression_encodings: self.send_compression_encodings, - max_decoding_message_size: self.max_decoding_message_size, - max_encoding_message_size: self.max_encoding_message_size, - } - } - } - impl<T: SecretDiscoveryService> Clone for _Inner<T> { - fn clone(&self) -> Self { - Self(Arc::clone(&self.0)) - } - } - impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> { - fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { - write!(f, "{:?}", self.0) - } - } - impl<T: SecretDiscoveryService> tonic::server::NamedService - for SecretDiscoveryServiceServer<T> { - const NAME: &'static str = "envoy.service.secret.v3.SecretDiscoveryService"; - } -} |