ic-logging 0.21.1

Bounded application logs with explicit retention and scan limits
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

//! Native application-owned logging without Canic, timers or IC calls.

use ic_logging::{EntryInput, Filter, Level, Limits, Log, PageRequest};
use std::{num::NonZeroUsize, ops::ControlFlow};

fn main() {
    let mut log = Log::new(Limits {
        max_entries: NonZeroUsize::new(8).expect("positive capacity"),
        max_message_bytes: 32,
        max_label_bytes: 16,
        max_text_bytes: 512,
    });
    for (created_at_secs, level, message) in [
        (10, Level::Info, "delivery accepted"),
        (
            11,
            Level::Warn,
            "provider reply is still unknown; reconcile before retry",
        ),
        (12, Level::Ok, "original delivery reconciled"),
    ] {
        log.append(EntryInput {
            created_at_secs,
            level,
            source: "worker",
            topic: Some("delivery"),
            message,
        })
        .expect("valid bounded entry");
    }
    let scan = log.visit_page(
        Filter::default(),
        PageRequest {
            before: None,
            max_results: NonZeroUsize::new(8).expect("positive results"),
            max_scanned: NonZeroUsize::new(8).expect("positive scan"),
        },
        |entry| {
            println!("{} {:?}: {}", entry.sequence, entry.level, entry.message);
            ControlFlow::Continue(())
        },
    );
    assert_eq!(scan.matched, 3);
    assert_eq!(log.checkpoint().next_sequence(), Some(3));
    let batch = log.prune_expired(16, 5, 1);
    assert_eq!(batch.removed, 1);
    assert_eq!(log.next_expiry_secs(5), Some(17));
}