Struct Server 

pub struct Server { /* private fields */ }

HTTP server that binds routes, middleware, and optional WebSocket handling.

Implementations

impl Server

pub fn new(router: impl Into<Router>) -> Self

Create a server with default host/port and no global middleware.

pub fn from_config(router: impl Into<Router>) -> Self

Create a server from environment configuration, booting all services.

pub fn ws_interceptor<F>(self, handler: F) -> Self

where F: Fn(Request<Incoming>) -> Result<Response<Full<Bytes>>, Request<Incoming>> + Send + Sync + 'static,

Set a WebSocket interceptor that runs before all routing.

The interceptor receives every WS upgrade request first. Return Ok(response) to handle the connection; return Err(request) to decline and let normal routing (including /_ferro/ws) proceed.

Example

Server::from_config(router)
    .ws_interceptor(|req| {
        if req.uri().path().starts_with("/sessions/") {
            Ok(my_ws_handler(req))
        } else {
            Err(req) // pass to /_ferro/ws
        }
    })
    .run()
    .await;

pub fn middleware<M: Middleware + 'static>(self, middleware: M) -> Self

Add global middleware (runs on every request)

For route-specific middleware, use .middleware(M) on the route itself.

Example

Server::from_config(router)
    .middleware(LoggingMiddleware)  // Global
    .middleware(CorsMiddleware)     // Global
    .run()
    .await;

pub fn host(self, host: &str) -> Self

Override the listen host address.

pub fn port(self, port: u16) -> Self

Override the listen port.

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

Start listening and serving requests until the process is terminated.