ribeye 0.3.0

ribeye -- a Rust library for BGP RIB data processing.
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

use anyhow::Result;
use bgpkit_parser::models::ElemType;
use bgpkit_parser::BgpElem;
use ribeye::{MessageProcessor, RibEye, RibMeta};

#[derive(Default)]
struct EntryCounter {
    a_count: usize,
    w_count: usize,
}

impl EntryCounter {
    pub fn new() -> Self {
        Self {
            a_count: 0,
            w_count: 0,
        }
    }
}

impl MessageProcessor for EntryCounter {
    fn name(&self) -> String {
        "basic_counter".to_string()
    }

    fn output_paths(&self) -> Option<String> {
        todo!()
    }

    fn reset_processor(&mut self, rib_meta: &RibMeta) {
        todo!()
    }

    fn process_entry(&mut self, elem: &BgpElem) -> Result<()> {
        match elem.elem_type {
            ElemType::ANNOUNCE => {
                self.a_count += 1;
            }
            ElemType::WITHDRAW => {
                self.w_count += 1;
            }
        }
        Ok(())
    }

    fn output(&mut self) -> Result<()> {
        println!(
            "{}: {} announcements, {} withdrawals",
            self.name(),
            self.a_count,
            self.w_count
        );
        Ok(())
    }
}

fn main() {
    let mut ribeye = RibEye::new();
    ribeye
        .add_processor(EntryCounter::new().to_boxed())
        .unwrap();
    ribeye
        .process_mrt_file("https://data.ris.ripe.net/rrc21/2023.08/updates.20230806.1640.gz")
        .unwrap();
}