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
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

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

use crate::event::payloads::effect_payload::EffectCursor;
use crate::event::payloads::execution_payload::{
    CircuitBreakerHealthClassification, CircuitBreakerOpenTrigger,
};
use crate::event::types::{
    Count, DurationMs, EventId, JournalIndex, JournalPath, RouteKey, SeqNo, ViolationCause,
};
use crate::event::vector_clock::VectorClock;
use crate::id::StageId;

#[derive(Debug, Clone)]
pub struct SourceContractEventParams {
    pub expected_count: Option<Count>,
    pub source_id: StageId,
    pub route: Option<RouteKey>,
    pub journal_path: JournalPath,
    pub journal_index: JournalIndex,
    pub writer_seq: Option<SeqNo>,
    pub vector_clock: Option<VectorClock>,
}

#[derive(Debug, Clone)]
pub struct ConsumptionProgressEventParams {
    pub reader_seq: SeqNo,
    pub last_event_id: Option<EventId>,
    pub vector_clock: Option<VectorClock>,
    pub eof_seen: bool,
    pub reader_path: JournalPath,
    pub reader_index: JournalIndex,
    pub advertised_writer_seq: Option<SeqNo>,
    pub advertised_vector_clock: Option<VectorClock>,
    pub stalled_since: Option<DurationMs>,
}

#[derive(Debug, Clone)]
pub struct ConsumptionFinalEventParams {
    pub pass: bool,
    pub consumed_count: Count,
    pub expected_count: Option<Count>,
    pub eof_seen: bool,
    pub last_event_id: Option<EventId>,
    pub reader_seq: SeqNo,
    pub advertised_writer_seq: Option<SeqNo>,
    pub advertised_vector_clock: Option<VectorClock>,
    pub failure_reason: Option<ViolationCause>,
}

#[derive(Debug, Clone)]
pub struct CircuitBreakerSummaryEventParams {
    pub window_duration_s: u64,
    pub requests_processed: u64,
    pub requests_rejected: u64,
    pub state: String,
    pub consecutive_failures: usize,
    pub rejection_rate: f64,
    pub successes_total: u64,
    pub failures_total: u64,
    pub opened_total: u64,
    pub time_in_closed_seconds: f64,
    pub time_in_open_seconds: f64,
    pub time_in_half_open_seconds: f64,
}

#[derive(Debug, Clone)]
pub struct CircuitBreakerOpenedEventParams {
    pub cooldown_ms: u64,
    pub trigger: CircuitBreakerOpenTrigger,
    pub observed_calls: u64,
    pub error_rate: f64,
    pub failure_count: u64,
    pub slow_call_rate: Option<f64>,
    pub slow_call_count: Option<u64>,
    pub last_error: Option<String>,
}

#[derive(Debug, Clone)]
pub struct CircuitBreakerAttemptSettledEventParams {
    pub cursor: EffectCursor,
    pub attempt: u32,
    pub health_classification: CircuitBreakerHealthClassification,
    pub slow: bool,
    pub dependency_elapsed_ms: u64,
    pub admission_wait_ms: u64,
}

#[derive(Debug, Clone)]
pub struct CircuitBreakerRecoveryCompletedEventParams {
    pub cursor: EffectCursor,
    pub total_attempts: u32,
    pub backoff_elapsed_ms: u64,
    pub recovery_elapsed_ms: u64,
}