reifydb_core/actors/
flow.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2026 ReifyDB
3
4use std::{collections::BTreeSet, sync::Arc};
5
6use reifydb_runtime::actor::system::ActorHandle;
7use reifydb_value::Result;
8
9use crate::{
10	actors::pending::Pending,
11	common::CommitVersion,
12	interface::{
13		catalog::{flow::FlowId, object::ObjectId},
14		cdc::Cdc,
15	},
16};
17
18pub type FlowActorHandle = ActorHandle<FlowActorMessage>;
19
20pub enum FlowActorMessage {
21	Drain,
22
23	Wake,
24
25	Loaded {
26		outcome: Result<(Vec<Arc<Cdc>>, CommitVersion)>,
27	},
28
29	Tick,
30
31	Sample,
32
33	PublishRestoredFrontiers,
34
35	UpdateSources {
36		source_objects: Arc<BTreeSet<ObjectId>>,
37		completeness_objects: Option<Arc<BTreeSet<u64>>>,
38	},
39
40	SliceCommitted {
41		advance_to: CommitVersion,
42		more: bool,
43		result: Result<()>,
44		committed: Option<(CommitVersion, Pending)>,
45	},
46
47	TickCommitted {
48		result: Result<()>,
49		committed: Option<(CommitVersion, Pending)>,
50	},
51
52	Stop {
53		delete_checkpoint: bool,
54		reply: Box<dyn FnOnce() + Send>,
55	},
56}
57
58pub type FlowSupervisorHandle = ActorHandle<FlowSupervisorMessage>;
59
60pub enum FlowSupervisorMessage {
61	Bootstrap {
62		flows: Vec<FlowId>,
63		scan_from: Option<CommitVersion>,
64	},
65
66	Wake,
67
68	PersistFrontiers,
69}
reifydb_core/actors/flow.rs

reifydb_core/actors/
flow.rs
