kglite 0.10.26

Pure-Rust knowledge graph engine — Cypher pipeline, snapshot/working CoW transactions, columnar/mmap/disk storage backends, optional dataset loaders (SEC EDGAR, Sodir, Wikidata). PyO3 wrappers live in the sibling kglite-py crate (the Python wheel); embeddable directly from any Rust binary without PyO3 in the dep tree.
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

//! Per-stage wall-clock timing for `load_disk_dir`, gated by the
//! `KGLITE_LOAD_TIMING` env var. Off by default (zero overhead); when
//! set, each stage emits a single `[TIMING] stage=<name> dur_ms=<ms>`
//! line to stderr. Consumed by the 0.8.13 load-perf benchmarks and by
//! `kglite.load(path, timing=True)` in the Python wrapper.

use std::time::Instant;

/// Start a timer if `KGLITE_LOAD_TIMING` is set in the environment.
/// Returns `None` otherwise (zero overhead on the hot path).
#[inline]
pub fn stage_timer() -> Option<Instant> {
    if std::env::var_os("KGLITE_LOAD_TIMING").is_some() {
        Some(Instant::now())
    } else {
        None
    }
}

/// Emit a `[TIMING]` line for this stage if timing is enabled. Accepts
/// the `Option<Instant>` returned by `stage_timer()`, so callers don't
/// need to conditionally test the env var themselves.
#[inline]
pub fn log_stage(name: &str, timer: Option<Instant>) {
    if let Some(t) = timer {
        let ms = t.elapsed().as_secs_f64() * 1000.0;
        eprintln!("[TIMING] stage={} dur_ms={:.1}", name, ms);
    }
}