libp2p-bitswap 0.25.1

Implementation of the ipfs bitswap protocol.
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

use lazy_static::lazy_static;
use prometheus::{HistogramOpts, HistogramVec, IntCounter, IntCounterVec, Opts};

lazy_static! {
    pub static ref REQUESTS_TOTAL: IntCounterVec = IntCounterVec::new(
        Opts::new(
            "bitswap_requests_total",
            "Number of bitswap requests labelled by type and result.",
        ),
        &["type"],
    )
    .unwrap();
    pub static ref REQUEST_DURATION_SECONDS: HistogramVec = HistogramVec::new(
        HistogramOpts::new(
            "bitswap_request_duration_seconds",
            "Duration of bitswap requests labelled by request type",
        ),
        &["type"],
    )
    .unwrap();
    pub static ref REQUESTS_CANCELED: IntCounter = IntCounter::new(
        "bitswap_requests_canceled_total",
        "Number of canceled requests",
    )
    .unwrap();
    pub static ref BLOCK_NOT_FOUND: IntCounter = IntCounter::new(
        "bitswap_block_not_found_total",
        "Number of block not found errors.",
    )
    .unwrap();
    pub static ref PROVIDERS_TOTAL: IntCounter = IntCounter::new(
        "bitswap_providers_total",
        r#"Number of providers total. Using the number of provider requests, the average
        number of providers per request can be computed."#
    )
    .unwrap();
    pub static ref MISSING_BLOCKS_TOTAL: IntCounter = IntCounter::new(
        "bitswap_missing_blocks_total",
        r#"Number of missing blocks total. Using the number of missing blocks requests, the
        average number of missing blocks per request can be computed."#
    )
    .unwrap();
    pub static ref RECEIVED_BLOCK_BYTES: IntCounter =
        IntCounter::new("bitswap_received_block_bytes", "Number of received bytes.",).unwrap();
    pub static ref RECEIVED_INVALID_BLOCK_BYTES: IntCounter = IntCounter::new(
        "bitswap_received_invalid_block_bytes",
        "Number of received bytes that didn't match the hash.",
    )
    .unwrap();
    pub static ref SENT_BLOCK_BYTES: IntCounter =
        IntCounter::new("bitswap_sent_block_bytes", "Number of sent block bytes.",).unwrap();
    pub static ref RESPONSES_TOTAL: IntCounterVec = IntCounterVec::new(
        Opts::new(
            "bitswap_responses_total",
            "Number of bitswap responses sent to peers.",
        ),
        &["type"],
    )
    .unwrap();
    pub static ref THROTTLED_INBOUND: IntCounter = IntCounter::new(
        "bitswap_throttled_too_many_inbound_total",
        "Number of too many inbound events.",
    )
    .unwrap();
    pub static ref THROTTLED_OUTBOUND: IntCounter = IntCounter::new(
        "bitswap_throttled_resume_send_total",
        "Number of resume send events.",
    )
    .unwrap();
    pub static ref OUTBOUND_FAILURE: IntCounterVec = IntCounterVec::new(
        Opts::new(
            "bitswap_outbound_failures_total",
            "Number of outbound failures.",
        ),
        &["type"],
    )
    .unwrap();
    pub static ref INBOUND_FAILURE: IntCounterVec = IntCounterVec::new(
        Opts::new(
            "bitswap_inbound_failures_total",
            "Number of inbound failures.",
        ),
        &["type"],
    )
    .unwrap();
}