func()

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
}