Module fluvio_stream_model::store [−][src]
Re-exports
pub use crate::epoch::*; |
Modules
actions | |
event |
Structs
ChangeListener | listen for changes local store |
LocalStore | Idempotent local memory cache of meta objects.
There are only 2 write operations are permitted: sync and apply changes which are idempotent.
For read, read guards are provided which provide hash map API using deref. |
MetadataStoreObject | |
SimpleConcurrentBTreeMap | |
SimpleConcurrentHashMap | inefficient but simple concurrent hashmap this should be only used in a test it locks for every write |
SyncStatus |
Traits
KeyFilter |
Type Definitions
DefaultMetadataObject | |
MetadataChanges |