liminal-server 0.23.1

Standalone server for the liminal messaging bus
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

//! Replacement observations add exact lifecycle totals without counting a dial as an open.
use super::{ServerError, failure};
use crate::link::LinkLifeCounters;
pub(super) fn lifecycle(
    current: LinkLifeCounters,
    previous: LinkLifeCounters,
) -> Result<LinkLifeCounters, ServerError> {
    let add = |current: u64, previous: u64| {
        current
            .checked_add(previous)
            .ok_or_else(|| failure("configured link lifecycle counter overflow"))
    };
    Ok(LinkLifeCounters {
        links_opened: add(current.links_opened, previous.links_opened)?,
        links_closed_by_peer_gone: add(
            current.links_closed_by_peer_gone,
            previous.links_closed_by_peer_gone,
        )?,
        links_closed_by_revoked: add(
            current.links_closed_by_revoked,
            previous.links_closed_by_revoked,
        )?,
        links_closed_by_refused: add(
            current.links_closed_by_refused,
            previous.links_closed_by_refused,
        )?,
        links_closed_by_replaced: add(
            current.links_closed_by_replaced,
            previous.links_closed_by_replaced,
        )?,
        links_closed_by_shutdown: add(
            current.links_closed_by_shutdown,
            previous.links_closed_by_shutdown,
        )?,
    })
}