Struct Server 

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

Generic gRPC server that can handle any service type This eliminates the need for duplicate Server implementations across all service files

Implementations

impl<T> Server<T>

pub async fn start_with_shutdown<F>( self, shutdown_rx: Receiver<()>, service_builder: F, ) -> Result<(), Box<dyn Error + Send + Sync>>

where F: FnOnce(T, usize, Sender<()>, CancellationToken) -> Router + Send + 'static, T: Send + Sync + 'static,

Starts the gRPC server with a custom service builder function. When message is received on the shutdown channel, graceful shutdown of the gRPC server will be initiated.

pub async fn start<F>( self, service_builder: F, ) -> Result<(), Box<dyn Error + Send + Sync>>

where F: FnOnce(T, usize, Sender<()>, CancellationToken) -> Router + Send + 'static, T: Send + Sync + 'static,

Starts the gRPC server with a custom service builder function. Automatically registers signal handlers for SIGINT and SIGTERM and initiates graceful shutdown of gRPC server when either one of the signal arrives.

Trait Implementations

impl<T: Debug> Debug for Server<T>

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

Formats the value using the given formatter.