Struct Grpc 

pub struct Grpc<T> { /* private fields */ }

A gRPC Server handler.

This will wrap some inner Codec and provide utilities to handle inbound unary, client side streaming, server side streaming, and bi-directional streaming.

Each request handler method accepts some service that implements the corresponding service trait and a http request that contains some body that implements some Body.

Implementations

impl<T> Grpc<T>

where T: Codec,

pub fn new(codec: T) -> Grpc<T>

Creates a new gRPC server with the provided Codec.

pub fn with_accept_compressed(self, encoding: CompressionEncoding) -> Grpc<T>

Enable accepting compressed requests.

If a request with an unsupported encoding is received the server will respond with Code::UnUnimplemented.

pub fn set_accept_compressed( &mut self, encoding: CompressionEncoding, ) -> &mut Grpc<T>

Enable accepting compressed requests.

If a request with an unsupported encoding is received the server will respond with Code::UnUnimplemented.

pub fn with_send_compressed(self, encoding: CompressionEncoding) -> Grpc<T>

Enable sending compressed responses.

Requires the client to also support receiving compressed responses.

pub fn set_send_compressed( &mut self, encoding: CompressionEncoding, ) -> &mut Grpc<T>

Enable sending compressed responses.

Requires the client to also support receiving compressed responses.

pub fn with_max_decoding_message_size(self, limit: usize) -> Grpc<T>

Limits the maximum size of a decoded message.

pub fn set_max_decoding_message_size(&mut self, limit: usize) -> &mut Grpc<T>

Limits the maximum size of a decoded message.

pub fn with_max_encoding_message_size(self, limit: usize) -> Grpc<T>

Limits the maximum size of a encoded message.

pub fn set_max_encoding_message_size(&mut self, limit: usize) -> &mut Grpc<T>

Limits the maximum size of a encoded message.

pub fn with_compression_config( self, accept_encodings: EnabledCompressionEncodings, send_encodings: EnabledCompressionEncodings, ) -> Grpc<T>

pub fn set_compression_config( &mut self, accept_encodings: EnabledCompressionEncodings, send_encodings: EnabledCompressionEncodings, ) -> &mut Grpc<T>

pub fn with_max_message_size_config( self, max_decoding_message_size: Option<usize>, max_encoding_message_size: Option<usize>, ) -> Grpc<T>

pub fn set_max_message_size_config( &mut self, max_decoding_message_size: Option<usize>, max_encoding_message_size: Option<usize>, ) -> &mut Grpc<T>

pub async fn unary<S, B>( &mut self, service: S, req: Request<B>, ) -> Result<Response, Box<dyn Error + Sync + Send>>

where S: UnaryService<<T as Codec>::Decode, Response = <T as Codec>::Encode>, B: Body + Send + Sync + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

Handle a single unary gRPC request.

pub async fn server_streaming<S, B>( &mut self, service: S, req: Request<B>, ) -> Result<Response, Box<dyn Error + Sync + Send>>

where S: ServerStreamingService<<T as Codec>::Decode, Response = <T as Codec>::Encode>, <S as ServerStreamingService<<T as Codec>::Decode>>::ResponseStream: Send + Sync + 'static, B: Body + Send + Sync + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

Handle a server side streaming request.

pub async fn client_streaming<S, B>( &mut self, service: S, req: Request<B>, ) -> Result<Response, Box<dyn Error + Sync + Send>>

where S: ClientStreamingService<<T as Codec>::Decode, Response = <T as Codec>::Encode>, B: Body + Send + Sync + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

Handle a client side streaming gRPC request.

pub async fn streaming<S, B>( &mut self, service: S, req: Request<B>, ) -> Result<Response, Box<dyn Error + Sync + Send>>

where S: StreamingService<<T as Codec>::Decode, Response = <T as Codec>::Encode> + Send, <S as StreamingService<<T as Codec>::Decode>>::ResponseStream: Send + Sync + 'static, B: Body + Send + Sync + 'static, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static,

Handle a bi-directional streaming gRPC request.

Trait Implementations

impl<T> Debug for Grpc<T>

where T: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.