ilp-node 0.6.0

Interledger node (sender, connector, receiver bundle)
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

use futures::Future;
use interledger::{
    ccp::CcpRoutingAccount,
    packet::{Fulfill, Reject},
    service::{Account, IncomingRequest, IncomingService, OutgoingRequest, OutgoingService},
};
use metrics::{self, labels, recorder, Key};
use std::time::Instant;

pub fn incoming_metrics<A: Account + CcpRoutingAccount>(
    request: IncomingRequest<A>,
    mut next: impl IncomingService<A>,
) -> impl Future<Item = Fulfill, Error = Reject> {
    let labels = labels!(
        "from_asset_code" => request.from.asset_code().to_string(),
        "from_routing_relation" => request.from.routing_relation().to_string(),
    );
    recorder().increment_counter(
        Key::from_name_and_labels("requests.incoming.prepare", labels.clone()),
        1,
    );
    let start_time = Instant::now();

    next.handle_request(request).then(move |result| {
        if result.is_ok() {
            recorder().increment_counter(
                Key::from_name_and_labels("requests.incoming.fulfill", labels.clone()),
                1,
            );
        } else {
            recorder().increment_counter(
                Key::from_name_and_labels("requests.incoming.reject", labels.clone()),
                1,
            );
        }
        recorder().record_histogram(
            Key::from_name_and_labels("requests.incoming.duration", labels),
            (Instant::now() - start_time).as_nanos() as u64,
        );
        result
    })
}

pub fn outgoing_metrics<A: Account + CcpRoutingAccount>(
    request: OutgoingRequest<A>,
    mut next: impl OutgoingService<A>,
) -> impl Future<Item = Fulfill, Error = Reject> {
    let labels = labels!(
        "from_asset_code" => request.from.asset_code().to_string(),
        "to_asset_code" => request.to.asset_code().to_string(),
        "from_routing_relation" => request.from.routing_relation().to_string(),
        "to_routing_relation" => request.to.routing_relation().to_string(),
    );

    // TODO replace these calls with the counter! macro if there's a way to easily pass in the already-created labels
    // right now if you pass the labels into one of the other macros, it gets a recursion limit error while expanding the macro
    recorder().increment_counter(
        Key::from_name_and_labels("requests.outgoing.prepare", labels.clone()),
        1,
    );
    let start_time = Instant::now();

    next.send_request(request).then(move |result| {
        if result.is_ok() {
            recorder().increment_counter(
                Key::from_name_and_labels("requests.outgoing.fulfill", labels.clone()),
                1,
            );
        } else {
            recorder().increment_counter(
                Key::from_name_and_labels("requests.outgoing.reject", labels.clone()),
                1,
            );
        }

        recorder().record_histogram(
            Key::from_name_and_labels("requests.outgoing.duration", labels.clone()),
            (Instant::now() - start_time).as_nanos() as u64,
        );
        result
    })
}