reifydb-core 0.8.0

Core database interfaces and data structures for ReifyDB
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

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

use reifydb_codec::key::encoded::{EncodedKey, EncodedKeyRange};
use reifydb_value::{Result, value::row_number::RowNumber};
use serde::{Serialize, de::DeserializeOwned};

pub trait WindowStore {
	fn state_get<V: DeserializeOwned>(&mut self, key: &EncodedKey) -> Result<Option<V>>;

	fn state_get_many_visit<V: DeserializeOwned>(
		&mut self,
		keys: &[EncodedKey],
		visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>,
	) -> Result<()>;

	fn state_set<V: Serialize>(&mut self, key: &EncodedKey, value: &V) -> Result<()>;

	fn state_remove(&mut self, key: &EncodedKey) -> Result<()>;

	fn state_drop(&mut self, key: &EncodedKey) -> Result<()>;

	fn internal_get<V: DeserializeOwned>(&mut self, key: &EncodedKey) -> Result<Option<V>>;

	fn internal_get_many_visit<V: DeserializeOwned>(
		&mut self,
		keys: &[EncodedKey],
		visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>,
	) -> Result<()>;

	fn internal_set<V: Serialize>(&mut self, key: &EncodedKey, value: &V) -> Result<()>;

	fn internal_remove(&mut self, key: &EncodedKey) -> Result<()>;

	fn internal_drop(&mut self, key: &EncodedKey) -> Result<()>;

	fn internal_range_visit<V: DeserializeOwned>(
		&mut self,
		range: EncodedKeyRange,
		visit: &mut dyn FnMut(EncodedKey, V) -> Result<()>,
	) -> Result<()>;

	fn get_or_create_row_number(&mut self, key: &EncodedKey) -> Result<(RowNumber, bool)>;

	fn get_or_create_row_numbers(&mut self, keys: &[EncodedKey]) -> Result<Vec<(RowNumber, bool)>>;

	fn allocate_row_numbers(&mut self, count: u64) -> Result<RowNumber>;

	fn clock_now_nanos(&self) -> u64;
}