sark-core 0.26.0

Fiber-free request, route, dispatch, and lifecycle core for Sark
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
48
49
50
51
52
53
54
55
56
57
58

//! Protocol-independent session lifetime policy.

use std::time::Duration;

use o3::{
    base::time,
    buffer::{self, storage},
};

/// Retained byte ownership accepted by a protocol-independent session.
pub trait Storage: buffer::raw::Segment + From<storage::Shared> {}

impl<T: buffer::raw::Segment + From<storage::Shared>> Storage for T {}

#[derive(Clone, Copy, PartialEq, Eq)]
pub struct Config {
    age: time::Positive,
    drain: time::Positive,
}

#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum ConfigError {
    MaxAge { source: time::Zero },
    DrainTimeout { source: time::Zero },
}

impl Config {
    pub const fn new(age: time::Positive, drain: time::Positive) -> Self {
        Self { age, drain }
    }

    pub fn try_new(age: Duration, drain: Duration) -> Result<Self, ConfigError> {
        let age = match time::Positive::try_new(age) {
            Ok(age) => age,
            Err(source) => return Err(ConfigError::MaxAge { source }),
        };
        let drain = match time::Positive::try_new(drain) {
            Ok(drain) => drain,
            Err(source) => return Err(ConfigError::DrainTimeout { source }),
        };
        Ok(Self::new(age, drain))
    }

    pub const fn age(self) -> time::Positive {
        self.age
    }

    pub const fn drain(self) -> time::Positive {
        self.drain
    }
}

#[derive(Clone, Copy, Default)]
pub struct Disabled;

const _: () = {
    assert!(core::mem::size_of::<Disabled>() == 0);
};