reifydb-store-multi 0.8.0

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

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

//! Version-epoch population. The `VersionEpoch` map itself lives in `reifydb-runtime`
//! (`reifydb_runtime::version_epoch::VersionEpoch`) so the flow engine can share it via
//! `RuntimeContext`. Two complementary feeders keep it current:
//!
//! - [`listener`] is the PRIMARY feed: it records `(commit wall-clock, commit version)` on every commit, so the map
//!   carries the exact instant each version was assigned. This is what the version-anchored TTL needs - a row's age is
//!   the wall-clock distance from its commit instant, and only per-commit recording captures the version of commits
//!   that share an instant (notably the flow-processing commits triggered by a source write).
//! - [`actor`] is a periodic BACKSTOP: it samples `(now, current version)` on an interval, so a commit event dropped
//!   under mailbox pressure is still eventually reflected. Same-instant samples collapse to the highest version, so the
//!   backstop never lowers a floor the listener already set.

pub mod actor;
pub mod listener;

use reifydb_core::common::CommitVersion;

/// Supplies the sampler with the current wall-clock time and the current commit version.
pub trait EpochSource: Send + Sync + 'static {
	fn now_nanos(&self) -> u64;

	fn current_version(&self) -> Option<CommitVersion>;
}