rspack_core 0.102.3

rspack core
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

#[cfg(target_family = "wasm")]
mod noop;
#[cfg(not(target_family = "wasm"))]
mod turbo;

use rspack_error::Result;

use crate::new_cache::CacheKey;

#[derive(Debug, Clone, Copy)]
pub enum DatabaseFamily {
  Cache,
  Validator,
  Meta,
}

impl DatabaseFamily {
  pub const COUNT: usize = 3;

  pub const fn index(self) -> usize {
    match self {
      Self::Cache => 0,
      Self::Validator => 1,
      Self::Meta => 2,
    }
  }
}

#[cfg(target_family = "wasm")]
pub type DatabaseValue = std::sync::Arc<[u8]>;
#[cfg(target_family = "wasm")]
pub use noop::NoopDatabase as TurboDatabase;
#[cfg(not(target_family = "wasm"))]
pub type DatabaseValue = turbo_persistence::ArcBytes;
#[cfg(not(target_family = "wasm"))]
pub use turbo::TurboDatabase;

pub(crate) trait Database: Send + Sync {
  fn get(&self, family: DatabaseFamily, key: &CacheKey) -> Result<Option<DatabaseValue>>;

  fn is_empty(&self) -> bool;

  fn write_batch(&self, writes: Vec<(DatabaseFamily, CacheKey, Vec<u8>)>) -> Result<()>;

  fn compact(&self) -> Result<()>;

  fn has_unrecoverable_write_error(&self) -> bool;

  fn reset(&mut self) -> Result<()>;

  fn cleanup_stale(&self) -> Result<()>;

  fn shutdown(self: Box<Self>) -> Result<()>;
}