log_store::kafka::index::encoder

Trait IndexEncoder

Source 
pub trait IndexEncoder: Send + Sync {
    // Required methods
    fn encode(&self, provider: &KafkaProvider, region_index: &RegionIndexes);
    fn finish(&self) -> Result<Vec<u8>>;
}

Required Methods§

Source

fn encode(&self, provider: &KafkaProvider, region_index: &RegionIndexes)

Source

fn finish(&self) -> Result<Vec<u8>>

Implementors§