obzenflow_runtime 0.1.2

Runtime services for ObzenFlow - execution and coordination business logic
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

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

//! Base abstractions for the runtime services
//!
//! This module provides supervised state machine patterns that enforce FSM-driven control flow:
//! - `SelfSupervisedStateMachine` - for state machines that contain their own logic
//! - `HandlerSupervisedStateMachine` - for state machines that delegate to handlers

pub(crate) mod base;
pub mod builder;
pub mod handle;
pub mod handler_supervised;
pub(crate) mod idle_backoff;
pub mod self_supervised;
pub(crate) mod with_external_events;

#[cfg(test)]
mod tests;

// Re-export main types
pub use base::EventLoopDirective;
pub use handler_supervised::{HandlerSupervised, HandlerSupervisedExt};
pub use self_supervised::{SelfSupervised, SelfSupervisedExt};

// Builder and handle infrastructure
pub use builder::{
    BuilderError, ChannelBuilder, EventReceiver, EventSender, HandleError, StateWatcher,
    SupervisorBuilder, SupervisorHandle,
};
pub use handle::{HandleBuilder, StandardHandle, SupervisorTaskBuilder};

// DON'T export Supervisor - force users to choose SelfSupervised or HandlerSupervised

pub(crate) use with_external_events::{
    ExternalEventMode, ExternalEventPolicy, HandlerSupervisedWithExternalEvents,
    SelfSupervisedWithExternalEvents,
};