[−]Trait fluvio::metadata::topic::store::TopicMd
Required methods
#[must_use]pub fn create_new_partitions<'life0, 'life1, 'async_trait>(
&'life0 self,
partition_store: &'life1 LocalStore<PartitionSpec, C>
) -> Pin<Box<dyn Future<Output = Vec<MetadataStoreObject<PartitionSpec, C>, Global>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
&'life0 self,
partition_store: &'life1 LocalStore<PartitionSpec, C>
) -> Pin<Box<dyn Future<Output = Vec<MetadataStoreObject<PartitionSpec, C>, Global>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Implementors
impl<C> TopicMd<C> for MetadataStoreObject<TopicSpec, C> where
C: MetadataItem + Send + Sync,
C: MetadataItem + Send + Sync,
pub fn create_new_partitions<'life0, 'life1, 'async_trait>(
&'life0 self,
partition_store: &'life1 LocalStore<PartitionSpec, C>
) -> Pin<Box<dyn Future<Output = Vec<MetadataStoreObject<PartitionSpec, C>, Global>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
MetadataStoreObject<TopicSpec, C>: 'async_trait,
&'life0 self,
partition_store: &'life1 LocalStore<PartitionSpec, C>
) -> Pin<Box<dyn Future<Output = Vec<MetadataStoreObject<PartitionSpec, C>, Global>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
MetadataStoreObject<TopicSpec, C>: 'async_trait,
create new partitions from my replica map if it doesn't exists from partition store