allsource-core 0.20.1

High-performance event store core built in Rust
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

//! Deterministic in-memory ingest workload for profiling.
//!
//! Mirrors `benches/performance_benchmarks.rs::ingestion_throughput` so
//! samply/dhat flamegraphs point at the same hot paths the criterion
//! baseline measures.
//!
//! Usage:
//!   cargo build --release --example ingest_workload
//!   samply record ./target/release/examples/ingest_workload
//!
//! With dhat-heap (when the `dhat-heap` feature is enabled):
//!   cargo run --release --example ingest_workload --features dhat-heap
//!   # produces dhat-heap.json; open at https://nnethercote.github.io/dh_view/dh_view.html

#[cfg(not(feature = "dhat-heap"))]
#[global_allocator]
static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc;

#[cfg(feature = "dhat-heap")]
#[global_allocator]
static ALLOC: dhat::Alloc = dhat::Alloc;

use allsource_core::{domain::entities::Event, store::EventStore};
use serde_json::json;

const ITERATIONS: usize = 20;
const EVENTS_PER_ITER: usize = 10_000;

fn main() {
    #[cfg(feature = "dhat-heap")]
    let _profiler = dhat::Profiler::new_heap();

    for _ in 0..ITERATIONS {
        let store = EventStore::new();
        for i in 0..EVENTS_PER_ITER {
            let event = Event::from_strings(
                "benchmark.event".to_string(),
                format!("entity-{}", i % 100),
                "default".to_string(),
                json!({ "index": i, "data": "payload" }),
                None,
            )
            .unwrap();
            store.ingest(&event).unwrap();
        }
        std::hint::black_box(store);
    }
}