reifydb_transaction/interceptor/
ringbuffer_def.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use reifydb_core::interface::catalog::ringbuffer::RingBufferDef;
5use reifydb_type::Result;
6
7use crate::interceptor::chain::InterceptorChain;
8
9// RING BUFFER POST CREATE
10/// Context for ring buffer post-create interceptors
11pub struct RingBufferDefPostCreateContext<'a> {
12	pub post: &'a RingBufferDef,
13}
14
15impl<'a> RingBufferDefPostCreateContext<'a> {
16	pub fn new(post: &'a RingBufferDef) -> Self {
17		Self {
18			post,
19		}
20	}
21}
22
23pub trait RingBufferDefPostCreateInterceptor: Send + Sync {
24	fn intercept<'a>(&self, ctx: &mut RingBufferDefPostCreateContext<'a>) -> Result<()>;
25}
26
27impl InterceptorChain<dyn RingBufferDefPostCreateInterceptor + Send + Sync> {
28	pub fn execute(&self, mut ctx: RingBufferDefPostCreateContext) -> Result<()> {
29		for interceptor in &self.interceptors {
30			interceptor.intercept(&mut ctx)?;
31		}
32		Ok(())
33	}
34}
35
36pub struct ClosureRingBufferDefPostCreateInterceptor<F>
37where
38	F: for<'a> Fn(&mut RingBufferDefPostCreateContext<'a>) -> Result<()> + Send + Sync,
39{
40	closure: F,
41}
42
43impl<F> ClosureRingBufferDefPostCreateInterceptor<F>
44where
45	F: for<'a> Fn(&mut RingBufferDefPostCreateContext<'a>) -> Result<()> + Send + Sync,
46{
47	pub fn new(closure: F) -> Self {
48		Self {
49			closure,
50		}
51	}
52}
53
54impl<F> Clone for ClosureRingBufferDefPostCreateInterceptor<F>
55where
56	F: for<'a> Fn(&mut RingBufferDefPostCreateContext<'a>) -> Result<()> + Send + Sync + Clone,
57{
58	fn clone(&self) -> Self {
59		Self {
60			closure: self.closure.clone(),
61		}
62	}
63}
64
65impl<F> RingBufferDefPostCreateInterceptor for ClosureRingBufferDefPostCreateInterceptor<F>
66where
67	F: for<'a> Fn(&mut RingBufferDefPostCreateContext<'a>) -> Result<()> + Send + Sync,
68{
69	fn intercept<'a>(&self, ctx: &mut RingBufferDefPostCreateContext<'a>) -> Result<()> {
70		(self.closure)(ctx)
71	}
72}
73
74pub fn ringbuffer_def_post_create<F>(f: F) -> ClosureRingBufferDefPostCreateInterceptor<F>
75where
76	F: for<'a> Fn(&mut RingBufferDefPostCreateContext<'a>) -> Result<()> + Send + Sync + Clone + 'static,
77{
78	ClosureRingBufferDefPostCreateInterceptor::new(f)
79}
80
81// RING BUFFER PRE UPDATE
82/// Context for ring buffer pre-update interceptors
83pub struct RingBufferDefPreUpdateContext<'a> {
84	pub pre: &'a RingBufferDef,
85}
86
87impl<'a> RingBufferDefPreUpdateContext<'a> {
88	pub fn new(pre: &'a RingBufferDef) -> Self {
89		Self {
90			pre,
91		}
92	}
93}
94
95pub trait RingBufferDefPreUpdateInterceptor: Send + Sync {
96	fn intercept<'a>(&self, ctx: &mut RingBufferDefPreUpdateContext<'a>) -> Result<()>;
97}
98
99impl InterceptorChain<dyn RingBufferDefPreUpdateInterceptor + Send + Sync> {
100	pub fn execute(&self, mut ctx: RingBufferDefPreUpdateContext) -> Result<()> {
101		for interceptor in &self.interceptors {
102			interceptor.intercept(&mut ctx)?;
103		}
104		Ok(())
105	}
106}
107
108pub struct ClosureRingBufferDefPreUpdateInterceptor<F>
109where
110	F: for<'a> Fn(&mut RingBufferDefPreUpdateContext<'a>) -> Result<()> + Send + Sync,
111{
112	closure: F,
113}
114
115impl<F> ClosureRingBufferDefPreUpdateInterceptor<F>
116where
117	F: for<'a> Fn(&mut RingBufferDefPreUpdateContext<'a>) -> Result<()> + Send + Sync,
118{
119	pub fn new(closure: F) -> Self {
120		Self {
121			closure,
122		}
123	}
124}
125
126impl<F> Clone for ClosureRingBufferDefPreUpdateInterceptor<F>
127where
128	F: for<'a> Fn(&mut RingBufferDefPreUpdateContext<'a>) -> Result<()> + Send + Sync + Clone,
129{
130	fn clone(&self) -> Self {
131		Self {
132			closure: self.closure.clone(),
133		}
134	}
135}
136
137impl<F> RingBufferDefPreUpdateInterceptor for ClosureRingBufferDefPreUpdateInterceptor<F>
138where
139	F: for<'a> Fn(&mut RingBufferDefPreUpdateContext<'a>) -> Result<()> + Send + Sync,
140{
141	fn intercept<'a>(&self, ctx: &mut RingBufferDefPreUpdateContext<'a>) -> Result<()> {
142		(self.closure)(ctx)
143	}
144}
145
146pub fn ringbuffer_def_pre_update<F>(f: F) -> ClosureRingBufferDefPreUpdateInterceptor<F>
147where
148	F: for<'a> Fn(&mut RingBufferDefPreUpdateContext<'a>) -> Result<()> + Send + Sync + Clone + 'static,
149{
150	ClosureRingBufferDefPreUpdateInterceptor::new(f)
151}
152
153// RING BUFFER POST UPDATE
154/// Context for ring buffer post-update interceptors
155pub struct RingBufferDefPostUpdateContext<'a> {
156	pub pre: &'a RingBufferDef,
157	pub post: &'a RingBufferDef,
158}
159
160impl<'a> RingBufferDefPostUpdateContext<'a> {
161	pub fn new(pre: &'a RingBufferDef, post: &'a RingBufferDef) -> Self {
162		Self {
163			pre,
164			post,
165		}
166	}
167}
168
169pub trait RingBufferDefPostUpdateInterceptor: Send + Sync {
170	fn intercept<'a>(&self, ctx: &mut RingBufferDefPostUpdateContext<'a>) -> Result<()>;
171}
172
173impl InterceptorChain<dyn RingBufferDefPostUpdateInterceptor + Send + Sync> {
174	pub fn execute(&self, mut ctx: RingBufferDefPostUpdateContext) -> Result<()> {
175		for interceptor in &self.interceptors {
176			interceptor.intercept(&mut ctx)?;
177		}
178		Ok(())
179	}
180}
181
182pub struct ClosureRingBufferDefPostUpdateInterceptor<F>
183where
184	F: for<'a> Fn(&mut RingBufferDefPostUpdateContext<'a>) -> Result<()> + Send + Sync,
185{
186	closure: F,
187}
188
189impl<F> ClosureRingBufferDefPostUpdateInterceptor<F>
190where
191	F: for<'a> Fn(&mut RingBufferDefPostUpdateContext<'a>) -> Result<()> + Send + Sync,
192{
193	pub fn new(closure: F) -> Self {
194		Self {
195			closure,
196		}
197	}
198}
199
200impl<F> Clone for ClosureRingBufferDefPostUpdateInterceptor<F>
201where
202	F: for<'a> Fn(&mut RingBufferDefPostUpdateContext<'a>) -> Result<()> + Send + Sync + Clone,
203{
204	fn clone(&self) -> Self {
205		Self {
206			closure: self.closure.clone(),
207		}
208	}
209}
210
211impl<F> RingBufferDefPostUpdateInterceptor for ClosureRingBufferDefPostUpdateInterceptor<F>
212where
213	F: for<'a> Fn(&mut RingBufferDefPostUpdateContext<'a>) -> Result<()> + Send + Sync,
214{
215	fn intercept<'a>(&self, ctx: &mut RingBufferDefPostUpdateContext<'a>) -> Result<()> {
216		(self.closure)(ctx)
217	}
218}
219
220pub fn ringbuffer_def_post_update<F>(f: F) -> ClosureRingBufferDefPostUpdateInterceptor<F>
221where
222	F: for<'a> Fn(&mut RingBufferDefPostUpdateContext<'a>) -> Result<()> + Send + Sync + Clone + 'static,
223{
224	ClosureRingBufferDefPostUpdateInterceptor::new(f)
225}
226
227// RING BUFFER PRE DELETE
228/// Context for ring buffer pre-delete interceptors
229pub struct RingBufferDefPreDeleteContext<'a> {
230	pub pre: &'a RingBufferDef,
231}
232
233impl<'a> RingBufferDefPreDeleteContext<'a> {
234	pub fn new(pre: &'a RingBufferDef) -> Self {
235		Self {
236			pre,
237		}
238	}
239}
240
241pub trait RingBufferDefPreDeleteInterceptor: Send + Sync {
242	fn intercept<'a>(&self, ctx: &mut RingBufferDefPreDeleteContext<'a>) -> Result<()>;
243}
244
245impl InterceptorChain<dyn RingBufferDefPreDeleteInterceptor + Send + Sync> {
246	pub fn execute(&self, mut ctx: RingBufferDefPreDeleteContext) -> Result<()> {
247		for interceptor in &self.interceptors {
248			interceptor.intercept(&mut ctx)?;
249		}
250		Ok(())
251	}
252}
253
254pub struct ClosureRingBufferDefPreDeleteInterceptor<F>
255where
256	F: for<'a> Fn(&mut RingBufferDefPreDeleteContext<'a>) -> Result<()> + Send + Sync,
257{
258	closure: F,
259}
260
261impl<F> ClosureRingBufferDefPreDeleteInterceptor<F>
262where
263	F: for<'a> Fn(&mut RingBufferDefPreDeleteContext<'a>) -> Result<()> + Send + Sync,
264{
265	pub fn new(closure: F) -> Self {
266		Self {
267			closure,
268		}
269	}
270}
271
272impl<F> Clone for ClosureRingBufferDefPreDeleteInterceptor<F>
273where
274	F: for<'a> Fn(&mut RingBufferDefPreDeleteContext<'a>) -> Result<()> + Send + Sync + Clone,
275{
276	fn clone(&self) -> Self {
277		Self {
278			closure: self.closure.clone(),
279		}
280	}
281}
282
283impl<F> RingBufferDefPreDeleteInterceptor for ClosureRingBufferDefPreDeleteInterceptor<F>
284where
285	F: for<'a> Fn(&mut RingBufferDefPreDeleteContext<'a>) -> Result<()> + Send + Sync,
286{
287	fn intercept<'a>(&self, ctx: &mut RingBufferDefPreDeleteContext<'a>) -> Result<()> {
288		(self.closure)(ctx)
289	}
290}
291
292pub fn ringbuffer_def_pre_delete<F>(f: F) -> ClosureRingBufferDefPreDeleteInterceptor<F>
293where
294	F: for<'a> Fn(&mut RingBufferDefPreDeleteContext<'a>) -> Result<()> + Send + Sync + Clone + 'static,
295{
296	ClosureRingBufferDefPreDeleteInterceptor::new(f)
297}
reifydb_transaction/interceptor/ringbuffer_def.rs

reifydb_transaction/interceptor/
ringbuffer_def.rs
