jdb_trait 0.1.1

异步存储引擎数据库抽象层 / Async database abstraction layer for storage engines
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

use std::{fmt::Debug, future::Future};

use futures_core::Stream;

use crate::{
  AsyncItem, AsyncRow, Id, Order, Query, Row, SubTable, SubTableKey,
  schema::{Schema, SchemaVer},
};

pub trait Table: Sized + Send + Sync {
  type Error: Debug + Send + Sync;
  type SubTable: SubTable;
  type AsyncRow: AsyncRow;
  type Stream: Stream<Item = Result<AsyncItem<Self::AsyncRow>, Self::Error>> + Send;

  /// 获取当前 Schema Get current schema
  fn schema(&self) -> impl Future<Output = Schema> + Send;

  /// 获取历史 Schema Get schema by version
  fn schema_ver(&self, ver: SchemaVer) -> impl Future<Output = Option<Schema>> + Send;

  fn put(
    &self,
    key: &SubTableKey,
    data: &[Row],
  ) -> impl Future<Output = Result<Vec<Id>, Self::Error>> + Send;

  fn get(
    &self,
    key: &SubTableKey,
    id: Id,
  ) -> impl Future<Output = Result<Option<AsyncItem<Self::AsyncRow>>, Self::Error>> + Send;

  fn get_or_insert_with<F>(
    &self,
    key: &SubTableKey,
    query: &Query,
    f: F,
  ) -> impl Future<Output = Result<AsyncItem<Self::AsyncRow>, Self::Error>> + Send
  where
    F: FnOnce() -> Row + Send;

  fn compact(&self) -> impl Future<Output = Result<(), Self::Error>> + Send;

  fn select(&self, q: &Query) -> impl Future<Output = Self::Stream> + Send;

  fn scan(&self, begin_id: u64, order: Order) -> impl Future<Output = Self::Stream> + Send;

  fn history(
    &self,
    key: &SubTableKey,
    id: Id,
    offset: usize,
  ) -> impl Future<Output = Self::Stream> + Send;

  fn rm(&self, q: &Query) -> impl Future<Output = Result<u64, Self::Error>> + Send;

  fn sub_exists(&self, key: &SubTableKey) -> impl Future<Output = bool> + Send;

  fn sub(&self, key: &SubTableKey) -> impl Future<Output = Option<Self::SubTable>> + Send;
}