Struct mz_service::grpc::GrpcServer

pub struct GrpcServer<F> {
    state: Arc<GrpcServerState<F>>,
}

A gRPC server that stitches a gRPC service with a single bidirectional stream to a GenericClient.

It is the counterpart of GrpcClient.

To use, implement the tonic-generated ProtoService trait for this type. The implementation of the bidirectional stream method should call GrpcServer::forward_bidi_stream to stitch the bidirectional stream to the client underlying this server.

Fields

state: Arc<GrpcServerState<F>>

Implementations

impl<F, G> GrpcServer<F>

where F: Fn() -> G + Send + Sync + 'static,

pub fn serve<S, Fs>( metrics: &GrpcServerMetrics, listen_addr: SocketAddr, version: Version, host: Option<String>, client_builder: F, service_builder: Fs, ) -> impl Future<Output = Result<(), Error>>

where S: Service<Request<BoxBody>, Response = Response<BoxBody>, Error = Infallible> + NamedService + Clone + Send + 'static, S::Future: Send + 'static, Fs: FnOnce(Self) -> S + Send + 'static,

Starts the server, listening for gRPC connections on listen_addr.

The trait bounds on S are intimidating, but it is the return type of service_builder, which is a function that turns a GrpcServer<ProtoCommandType, ProtoResponseType> into a Service that represents a gRPC server. This is always encapsulated by the tonic-generated ProtoServer::new method for a specific Protobuf service.

pub async fn forward_bidi_stream<C, R, PC, PR>( &self, request: Request<Streaming<PC>>, ) -> Result<Response<ResponseStream<PR>>, Status>

where G: GenericClient<C, R> + 'static, C: RustType<PC> + Send + Sync + 'static + Debug, R: RustType<PR> + Send + Sync + 'static + Debug, PC: Debug + Send + Sync + 'static, PR: Debug + Send + Sync + 'static,

Handles a bidirectional stream request by forwarding commands to and responses from the server’s underlying client.

Call this method from the implementation of the tonic-generated ProtoService.