Struct ServerBuilder 

pub struct ServerBuilder<W = NoWork, G = NoGate, S = NoopSink, T = NoTls> { /* private fields */ }

Builds a Server. A builder without a gate or without sessions/handler has no build method: forgetting either is a compile error.

Examples

use net_io::{AllowAll, DriverKind, Limits, ListenerSpec, ServerBuilder};
use std::time::{Duration, Instant};

let server = ServerBuilder::new()
    .listener(ListenerSpec::tcp("0.0.0.0:8080").name("public"))
    .listener(ListenerSpec::tcp("127.0.0.1:9090").name("admin"))
    .driver(DriverKind::Blocking)
    .workers(64)
    .limits(Limits::builder().idle_timeout(Duration::from_secs(5)).build()?)
    .handler(|conn| { conn.send_all(b"hello\n")?; Ok(()) })
    .gate(AllowAll)
    .build()?;              // listeners bound, workers started, door closed
// ... drop privileges here ...
server.open_door()?;
let report = server.shutdown(Instant::now() + Duration::from_secs(30));
println!("{report:?}");

Implementations

impl ServerBuilder

pub fn new() -> ServerBuilder

An empty builder.

impl<W, G, S, T> ServerBuilder<W, G, S, T>

pub fn listener(self, spec: ListenerSpec) -> Self

Adds a listener (at most 64).

pub fn driver(self, kind: DriverKind) -> Self

The driver (default Auto).

pub fn workers(self, n: u16) -> Self

Worker threads (default 128 on the blocking driver; 1 to 4,096).

pub fn limits(self, limits: Limits) -> Self

The server’s limits; unset values take the driver’s defaults.

pub fn sessions<F: SessionFactory>( self, factory: F, ) -> ServerBuilder<Sessions<F>, G, S, T>

Runs a sans-IO session per connection.

pub fn handler<H>( self, handler: H, ) -> ServerBuilder<BlockingHandler<H>, G, S, T>

where H: Fn(&mut TcpConnection) -> Result<(), NetError> + Send + Sync + 'static,

Runs a blocking handler per connection (on the blocking driver).

pub fn gate<G2: Gate>(self, gate: G2) -> ServerBuilder<W, G2, S, T>

The connection gate (required; AllowAll for none).

pub fn events<S2: EventSink>(self, sink: S2) -> ServerBuilder<W, G, S2, T>

The event sink (default NoopSink).

pub fn control<C: ControlLine>(self, line: Arc<C>) -> Self

The control line (default: none).

pub fn wipe_buffers(self, on: bool) -> Self

Zero the used part of every buffer when it returns to a pool (default on).

pub fn clock<K: Clock>(self, clock: Arc<K>) -> Self

The clock deadlines read (tests inject a ManualClock).

impl<W, G, S, T> ServerBuilder<W, G, S, T>

where W: Workload, G: Gate, S: EventSink, T: TlsAcceptor,

pub fn build(self) -> Result<Server, NetError>

Validates everything, binds the listeners, starts the workers, and returns the server with the door closed.

Errors

InvalidConfig (field names the method), bind errors, Unsupported for a driver this version does not have.

Trait Implementations

impl Default for ServerBuilder

fn default() -> ServerBuilder

Returns the “default value” for a type.