Struct RpcServerConfig

Source

pub struct RpcServerConfig { /* private fields */ }

Expand description

Transport settings applied to every gRPC service on a server.

Implementations§

Source §

impl RpcServerConfig

Source

pub fn new(address: SocketAddr) -> Self

Examples found in repository ?

examples/echo_server.rs (line 77)

74async fn main() -> Result<(), Box<dyn std::error::Error>> {
75    let address: SocketAddr = "[::1]:50051".parse()?;
76    let server = RpcServer::new(
77        RpcServerConfig::new(address)
78            .with_request_timeout(Duration::from_secs(10))
79            .with_concurrency_limit(1_024),
80    );
81    let (mut reporter, health_service) = health_reporter();
82    reporter.set_serving::<EchoServer<EchoService>>().await;
83
84    server
85        .router()
86        .add_service(health_service)
87        .add_service(EchoServer::new(EchoService))
88        .serve(server.config().address())
89        .await?;
90    Ok(())
91}

Source

pub fn with_request_timeout(self, timeout: Duration) -> Self

Examples found in repository ?

examples/echo_server.rs (line 78)

74async fn main() -> Result<(), Box<dyn std::error::Error>> {
75    let address: SocketAddr = "[::1]:50051".parse()?;
76    let server = RpcServer::new(
77        RpcServerConfig::new(address)
78            .with_request_timeout(Duration::from_secs(10))
79            .with_concurrency_limit(1_024),
80    );
81    let (mut reporter, health_service) = health_reporter();
82    reporter.set_serving::<EchoServer<EchoService>>().await;
83
84    server
85        .router()
86        .add_service(health_service)
87        .add_service(EchoServer::new(EchoService))
88        .serve(server.config().address())
89        .await?;
90    Ok(())
91}

Source

pub fn with_concurrency_limit(self, limit: usize) -> Self

Examples found in repository ?

examples/echo_server.rs (line 79)

74async fn main() -> Result<(), Box<dyn std::error::Error>> {
75    let address: SocketAddr = "[::1]:50051".parse()?;
76    let server = RpcServer::new(
77        RpcServerConfig::new(address)
78            .with_request_timeout(Duration::from_secs(10))
79            .with_concurrency_limit(1_024),
80    );
81    let (mut reporter, health_service) = health_reporter();
82    reporter.set_serving::<EchoServer<EchoService>>().await;
83
84    server
85        .router()
86        .add_service(health_service)
87        .add_service(EchoServer::new(EchoService))
88        .serve(server.config().address())
89        .await?;
90    Ok(())
91}

Source

pub fn with_max_concurrent_streams(self, limit: u32) -> Self

Source

pub fn with_shutdown_timeout(self, timeout: Duration) -> Self

Source

pub fn address(&self) -> SocketAddr

Examples found in repository ?

examples/echo_server.rs (line 88)

74async fn main() -> Result<(), Box<dyn std::error::Error>> {
75    let address: SocketAddr = "[::1]:50051".parse()?;
76    let server = RpcServer::new(
77        RpcServerConfig::new(address)
78            .with_request_timeout(Duration::from_secs(10))
79            .with_concurrency_limit(1_024),
80    );
81    let (mut reporter, health_service) = health_reporter();
82    reporter.set_serving::<EchoServer<EchoService>>().await;
83
84    server
85        .router()
86        .add_service(health_service)
87        .add_service(EchoServer::new(EchoService))
88        .serve(server.config().address())
89        .await?;
90    Ok(())
91}