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
pub mod spu;
pub mod topic;
pub mod partition;
pub mod spg;
pub mod message;
pub mod smartmodule;
pub mod tableformat;
pub use fluvio_stream_model::core;
pub mod store {
pub use fluvio_stream_model::store::*;
}
#[cfg(feature = "k8")]
pub use fluvio_stream_model::k8_types;
pub mod extended {
use super::core::Spec;
#[derive(Debug, Clone, PartialEq, Hash, Eq)]
#[cfg_attr(feature = "use_serde", derive(serde::Serialize, serde::Deserialize))]
pub enum ObjectType {
Spu,
CustomSpu,
SpuGroup,
Topic,
Partition,
ManagedConnector,
SmartModule,
TableFormat,
DerivedStream,
}
pub trait SpecExt: Spec {
const OBJECT_TYPE: ObjectType;
}
}