Struct MetadataStore 

pub struct MetadataStore { /* private fields */ }

Thread-safe metadata store wrapper

Implementations

impl MetadataStore

pub fn new() -> Self

pub fn from_metadata(metadata: ClusterMetadata) -> Self

pub async fn read(&self) -> RwLockReadGuard<'_, ClusterMetadata>

pub async fn write(&self) -> RwLockWriteGuard<'_, ClusterMetadata>

pub async fn apply(&self, index: u64, cmd: MetadataCommand) -> MetadataResponse

pub async fn get_topic(&self, name: &str) -> Option<TopicState>

pub async fn get_partition(&self, id: &PartitionId) -> Option<PartitionState>

pub async fn epoch(&self) -> u64

Trait Implementations

impl Default for MetadataStore

fn default() -> Self

Returns the “default value” for a type.