pub fn push(&mut self, mut lines: Vec<types::api::PushLogLine>) -> Result<(), Error> {
        // encoding line length.
        let drain = lines.drain(0..lines.len());
        for line in drain {
            self.batch.push(line);
        }
        if self.batch.len() >= (self.config.max_batch_size as usize) {
            debug!("flushing log lines for the partition {}", self.partition);
            self.flush()?;
        }
        Ok(())
    }
/// push pushes logline and terms of the logline. terms are used to index the line's file
/// offset. push will essentially batch all the line. Once the batch size reached, it'll
/// flush the line to the file.
push pushes logline and terms of the logline. terms are used to index the line's file
offset. push will essentially batch all the line. Once the batch size reached, it'll
flush the line to the file.
push pushes logline and terms of the logline . terms are used to index the line ' s file offset . push will essentially batch all the line . Once the batch size reached it ' ll flush the line to the file .
pub fn push(&mut self, mut lines: Vec<types::api::PushLogLine>) -> Result<(), Error> {
        // encoding line length.
        let drain = lines.drain(0..lines.len());
        for line in drain {
            self.batch.push(line);
        }
        if self.batch.len() >= (self.config.max_batch_size as usize) {
            debug!("flushing log lines for the partition {}", self.partition);
            self.flush()?;
        }
        Ok(())
    }
pub fn push ( & mut self , mut lines : Vec < types :: api :: PushLogLine > ) -> Result < ( ) , Error > { // encoding line length. let drain = lines . drain ( 0 .. lines . len ( ) ) ; for line in drain { self . batch . push ( line ) ; } if self . batch . len ( ) >= ( self . config . max_batch_size as usize ) { debug ! ( " " self partition ) ; self . flush ( ) ? ; } Ok ( ( ) ) }
push pushes logline and terms of the logline.
push pushes logline and terms of the logline .
&mut self
lines
Vec<types::api::PushLogLine>