Struct ServerBuilder 

pub struct ServerBuilder { /* private fields */ }

Server builder for configuring the runtime.

Implementations

impl ServerBuilder

pub fn with_config(self, cfg: ServerConfig) -> Self

Apply a custom server configuration.

pub fn with_graceful_shutdown<F>(self, fut: F) -> Self

where F: Future<Output = ()> + Send + 'static,

Provide a future to trigger graceful shutdown.

Examples found in repository

examples/history.rs (lines 51-53)

pub async fn main() -> Result<()> {
    let addr = env::args()
        .nth(1)
        .unwrap_or_else(|| "0.0.0.0:6379".to_string());

    let app = Router::from_state(AppState::default())
        .route("HISTORY", history)
        .route("COMMAND", history)
        .route("PING", ping);

    Server::bind(&addr)
        .with_graceful_shutdown(async {
            let _ = signal::ctrl_c().await;
        })
        .serve(app)
        .await
}

pub fn with_hooks<H>(self, hooks: H) -> Self

where H: ServerHooks,

Provide observability hooks for the server runtime.

Examples found in repository

examples/router.rs (line 28)

pub async fn main() -> Result<()> {
    let app: Router<()> = Router::new().route("PING", ping);
    Server::bind("0.0.0.0:6379")
        .with_hooks(Hooks)
        .serve(app)
        .await
}

pub fn with_connection_extensions<F>(self, factory: F) -> Self

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

Provide per-connection extensions for request contexts.

The factory is invoked once per connection and its Extensions are cloned into each RequestContext for that connection.

pub async fn serve<State>(self, app: Router<State>) -> Result<()>

where State: Send + Sync + 'static,

Examples found in repository

examples/router.rs (line 29)

pub async fn main() -> Result<()> {
    let app: Router<()> = Router::new().route("PING", ping);
    Server::bind("0.0.0.0:6379")
        .with_hooks(Hooks)
        .serve(app)
        .await
}

examples/history.rs (line 54)

pub async fn main() -> Result<()> {
    let addr = env::args()
        .nth(1)
        .unwrap_or_else(|| "0.0.0.0:6379".to_string());

    let app = Router::from_state(AppState::default())
        .route("HISTORY", history)
        .route("COMMAND", history)
        .route("PING", ping);

    Server::bind(&addr)
        .with_graceful_shutdown(async {
            let _ = signal::ctrl_c().await;
        })
        .serve(app)
        .await
}

pub async fn serve_with_listener<State>( self, listener: TcpListener, app: Router<State>, ) -> Result<()>

where State: Send + Sync + 'static,

Serve using a pre-bound listener (useful for tests).