in accumulator/batch.go [345:364]
func (b *Batch) addData(data []byte) error {
if len(data) == 0 {
return nil
}
if b.metadataBytes == 0 {
return ErrMetadataUnavailable
}
if err := b.buf.WriteByte('\n'); err != nil {
return err
}
if _, err := b.buf.Write(data); err != nil {
return err
}
if b.count == 0 {
// For first entry, set the age of the batch
b.age = time.Now()
}
b.count++
return nil
}