/// Configures a new write buffer with the specified number of
/// sequencers (kafka partitions)
Configures a new write buffer with the specified number of
sequencers (kafka partitions)
Configures a new write buffer with the specified number of sequencers ( kafka partitions )
pub fn with_new_write_buffer_kafka_partitions(mut self, n_sequencers: u64) -> Self {
        let tmpdir = TempDir::new().expect("can not create tmp dir");
        let write_buffer_string = tmpdir.path().display().to_string();
        self.write_buffer_dir = Some(Arc::new(tmpdir));
        self.with_env("INFLUXDB_IOX_WRITE_BUFFER_TYPE", "file")
            .with_env(
                "INFLUXDB_IOX_WRITE_BUFFER_AUTO_CREATE_TOPICS",
                n_sequencers.to_string(),
            )
            .with_env("INFLUXDB_IOX_WRITE_BUFFER_ADDR", &write_buffer_string)
    }
pub fn with_new_write_buffer_kafka_partitions ( mut self , n_sequencers : u64 ) -> Self { let tmpdir = TempDir :: new ( ) . expect ( " " ) ; let write_buffer_string = tmpdir . path ( ) . display ( ) . to_string ( ) ; self . write_buffer_dir = Some ( Arc :: new ( tmpdir ) ) ; self . with_env ( " " , " " ) . with_env ( " " , n_sequencers . to_string ( ) , ) . with_env ( " " , & write_buffer_string ) }
Configures a new write buffer with the specified number of
sequencers (kafka partitions)
Configures a new write buffer with the specified number of sequencers ( kafka partitions )
mut self
n_sequencers
u64