reifydb-flow 0.9.1

Flow execution substrate: the flow transaction/state layer and the operator contract
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

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2026 ReifyDB

pub mod column;
pub(crate) mod expiry;
pub mod operator;
pub(crate) mod snapshot;
pub mod state;
pub mod store;
pub mod strategy;

use reifydb_core::{interface::change::Diff, value::column::columns::Columns};
use reifydb_value::value::row_number::RowNumber;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub(crate) enum Identity<'a> {
	Mint,
	Existing,
	Consume,
	Carried(&'a [(RowNumber, bool)]),
}

pub(crate) struct Emitted {
	pub(crate) fresh: Columns,
	pub(crate) existing: Columns,
}

impl Emitted {
	pub(crate) fn empty() -> Self {
		Self {
			fresh: Columns::empty(),
			existing: Columns::empty(),
		}
	}

	pub(crate) fn is_empty(&self) -> bool {
		self.fresh.row_count() == 0 && self.existing.row_count() == 0
	}

	pub(crate) fn published(self) -> Vec<Diff> {
		let mut out = Vec::new();
		if self.fresh.row_count() > 0 {
			out.push(Diff::insert(self.fresh));
		}
		if self.existing.row_count() > 0 {
			out.push(Diff::update(self.existing.clone(), self.existing));
		}
		out
	}

	pub(crate) fn withdrawn(self) -> Option<Diff> {
		(self.existing.row_count() > 0).then(|| Diff::remove(self.existing))
	}
}