reifydb-core 0.4.5

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
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

//! Storage and CDC statistics events.
//!
//! These events are emitted when storage operations occur that need stats tracking.
//! The metrics worker listens to these events and updates storage statistics.

use crate::{common::CommitVersion, encoded::key::EncodedKey};

define_event! {
	/// Emitted when storage operations are committed that need stats tracking.
	/// Used for both commit-time ops and async drop worker ops.
	pub struct StorageStatsRecordedEvent {
		pub writes: Vec<StorageWrite>,
		pub deletes: Vec<StorageDelete>,
		pub drops: Vec<StorageDrop>,
		pub version: CommitVersion,
	}
}

/// A storage write operation for stats tracking.
#[derive(Clone, Debug)]
pub struct StorageWrite {
	pub key: EncodedKey,
	pub value_bytes: u64,
}

/// A storage delete operation for stats tracking.
#[derive(Clone, Debug)]
pub struct StorageDelete {
	pub key: EncodedKey,
	pub value_bytes: u64,
}

/// A storage drop operation (MVCC cleanup) for stats tracking.
#[derive(Clone, Debug)]
pub struct StorageDrop {
	pub key: EncodedKey,
	pub value_bytes: u64,
}

define_event! {
	/// Emitted when CDC entries are written that need stats tracking.
	pub struct CdcStatsRecordedEvent {
		pub entries: Vec<CdcEntryStats>,
		pub version: CommitVersion,
	}
}

/// A CDC entry for stats tracking.
#[derive(Clone, Debug)]
pub struct CdcEntryStats {
	pub key: EncodedKey,
	pub value_bytes: u64,
}

/// A CDC entry drop for stats tracking.
#[derive(Clone, Debug)]
pub struct CdcEntryDrop {
	pub key: EncodedKey,
	pub value_bytes: u64,
}

define_event! {
	/// Emitted when CDC entries are dropped that need stats tracking.
	pub struct CdcStatsDroppedEvent {
		pub entries: Vec<CdcEntryDrop>,
		pub version: CommitVersion,
	}
}