common_meta::wal_options_allocator::kafka::topic_selector

Trait TopicSelector

source 
pub(crate) trait TopicSelector: Send + Sync {
    // Required method
    fn select<'a>(&self, topic_pool: &'a [String]) -> Result<&'a String>;
}
Expand description

Controls topic selection.

Required Methods§

source

fn select<'a>(&self, topic_pool: &'a [String]) -> Result<&'a String>

Selects a topic from the topic pool.

Implementors§