async-txn 0.1.3

A runtime agnostic, WASM/WASI friendly, multi-writer-multi-reader MVCC, ACID, Serializable Snapshot Isolation transaction manager for database development.
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

use super::*;

/// AsyncRtm is a read-only transaction manager.
///
/// It is created by calling [`AsyncTm::read`],
/// the read transaction will automatically notify the transaction manager when it
/// is dropped. So, the end user doesn't need to call any cleanup function, but must
/// hold this struct in their final read transaction implementation.
pub struct AsyncRtm<K, V, C, P, S>
where
  S: AsyncSpawner,
{
  pub(super) db: AsyncTm<K, V, C, P, S>,
  pub(super) read_ts: u64,
}

impl<K, V, C, P, S> AsyncRtm<K, V, C, P, S>
where
  S: AsyncSpawner,
{
  /// Returns the version of this read transaction.
  #[inline]
  pub const fn version(&self) -> u64 {
    self.read_ts
  }
}

impl<K, V, C, P, S> Drop for AsyncRtm<K, V, C, P, S>
where
  S: AsyncSpawner,
{
  fn drop(&mut self) {
    self.db.inner.done_read(self.read_ts)
  }
}