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
4//! Compilation of ringbuffer scan operations
5
6use reifydb_core::interface::catalog::flow::FlowNodeId;
7use reifydb_rql::{flow::node::FlowNodeType::SourceRingBuffer, nodes::RingBufferScanNode};
8use reifydb_transaction::transaction::admin::AdminTransaction;
9use reifydb_type::Result;
10
11use crate::flow::compiler::{CompileOperator, FlowCompiler};
12
13pub(crate) struct RingBufferScanCompiler {
14	pub ringbuffer_scan: RingBufferScanNode,
15}
16
17impl From<RingBufferScanNode> for RingBufferScanCompiler {
18	fn from(ringbuffer_scan: RingBufferScanNode) -> Self {
19		Self {
20			ringbuffer_scan,
21		}
22	}
23}
24
25impl CompileOperator for RingBufferScanCompiler {
26	fn compile(self, compiler: &mut FlowCompiler, txn: &mut AdminTransaction) -> Result<FlowNodeId> {
27		let ringbuffer_id = self.ringbuffer_scan.source.def().id;
28		compiler.add_node(
29			txn,
30			SourceRingBuffer {
31				ringbuffer: ringbuffer_id,
32			},
33		)
34	}
35}