Struct Server 

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

gRPC server for session reduce service

Implementations

impl<C> Server<C>

pub fn new(creator: C) -> Self

Create a new Server with the given session reduce service

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

where C: SessionReducerCreator + Send + Sync + 'static,

Starts the gRPC server. When message is received on the shutdown channel, graceful shutdown of the gRPC server will be initiated.

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

where C: SessionReducerCreator + Send + Sync + 'static,

Starts the gRPC server. 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<C: Debug> Debug for Server<C>

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

Formats the value using the given formatter.

impl<C> ServerExtras<C> for Server<C>

fn transform_inner<F>(self, f: F) -> Self

where F: FnOnce(Server<C>) -> Server<C>,

Extract the inner server, transform it, and wrap it back

fn inner_ref(&self) -> &Server<C>

Get a reference to the inner server

fn with_socket_file(self, file: impl Into<PathBuf>) -> Self

where Self: Sized,

Set the unix domain socket file path used by the gRPC server to listen for incoming connections.

fn socket_file<'a>(&'a self) -> &'a Path

where T: 'a,

Get the unix domain socket file path where gRPC server listens for incoming connections.

fn with_max_message_size(self, message_size: usize) -> Self

where Self: Sized,

Set the maximum size of an encoded and decoded gRPC message. The value of message_size is in bytes.

fn max_message_size(&self) -> usize

Get the maximum size of an encoded and decoded gRPC message in bytes.

fn with_server_info_file(self, file: impl Into<PathBuf>) -> Self

where Self: Sized,

Change the file in which numaflow server information is stored on start up to the new value.

fn server_info_file<'a>(&'a self) -> &'a Path

where T: 'a,

Get the path to the file where numaflow server info is stored.