reifydb-store-multi 0.4.13

Multi-version storage for OLTP operations with MVCC support
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

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

use std::time::Duration;

use reifydb_core::event::EventBus;
use reifydb_runtime::{actor::system::ActorSystem, context::clock::Clock};

use crate::hot::storage::HotStorage;

#[derive(Clone)]
pub struct MultiStoreConfig {
	pub hot: Option<HotConfig>,
	pub warm: Option<WarmConfig>,
	pub cold: Option<ColdConfig>,
	pub retention: RetentionConfig,
	pub merge_config: MergeConfig,
	pub event_bus: EventBus,
	pub actor_system: ActorSystem,
	pub clock: Clock,
}

#[derive(Clone)]
pub struct HotConfig {
	pub storage: HotStorage,
}

/// Warm tier configuration.
///
/// Placeholder for future warm tier configuration.
#[derive(Clone, Default)]
pub struct WarmConfig;

/// Cold tier configuration.
///
/// Placeholder for future cold tier configuration.
#[derive(Clone, Default)]
pub struct ColdConfig;

#[derive(Clone, Debug)]
pub struct RetentionConfig {
	pub hot: Duration,
	pub warm: Duration,
	// cold is forever (no eviction)
}

#[derive(Clone, Debug)]
pub struct MergeConfig {
	pub merge_threshold_rows: usize,
	pub merge_batch_size: usize,
	pub enable_auto_eviction: bool,
}

impl Default for RetentionConfig {
	fn default() -> Self {
		Self {
			hot: Duration::from_secs(300),   // 5 minutes
			warm: Duration::from_secs(3600), // 1 hour
		}
	}
}

impl Default for MergeConfig {
	fn default() -> Self {
		Self {
			merge_threshold_rows: 100_000,
			merge_batch_size: 10_000,
			enable_auto_eviction: true,
		}
	}
}