obzenflow_core 0.2.4

Core domain layer for ObzenFlow - pure abstractions with minimal dependencies
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

// SPDX-License-Identifier: MIT OR Apache-2.0
// SPDX-FileCopyrightText: 2025-2026 ObzenFlow Contributors
// https://obzenflow.dev

//! Ephemeral processing rates. These never establish accounting or journal coverage.

use crate::event::observability::CaptureStamp;
use crate::time::MetricsDuration;
use crate::StageId;
use serde::{Deserialize, Serialize};
use std::collections::HashMap;

/// An indivisible observation, retained with its original capture on retransmission.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct ThroughputMeasurement {
    pub capture: CaptureStamp,
    pub event_delta: u64,
    pub elapsed: MetricsDuration,
    pub events_per_second: f64,
}

#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
pub struct ThroughputSnapshot {
    pub stages: HashMap<StageId, ThroughputMeasurement>,
    pub flow_input: Option<ThroughputMeasurement>,
    pub flow_output: Option<ThroughputMeasurement>,
}

/// An owned latest-value view; reading it never triggers capture.
pub trait ThroughputSource: Send + Sync {
    fn throughput(&self) -> ThroughputSnapshot;
}