pelikan-net 0.1.0

Pelikan project's networking abstractions for non-blocking event loops
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

// Copyright 2022 Twitter, Inc.
// Licensed under the Apache License, Version 2.0
// http://www.apache.org/licenses/LICENSE-2.0

mod connector;
mod listener;
mod stream;
mod tcp;
mod tls_tcp;

pub use connector::*;
pub use listener::*;
pub use stream::*;
pub use tcp::*;
pub use tls_tcp::*;

pub mod event {
    pub use mio::event::*;
}

pub use mio::*;

use core::fmt::Debug;
use core::ops::Deref;
use std::io::{Error, ErrorKind, Read, Write};
use std::net::{SocketAddr, ToSocketAddrs};
use std::path::{Path, PathBuf};

use foreign_types_shared::{ForeignType, ForeignTypeRef};
use metriken::*;

type Result<T> = std::io::Result<T>;

// stats

#[metric(
    name = "tcp_accept",
    description = "number of TCP streams passively opened with accept"
)]
pub static TCP_ACCEPT: Counter = Counter::new();

#[metric(
    name = "tcp_connect",
    description = "number of TCP streams actively opened with connect"
)]
pub static TCP_CONNECT: Counter = Counter::new();

#[metric(name = "tcp_close", description = "number of TCP streams closed")]
pub static TCP_CLOSE: Counter = Counter::new();

#[metric(
    name = "tcp_conn_curr",
    description = "current number of open TCP streams"
)]
pub static TCP_CONN_CURR: Gauge = Gauge::new();

#[metric(
    name = "tcp_recv_byte",
    description = "number of bytes received on TCP streams"
)]
pub static TCP_RECV_BYTE: Counter = Counter::new();

#[metric(
    name = "tcp_send_byte",
    description = "number of bytes sent on TCP streams"
)]
pub static TCP_SEND_BYTE: Counter = Counter::new();

#[metric(name = "stream_accept", description = "number of calls to accept")]
pub static STREAM_ACCEPT: Counter = Counter::new();

#[metric(
    name = "stream_accept_ex",
    description = "number of times calling accept resulted in an exception"
)]
pub static STREAM_ACCEPT_EX: Counter = Counter::new();

#[metric(name = "stream_close", description = "number of streams closed")]
pub static STREAM_CLOSE: Counter = Counter::new();

#[metric(
    name = "stream_handshake",
    description = "number of times stream handshaking was attempted"
)]
pub static STREAM_HANDSHAKE: Counter = Counter::new();

#[metric(
    name = "stream_handshake_ex",
    description = "number of exceptions while handshaking"
)]
pub static STREAM_HANDSHAKE_EX: Counter = Counter::new();

#[metric(
    name = "stream_shutdown",
    description = "number of streams gracefully shutdown"
)]
pub static STREAM_SHUTDOWN: Counter = Counter::new();

#[metric(
    name = "stream_shutdown_ex",
    description = "number of exceptions while attempting to gracefully shutdown a stream"
)]
pub static STREAM_SHUTDOWN_EX: Counter = Counter::new();