Module fluvio_stream_model::store

Re-exports

• pub use crate::epoch::*;

Modules

• actions
• event
• memory
  simple memory based metadata

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.
  Hash values are wrapped in EpochCounter. EpochCounter is also deref. Using async lock to ensure read/write are thread safe.
• MetadataStoreList
• MetadataStoreObject
• SimpleConcurrentBTreeMap
• SimpleConcurrentHashMap
  inefficient but simple concurrent hashmap this should be only used in a test it locks for every write
• SyncStatus

Enums

• NameSpace

Traits

• KeyFilter

Type Aliases

• DefaultMetadataObject
• MetadataChanges