Skip to main content

reifydb_engine/flow/compiler/primitive/
ringbuffer_scan.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use reifydb_core::interface::catalog::flow::FlowNodeId;
5use reifydb_rql::{flow::node::FlowNodeType::SourceRingBuffer, nodes::RingBufferScanNode};
6use reifydb_transaction::transaction::Transaction;
7use reifydb_type::Result;
8
9use crate::flow::compiler::{CompileOperator, FlowCompiler};
10
11pub(crate) struct RingBufferScanCompiler {
12	pub ringbuffer_scan: RingBufferScanNode,
13}
14
15impl From<RingBufferScanNode> for RingBufferScanCompiler {
16	fn from(ringbuffer_scan: RingBufferScanNode) -> Self {
17		Self {
18			ringbuffer_scan,
19		}
20	}
21}
22
23impl CompileOperator for RingBufferScanCompiler {
24	fn compile(self, compiler: &mut FlowCompiler, txn: &mut Transaction<'_>) -> Result<FlowNodeId> {
25		let ringbuffer_id = self.ringbuffer_scan.source.def().id;
26		compiler.add_node(
27			txn,
28			SourceRingBuffer {
29				ringbuffer: ringbuffer_id,
30			},
31		)
32	}
33}