sova-core 0.1.10

Core HTTP primitives for Sova (App, Router, Request, Response)
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use crate::app::{AppInner, ShutdownHook, StartupHook};
use crate::error::Result;
use crate::service::BoxedService;
use tokio::net::TcpListener;

use super::ExternalShutdown;

mod accept;
mod convert;
mod serve;
#[cfg(feature = "tls")]
mod tls;

#[cfg(not(feature = "tls"))]
#[allow(clippy::too_many_arguments)]
pub(super) async fn run_tcp(
    inner: AppInner,
    startups: Vec<StartupHook>,
    shutdowns: Vec<ShutdownHook>,
    services: Vec<BoxedService>,
    start_services: bool,
    listener: TcpListener,
    external_shutdown: Option<ExternalShutdown>,
) -> Result<()> {
    accept::run_accept_loop(
        inner,
        startups,
        shutdowns,
        services,
        start_services,
        external_shutdown,
        accept::AcceptKind::Tcp(listener),
    )
    .await
}

#[cfg(feature = "tls")]
#[allow(clippy::too_many_arguments)]
pub(super) async fn run_tcp(
    inner: AppInner,
    startups: Vec<StartupHook>,
    shutdowns: Vec<ShutdownHook>,
    services: Vec<BoxedService>,
    start_services: bool,
    listener: TcpListener,
    external_shutdown: Option<ExternalShutdown>,
    tls: Option<crate::tls::TlsRuntime>,
) -> Result<()> {
    accept::run_accept_loop(
        inner,
        startups,
        shutdowns,
        services,
        start_services,
        external_shutdown,
        accept::AcceptKind::Tcp(listener),
        tls,
    )
    .await
}

#[cfg(all(unix, not(feature = "tls")))]
pub(super) async fn run_unix(
    inner: AppInner,
    startups: Vec<StartupHook>,
    shutdowns: Vec<ShutdownHook>,
    services: Vec<BoxedService>,
    start_services: bool,
    listener: tokio::net::UnixListener,
    external_shutdown: Option<ExternalShutdown>,
) -> Result<()> {
    accept::run_accept_loop(
        inner,
        startups,
        shutdowns,
        services,
        start_services,
        external_shutdown,
        accept::AcceptKind::Unix(listener),
    )
    .await
}

#[cfg(all(unix, feature = "tls"))]
pub(super) async fn run_unix(
    inner: AppInner,
    startups: Vec<StartupHook>,
    shutdowns: Vec<ShutdownHook>,
    services: Vec<BoxedService>,
    start_services: bool,
    listener: tokio::net::UnixListener,
    external_shutdown: Option<ExternalShutdown>,
) -> Result<()> {
    accept::run_accept_loop(
        inner,
        startups,
        shutdowns,
        services,
        start_services,
        external_shutdown,
        accept::AcceptKind::Unix(listener),
        None,
    )
    .await
}