swindon 0.7.8

An HTTP edge (frontend) server with smart websockets support 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use std::time::Duration;
use quire::validate::{Structure, Sequence, Scalar, Numeric};

use super::listen::{self, Listen};
use super::http;

#[derive(Deserialize, Debug, PartialEq, Eq, Clone)]
pub struct SessionPool {
    pub listen: Listen,
    pub max_connections: usize,
    pub pipeline_depth: usize,
    #[serde(with="::quire::duration")]
    pub listen_error_timeout: Duration,
    pub max_payload_size: usize,
    pub inactivity_handlers: Vec<http::Destination>,
    #[serde(with="::quire::duration")]
    pub new_connection_idle_timeout: Duration,
    #[serde(with="::quire::duration")]
    pub client_min_idle_timeout: Duration,
    #[serde(with="::quire::duration")]
    pub client_max_idle_timeout: Duration,
    // XXX: never used
    #[serde(with="::quire::duration")]
    pub client_default_idle_timeout: Duration,
    #[serde(skip)]
    pub use_tangle_prefix: Option<bool>,
    #[serde(skip)]
    pub use_tangle_auth: Option<bool>,
    #[serde(skip)]
    pub weak_content_type: Option<bool>,
}


pub fn validator<'x>() -> Structure<'x> {
    Structure::new()
    .member("listen", Sequence::new(listen::validator()))
    .member("pipeline_depth",
        Numeric::new().min(1).max(10000).default(2))
    .member("max_connections",
        Numeric::new().min(1).max(1 << 31).default(1000))
    .member("listen_error_timeout", Scalar::new().default("100ms"))
    .member("max_payload_size",
        Numeric::new().min(1).max(1 << 31).default(10_485_760))
    .member("inactivity_handlers",
        Sequence::new(http::destination_validator()))
    .member("new_connection_idle_timeout",
        Scalar::new().min_length(1).default("60s"))
    .member("client_min_idle_timeout",
        Scalar::new().min_length(1).default("1s"))
    .member("client_max_idle_timeout",
        Scalar::new().min_length(1).default("2h"))
    .member("client_default_idle_timeout",
        Scalar::new().min_length(1).default("1s"))
}