datum-core 0.10.4

Rust stream-processing library mirroring Akka/Pekko Streams Typed, built on Ractor actors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//! Linked-artifact probe for the M14-M1 disabled metrics seam.

use std::{hint::black_box, sync::atomic::AtomicBool};

use datum::graph::{metrics_disabled_path_probe, metrics_no_site_probe};

fn main() {
    let mut args = std::env::args().skip(1);
    let enabled = args.next().as_deref() == Some("enabled");
    let value = args
        .next()
        .and_then(|value| value.parse::<u64>().ok())
        .unwrap_or(41);
    let flag = AtomicBool::new(black_box(enabled));

    black_box(metrics_disabled_path_probe(&flag, black_box(value)));
    black_box(metrics_no_site_probe(&flag, black_box(value)));
}