Struct axum_server::AddrIncomingConfig

source · [−]

pub struct AddrIncomingConfig { /* private fields */ }

Expand description

A configuration for AddrIncoming.

Implementations

source

impl AddrIncomingConfig

source

pub fn new() -> AddrIncomingConfig

Creates a default AddrIncoming config.

Examples found in repository ?

examples/configure_addr_incoming.rs (line 14)

↕

async fn main() {
    let app = Router::new().route("/", get(|| async { "Hello, world!" }));

    let config = AddrIncomingConfig::new()
        .tcp_nodelay(true)
        .tcp_sleep_on_accept_errors(true)
        .tcp_keepalive(Some(Duration::from_secs(32)))
        .build();

    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
    println!("listening on {}", addr);
    axum_server::bind(addr)
        .addr_incoming_config(config)
        .serve(app.into_make_service())
        .await
        .unwrap();
}

source

pub fn build(&mut self) -> Self

Builds the config, creating an owned version of it.

Examples found in repository ?

examples/configure_addr_incoming.rs (line 18)

↕

async fn main() {
    let app = Router::new().route("/", get(|| async { "Hello, world!" }));

    let config = AddrIncomingConfig::new()
        .tcp_nodelay(true)
        .tcp_sleep_on_accept_errors(true)
        .tcp_keepalive(Some(Duration::from_secs(32)))
        .build();

    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
    println!("listening on {}", addr);
    axum_server::bind(addr)
        .addr_incoming_config(config)
        .serve(app.into_make_service())
        .await
        .unwrap();
}

source

pub fn tcp_sleep_on_accept_errors(&mut self, val: bool) -> &mut Self

Set whether to sleep on accept errors, to avoid exhausting file descriptor limits.

Default is true.

Examples found in repository ?

examples/configure_addr_incoming.rs (line 16)

↕

async fn main() {
    let app = Router::new().route("/", get(|| async { "Hello, world!" }));

    let config = AddrIncomingConfig::new()
        .tcp_nodelay(true)
        .tcp_sleep_on_accept_errors(true)
        .tcp_keepalive(Some(Duration::from_secs(32)))
        .build();

    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
    println!("listening on {}", addr);
    axum_server::bind(addr)
        .addr_incoming_config(config)
        .serve(app.into_make_service())
        .await
        .unwrap();
}

source

pub fn tcp_keepalive(&mut self, val: Option<Duration>) -> &mut Self

Set how often to send TCP keepalive probes.

Default is false.

Examples found in repository ?

examples/configure_addr_incoming.rs (line 17)

↕

async fn main() {
    let app = Router::new().route("/", get(|| async { "Hello, world!" }));

    let config = AddrIncomingConfig::new()
        .tcp_nodelay(true)
        .tcp_sleep_on_accept_errors(true)
        .tcp_keepalive(Some(Duration::from_secs(32)))
        .build();

    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
    println!("listening on {}", addr);
    axum_server::bind(addr)
        .addr_incoming_config(config)
        .serve(app.into_make_service())
        .await
        .unwrap();
}

source

pub fn tcp_nodelay(&mut self, val: bool) -> &mut Self

Set the value of TCP_NODELAY option for accepted connections.

Default is false.

Examples found in repository ?

examples/configure_addr_incoming.rs (line 15)

↕

async fn main() {
    let app = Router::new().route("/", get(|| async { "Hello, world!" }));

    let config = AddrIncomingConfig::new()
        .tcp_nodelay(true)
        .tcp_sleep_on_accept_errors(true)
        .tcp_keepalive(Some(Duration::from_secs(32)))
        .build();

    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
    println!("listening on {}", addr);
    axum_server::bind(addr)
        .addr_incoming_config(config)
        .serve(app.into_make_service())
        .await
        .unwrap();
}