worterbuch 1.4.1

A message broker / database hybrid.
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

use miette::Diagnostic;
use redb::{
    CommitError, CompactionError, DatabaseError, StorageError, TableError, TransactionError,
};
use std::io;
use thiserror::Error;
use tokio::sync::oneshot;
use worterbuch_common::error::WorterbuchError;

use crate::store::StoreError;

#[derive(Debug, Error, Diagnostic)]
pub enum PersistenceError {
    #[error("I/O error: {0}")]
    IoError(#[from] io::Error),
    #[error("Checksum mismatch")]
    ChecksumMismatch,
    #[error("(De-)Serialization error: {0}")]
    SerdeError(#[from] serde_json::Error),
    #[error("Store is locked")]
    StoreLocked,
    #[error("Worterbuch error: {0}")]
    WorterbuchError(#[from] WorterbuchError),
    #[error("Written data is different from data to be written")]
    DataMismatch,
    #[error("redb database error: {0}")]
    RedbDatabaseBError(#[from] DatabaseError),
    #[error("redb transaction error: {0}")]
    RedbTransactioneError(#[from] TransactionError),
    #[error("redb table error: {0}")]
    RedbTableError(#[from] TableError),
    #[error("redb storage error: {0}")]
    RedbStorageError(#[from] StorageError),
    #[error("redb compaction error: {0}")]
    RedbCompactionError(#[from] CompactionError),
    #[error("redb commit error: {0}")]
    RedbCommitError(#[from] CommitError),
    #[error("store error: {0}")]
    StoreError(#[from] StoreError),
    #[error("internal api error")]
    ApiError(#[from] oneshot::error::RecvError),
}

pub type PersistenceResult<T> = Result<T, PersistenceError>;