Struct RpcServer 

pub struct RpcServer { /* private fields */ }

Builds configured Tonic server routers.

Implementations

impl RpcServer

pub fn new(config: RpcServerConfig) -> Self

Examples found in repository

examples/echo_server.rs (lines 76-80)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let address: SocketAddr = "[::1]:50051".parse()?;
    let server = RpcServer::new(
        RpcServerConfig::new(address)
            .with_request_timeout(Duration::from_secs(10))
            .with_concurrency_limit(1_024),
    );
    let (mut reporter, health_service) = health_reporter();
    reporter.set_serving::<EchoServer<EchoService>>().await;

    server
        .router()
        .add_service(health_service)
        .add_service(EchoServer::new(EchoService))
        .serve(server.config().address())
        .await?;
    Ok(())
}

pub fn try_new(config: RpcServerConfig) -> Result<Self, RpcConfigError>

pub fn config(&self) -> &RpcServerConfig

Examples found in repository

examples/echo_server.rs (line 88)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let address: SocketAddr = "[::1]:50051".parse()?;
    let server = RpcServer::new(
        RpcServerConfig::new(address)
            .with_request_timeout(Duration::from_secs(10))
            .with_concurrency_limit(1_024),
    );
    let (mut reporter, health_service) = health_reporter();
    reporter.set_serving::<EchoServer<EchoService>>().await;

    server
        .router()
        .add_service(health_service)
        .add_service(EchoServer::new(EchoService))
        .serve(server.config().address())
        .await?;
    Ok(())
}

pub fn router(&self) -> Server

Returns a Tonic server builder with the configured timeout and load limits.

Examples found in repository

examples/echo_server.rs (line 85)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let address: SocketAddr = "[::1]:50051".parse()?;
    let server = RpcServer::new(
        RpcServerConfig::new(address)
            .with_request_timeout(Duration::from_secs(10))
            .with_concurrency_limit(1_024),
    );
    let (mut reporter, health_service) = health_reporter();
    reporter.set_serving::<EchoServer<EchoService>>().await;

    server
        .router()
        .add_service(health_service)
        .add_service(EchoServer::new(EchoService))
        .serve(server.config().address())
        .await?;
    Ok(())
}

pub async fn serve_with_shutdown<F>( &self, router: Router, signal: F, ) -> Result<(), RpcServerError>

where F: Future<Output = ()>,

Serves an assembled Tonic router and bounds draining after the shutdown signal fires.

Trait Implementations

impl Clone for RpcServer

fn clone(&self) -> RpcServer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RpcServer

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

Formats the value using the given formatter.