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

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

//! Stage implementations organized by type

pub mod common;
pub mod join;
pub mod resources_builder;
pub mod sink;
pub mod source;
pub mod stateful;
pub mod transform;

// Re-export commonly used types from common
pub use common::handlers::source::SourceError;
pub use common::{
    ControlEventAction, ControlEventStrategy, FiniteSourceHandler, InfiniteSourceHandler,
    ObserverHandler, ProcessingContext, ResourceManaged, SinkHandler, StatefulHandler,
    TransformHandler,
};

// Re-export JoinHandler from common::handlers
pub use common::handlers::JoinHandler;

// Re-export resources builder
pub use resources_builder::{StageResources, StageResourcesBuilder, StageResourcesSet};