Struct MulticoreServer 

pub struct MulticoreServer<Factory> { /* private fields */ }

Thread-per-core launcher with one compiled, non-Send app per worker.

The factory runs lazily once on every worker. Requests execute as local futures, preserving thread-local handlers and DI values.

Implementations

impl<Factory> MulticoreServer<Factory>

where Factory: Fn() -> ExecutableApp + Send + Sync + 'static,

pub fn new(workers: NonZeroUsize, factory: Factory) -> Self

pub const fn with_max_body_bytes(self, max_body_bytes: usize) -> Self

pub const fn with_limits(self, limits: ServerLimits) -> Self

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

Sets a wall-clock limit for provider, hook, and handler execution.

pub fn with_openapi(self, config: OpenApiConfig) -> Self

Mounts the same precompiled OpenAPI assets in every worker-local app.

pub fn with_middleware_factory<Middleware>(self, middleware: Middleware) -> Self

where Middleware: Fn() -> Vec<Rc<dyn HttpMiddleware>> + Send + Sync + 'static,

Builds worker-local middleware once per worker, in registration order.

Middleware is !Send, so it cannot be shared across workers. The factory runs on each worker thread and its layers stay thread-local, exactly like the compiled app produced by the application factory.

pub const fn with_max_connections( self, connections: Option<NonZeroUsize>, ) -> Self

Bounds concurrently served connections. None accepts without a cap.

A connection accepted while the cap is reached is closed immediately instead of being dispatched to a worker.

pub const fn with_tcp_nodelay(self, nodelay: bool) -> Self

Enables or disables TCP_NODELAY on accepted sockets. Enabled by default so a small response is not delayed by Nagle’s algorithm.

pub fn serve(self, address: impl ToSocketAddrs) -> Result<()>

Runs until the listener fails or the process stops.

Every worker’s app is compiled and started before the first connection is accepted, so a failing startup hook refuses to boot instead of silently dropping connections.

Errors

Returns an I/O error when binding, worker startup, accepting, or dispatching fails.

pub fn serve_gracefully( self, address: impl ToSocketAddrs, shutdown: ShutdownSignal, drain_timeout: Duration, ) -> Result<()>

Stops accepting after shutdown, asks keep-alive connections to close after the current response, and drains active work.

Errors

Returns an I/O error when binding, worker startup, accepting, or dispatching fails.