camber 0.1.4

Opinionated async Rust for IO-bound services on top of Tokio
Documentation 
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

/// Default maximum request body size (8 MB).
pub(crate) const DEFAULT_MAX_BODY: usize = 8 * 1024 * 1024;
/// Hard ceiling for request body size (256 MB).
pub(crate) const MAX_BODY_LIMIT: usize = 256 * 1024 * 1024;
/// Default channel buffer size for SSE and WebSocket connections.
pub(crate) const DEFAULT_CHANNEL_BUFFER: usize = 32;

/// Shared buffer-size configuration embedded by Router and HostRouter.
#[derive(Debug, Clone, Copy)]
pub(crate) struct BufferConfig {
    pub(crate) max_request_body: usize,
    pub(crate) sse_buffer_size: usize,
    #[cfg(feature = "ws")]
    pub(crate) ws_buffer_size: usize,
}

impl Default for BufferConfig {
    fn default() -> Self {
        Self {
            max_request_body: DEFAULT_MAX_BODY,
            sse_buffer_size: DEFAULT_CHANNEL_BUFFER,
            #[cfg(feature = "ws")]
            ws_buffer_size: DEFAULT_CHANNEL_BUFFER,
        }
    }
}

impl BufferConfig {
    /// Set the maximum request body size in bytes (capped at 256 MB).
    pub(crate) fn with_max_request_body(mut self, bytes: usize) -> Self {
        self.max_request_body = bytes.min(MAX_BODY_LIMIT);
        self
    }

    /// Set the channel buffer size for SSE connections (minimum 1).
    pub(crate) fn with_sse_buffer_size(mut self, size: usize) -> Self {
        self.sse_buffer_size = size.max(1);
        self
    }

    /// Set the channel buffer size for WebSocket connections (minimum 1).
    #[cfg(feature = "ws")]
    pub(crate) fn with_ws_buffer_size(mut self, size: usize) -> Self {
        self.ws_buffer_size = size.max(1);
        self
    }
}