wedb_standalone 0.1.1

单机网络服务底座：RESP 协议帧、AOF 逻辑层与节点服务编排（对标 Garnet libs/server 单机半区）
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

//! 高级 API 面（对标 libs/server/API/IGarnetAdvancedApi.cs:IGarnetAdvancedApi）
//!
//! C# 侧为"仅供非普通客户端使用"的底层入口；Rust 侧以 [`IGarnetAdvancedApi`]
//! 关联函数委托 [`StorageSession`](crate::storage::session::storage_session::StorageSession)
//! 已实现的高级操作面。

use wdev::Device;

use crate::{
  api::garnet_status::GarnetStatus,
  storage::session::{
    mainstore::advanced_ops::{RmwResult, StringRMWOp},
    objectstore::common::RmwOutcome,
    storage_session::StorageSession,
    unifiedstore::advanced_ops::UnifiedRMWOp,
  },
};

/// 高级 API 面
pub struct IGarnetAdvancedApi;

impl IGarnetAdvancedApi {
  /// libs/server/API/IGarnetAdvancedApi.cs:GET_WithPending
  pub async fn get__with_pending<D: Device>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
  ) -> wkv::Result<(GarnetStatus, Option<Vec<u8>>, bool)> {
    ss.get_with_pending(key).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:GET_CompletePending
  pub fn get__complete_pending<D: Device>(ss: &StorageSession<'_, D>) -> bool {
    ss.get_complete_pending()
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:RMW_MainStore
  pub async fn rmw__main_store<D: Device>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
    op: StringRMWOp<'_>,
  ) -> wkv::Result<RmwResult> {
    ss.rmw_main_store(key, op).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:Read_MainStore
  pub async fn read__main_store<D: Device>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
  ) -> wkv::Result<(GarnetStatus, Option<Vec<u8>>)> {
    ss.read_main_store(key).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:RMW_ObjectStore
  ///
  /// 返回 [`RmwOutcome`] 三态（写回 / 放弃 / 类型不符）
  pub async fn rmw__object_store<D: Device, R>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
    tag: u8,
    on_load: impl FnOnce(Option<Vec<u8>>) -> Option<(Vec<u8>, R)>,
  ) -> wkv::Result<RmwOutcome<R>> {
    ss.rmw_object_store(key, tag, on_load).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:Read_ObjectStore
  pub async fn read__object_store<D: Device>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
    tag: u8,
  ) -> wkv::Result<(GarnetStatus, Option<Vec<u8>>)> {
    ss.read_object_store(key, tag).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:RMW_UnifiedStore
  pub async fn rmw__unified_store<D: Device>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
    op: UnifiedRMWOp<'_>,
  ) -> wkv::Result<GarnetStatus> {
    ss.rmw_unified_store(key, op).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:Read_UnifiedStore
  pub async fn read__unified_store<D: Device>(
    ss: &StorageSession<'_, D>,
    key: &[u8],
  ) -> wkv::Result<(GarnetStatus, Option<Vec<u8>>)> {
    ss.read_unified_store(key).await
  }

  /// libs/server/API/IGarnetAdvancedApi.cs:ReadWithPrefetch
  pub async fn read_with_prefetch<D: Device, K: AsRef<[u8]>>(
    ss: &StorageSession<'_, D>,
    keys: &[K],
    on_item: impl FnMut(usize, Option<&[u8]>),
  ) -> wkv::Result<()> {
    ss.read_with_prefetch(keys, on_item).await
  }
}