wedb_standalone 0.1.2

Standalone server foundation: RESP protocol, AOF logic layer, and node service orchestration
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

pub mod ri_frame;
pub use ri_frame::*;
pub mod acl_commands;
pub mod admin_commands;
pub mod array_commands;
pub mod async_processor;
pub mod basic_commands;
pub mod basic_etag_commands;
pub mod bitmap;
pub mod byte_array_comparer;
pub mod client_commands;
pub mod cmd_strings;
pub mod hyperloglog;
pub mod i_resp_serializable;
pub mod key_admin_commands;
pub mod m_get_read_arg_batch;
pub mod objects;
pub mod parser;
pub mod rangeindex;
pub mod rdb_crc64;
pub mod resp_command_argument;
pub mod resp_command_data_common;
pub mod resp_command_data_provider;
pub mod resp_command_docs;
pub mod resp_command_info_simplified_structs;
pub mod resp_command_key_specification;
pub mod resp_commands_info;
pub mod resp_commands_info_data;
pub mod resp_memory_writer;
pub mod resp_server_session;
pub mod resp_server_session_output;
pub mod resp_server_session_slot_verify;
pub mod session_logger;
pub mod ttl_sync;
pub mod vector;

/// 单测共用装具：临时单文件库 + 批处理纪元会话（各命令文件的 #[cfg(test)] 共享，
/// 一处定义避免逐文件复制）
#[cfg(test)]
pub(crate) mod batch_harness {
  use std::sync::Arc;

  use compio::runtime::Runtime;
  use wdev::SegmentedDevice;
  use wkv::{StoreConfig, WedbStore};

  use super::resp_server_session::RespServerSession;

  pub(crate) type Batch<'a> = wkv::BatchStoreSession<'a, SegmentedDevice>;

  pub(crate) fn with_batch(f: impl FnOnce(&mut RespServerSession, &Batch)) {
    let rt = Runtime::new().unwrap();
    rt.block_on(async {
      let dir = tempfile::tempdir().unwrap();
      let device = Arc::new(SegmentedDevice::single_file(dir.path().join("resp.db")).unwrap());
      let mut config = StoreConfig::new(1024, 4096, 16, 0.5).unwrap();
      config.gc.enabled = false;
      let store = Arc::new(WedbStore::open(config, device).unwrap());
      let session = store.new_session().unwrap();
      let batch = session.enter_batch();
      // 会话状态域（周期6）落地为真实结构体：默认零号会话（无端点/库0/RESP2）
      let mut s = RespServerSession::default();
      f(&mut s, &batch);
    });
  }
}