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

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

//! Join metadata representation for topology export
//!
//! This module defines a simple structural type that tracks, per join stage,
//! which upstream stages are treated as catalog/reference sources vs
//! streaming sources. It is populated during flow construction and exposed
//! via the topology HTTP API.

use obzenflow_core::StageId;
use serde::{Deserialize, Serialize};

/// Internal join metadata keyed by core StageId (join stage id).
///
/// This mirrors the public API shape but uses StageId internally so that
/// both the runtime and web layers can convert to their preferred string
/// or topology id representations.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct JoinMetadata {
    /// Stage IDs whose outputs are catalog/reference inputs.
    pub catalog_source_ids: Vec<StageId>,
    /// Stage IDs whose outputs are stream inputs.
    pub stream_source_ids: Vec<StageId>,
}