/// Generated client implementations. pub mod transaction_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 TransactionClient { inner: tonic::client::Grpc, } impl TransactionClient { /// Attempt to create a new client by connecting to a given endpoint. pub async fn connect(dst: D) -> Result where D: TryInto, D::Error: Into, { let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; Ok(Self::new(conn)) } } impl TransactionClient where T: tonic::client::GrpcService, T::Error: Into, T::ResponseBody: Body + Send + 'static, ::Error: Into + 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( inner: T, interceptor: F, ) -> TransactionClient> where F: tonic::service::Interceptor, T::ResponseBody: Default, T: tonic::codegen::Service< http::Request, Response = http::Response< >::ResponseBody, >, >, , >>::Error: Into + Send + Sync, { TransactionClient::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 create_or_update( &mut self, request: impl tonic::IntoRequest< super::super::super::requests::transaction::CreateTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< super::super::super::requests::transaction::CreateTransactionResponseProto, >, 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( "/fintekkers.services.transaction_service.Transaction/CreateOrUpdate", ); let mut req = request.into_request(); req.extensions_mut() .insert( GrpcMethod::new( "fintekkers.services.transaction_service.Transaction", "CreateOrUpdate", ), ); self.inner.unary(req, path, codec).await } pub async fn get_by_ids( &mut self, request: impl tonic::IntoRequest< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< super::super::super::requests::transaction::QueryTransactionResponseProto, >, 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( "/fintekkers.services.transaction_service.Transaction/GetByIds", ); let mut req = request.into_request(); req.extensions_mut() .insert( GrpcMethod::new( "fintekkers.services.transaction_service.Transaction", "GetByIds", ), ); self.inner.unary(req, path, codec).await } pub async fn search( &mut self, request: impl tonic::IntoRequest< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< tonic::codec::Streaming< super::super::super::requests::transaction::QueryTransactionResponseProto, >, >, 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( "/fintekkers.services.transaction_service.Transaction/Search", ); let mut req = request.into_request(); req.extensions_mut() .insert( GrpcMethod::new( "fintekkers.services.transaction_service.Transaction", "Search", ), ); self.inner.server_streaming(req, path, codec).await } pub async fn list_ids( &mut self, request: impl tonic::IntoRequest< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< super::super::super::requests::transaction::QueryTransactionResponseProto, >, 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( "/fintekkers.services.transaction_service.Transaction/ListIds", ); let mut req = request.into_request(); req.extensions_mut() .insert( GrpcMethod::new( "fintekkers.services.transaction_service.Transaction", "ListIds", ), ); self.inner.unary(req, path, codec).await } pub async fn validate_create_or_update( &mut self, request: impl tonic::IntoRequest< super::super::super::requests::transaction::CreateTransactionRequestProto, >, ) -> std::result::Result< tonic::Response, 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( "/fintekkers.services.transaction_service.Transaction/ValidateCreateOrUpdate", ); let mut req = request.into_request(); req.extensions_mut() .insert( GrpcMethod::new( "fintekkers.services.transaction_service.Transaction", "ValidateCreateOrUpdate", ), ); self.inner.unary(req, path, codec).await } pub async fn validate_query_request( &mut self, request: impl tonic::IntoRequest< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response, 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( "/fintekkers.services.transaction_service.Transaction/ValidateQueryRequest", ); let mut req = request.into_request(); req.extensions_mut() .insert( GrpcMethod::new( "fintekkers.services.transaction_service.Transaction", "ValidateQueryRequest", ), ); self.inner.unary(req, path, codec).await } } } /// Generated server implementations. pub mod transaction_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 TransactionServer. #[async_trait] pub trait Transaction: Send + Sync + 'static { async fn create_or_update( &self, request: tonic::Request< super::super::super::requests::transaction::CreateTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< super::super::super::requests::transaction::CreateTransactionResponseProto, >, tonic::Status, >; async fn get_by_ids( &self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< super::super::super::requests::transaction::QueryTransactionResponseProto, >, tonic::Status, >; /// Server streaming response type for the Search method. type SearchStream: futures_core::Stream< Item = std::result::Result< super::super::super::requests::transaction::QueryTransactionResponseProto, tonic::Status, >, > + Send + 'static; async fn search( &self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result, tonic::Status>; async fn list_ids( &self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response< super::super::super::requests::transaction::QueryTransactionResponseProto, >, tonic::Status, >; async fn validate_create_or_update( &self, request: tonic::Request< super::super::super::requests::transaction::CreateTransactionRequestProto, >, ) -> std::result::Result< tonic::Response, tonic::Status, >; async fn validate_query_request( &self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> std::result::Result< tonic::Response, tonic::Status, >; } #[derive(Debug)] pub struct TransactionServer { inner: _Inner, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } struct _Inner(Arc); impl TransactionServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } pub fn from_arc(inner: Arc) -> 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( inner: T, interceptor: F, ) -> InterceptedService 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 tonic::codegen::Service> for TransactionServer where T: Transaction, B: Body + Send + 'static, B::Error: Into + Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; type Future = BoxFuture; fn poll_ready( &mut self, _cx: &mut Context<'_>, ) -> Poll> { Poll::Ready(Ok(())) } fn call(&mut self, req: http::Request) -> Self::Future { let inner = self.inner.clone(); match req.uri().path() { "/fintekkers.services.transaction_service.Transaction/CreateOrUpdate" => { #[allow(non_camel_case_types)] struct CreateOrUpdateSvc(pub Arc); impl< T: Transaction, > tonic::server::UnaryService< super::super::super::requests::transaction::CreateTransactionRequestProto, > for CreateOrUpdateSvc { type Response = super::super::super::requests::transaction::CreateTransactionResponseProto; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request< super::super::super::requests::transaction::CreateTransactionRequestProto, >, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { (*inner).create_or_update(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 = CreateOrUpdateSvc(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) } "/fintekkers.services.transaction_service.Transaction/GetByIds" => { #[allow(non_camel_case_types)] struct GetByIdsSvc(pub Arc); impl< T: Transaction, > tonic::server::UnaryService< super::super::super::requests::transaction::QueryTransactionRequestProto, > for GetByIdsSvc { type Response = super::super::super::requests::transaction::QueryTransactionResponseProto; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { (*inner).get_by_ids(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 = GetByIdsSvc(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) } "/fintekkers.services.transaction_service.Transaction/Search" => { #[allow(non_camel_case_types)] struct SearchSvc(pub Arc); impl< T: Transaction, > tonic::server::ServerStreamingService< super::super::super::requests::transaction::QueryTransactionRequestProto, > for SearchSvc { type Response = super::super::super::requests::transaction::QueryTransactionResponseProto; type ResponseStream = T::SearchStream; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { (*inner).search(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 = SearchSvc(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.server_streaming(method, req).await; Ok(res) }; Box::pin(fut) } "/fintekkers.services.transaction_service.Transaction/ListIds" => { #[allow(non_camel_case_types)] struct ListIdsSvc(pub Arc); impl< T: Transaction, > tonic::server::UnaryService< super::super::super::requests::transaction::QueryTransactionRequestProto, > for ListIdsSvc { type Response = super::super::super::requests::transaction::QueryTransactionResponseProto; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { (*inner).list_ids(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 = ListIdsSvc(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) } "/fintekkers.services.transaction_service.Transaction/ValidateCreateOrUpdate" => { #[allow(non_camel_case_types)] struct ValidateCreateOrUpdateSvc(pub Arc); impl< T: Transaction, > tonic::server::UnaryService< super::super::super::requests::transaction::CreateTransactionRequestProto, > for ValidateCreateOrUpdateSvc { type Response = super::super::super::requests::util::errors::SummaryProto; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request< super::super::super::requests::transaction::CreateTransactionRequestProto, >, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { (*inner).validate_create_or_update(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 = ValidateCreateOrUpdateSvc(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) } "/fintekkers.services.transaction_service.Transaction/ValidateQueryRequest" => { #[allow(non_camel_case_types)] struct ValidateQueryRequestSvc(pub Arc); impl< T: Transaction, > tonic::server::UnaryService< super::super::super::requests::transaction::QueryTransactionRequestProto, > for ValidateQueryRequestSvc { type Response = super::super::super::requests::util::errors::SummaryProto; type Future = BoxFuture< tonic::Response, tonic::Status, >; fn call( &mut self, request: tonic::Request< super::super::super::requests::transaction::QueryTransactionRequestProto, >, ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { (*inner).validate_query_request(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 = ValidateQueryRequestSvc(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 Clone for TransactionServer { 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 Clone for _Inner { fn clone(&self) -> Self { Self(Arc::clone(&self.0)) } } impl std::fmt::Debug for _Inner { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { write!(f, "{:?}", self.0) } } impl tonic::server::NamedService for TransactionServer { const NAME: &'static str = "fintekkers.services.transaction_service.Transaction"; } }