1pub mod error;
2
3mod basins;
4mod core;
5mod read;
6mod store;
7mod streamer;
8mod streams;
9
10mod append;
11mod kv;
12mod stream_id;
13
14pub use core::{Backend, FOLLOWER_MAX_LAG};
15
16#[derive(Debug, Clone, PartialEq, Eq)]
17pub enum CreatedOrReconfigured<T> {
18 Created(T),
19 Reconfigured(T),
20}
21
22impl<T> CreatedOrReconfigured<T> {
23 pub fn is_created(&self) -> bool {
24 matches!(self, Self::Created(_))
25 }
26
27 pub fn into_inner(self) -> T {
28 match self {
29 Self::Created(v) | Self::Reconfigured(v) => v,
30 }
31 }
32}