Method send

input/inpututils/compressedstream.go:212–217

(data *baker.Data)

}

func (s *CompressedInput) send(data *baker.Data) {
	nlines := int64(bytes.Count(data.Bytes, []byte{'\n'}))
	atomic.AddInt64(&s.numProcessedLines, nlines)

	s.data <- data
}

// Enqueue a file for processing by compressedInput. This function must be called
// by subclasses to schedule processing a (gzip|zstd) logfile.