Skip to main content

nstreams_core/
error.rs

1use thiserror::Error;
2
3#[derive(Debug, Error)]
4pub enum Error {
5    #[error("namespace {0} is invalid: {1}")]
6    InvalidNamespace(String, String),
7
8    #[error("event store error: {0}")]
9    Store(String),
10
11    #[error("write queue error: {0}")]
12    WriteQueue(String),
13
14    #[error("read stream error: {0}")]
15    ReadStream(String),
16
17    #[error("serialization error: {0}")]
18    Serialization(String),
19
20    #[error("version gap detected: expected {expected}, got {actual}")]
21    VersionGap { expected: u64, actual: u64 },
22
23    #[error("stream population in progress for namespace {0}")]
24    PopulationInProgress(String),
25
26    #[error("invalid stream filter: {0}")]
27    InvalidFilter(String),
28
29    #[error("{0}")]
30    Other(String),
31}
32
33pub type Result<T> = std::result::Result<T, Error>;