Method ProcessFile

input/inpututils/compressedstream.go:224–233

Enqueue a file for processing by compressedInput. This function must be called by subclasses to schedule processing a (gzip|zstd) logfile. The function just enqueues the file and exits, so it's normally fast, but might block if the backlog is bigger than internal channel size (default: 1024 files)

(fn string)

// but might block if the backlog is bigger than internal channel size
// (default: 1024 files)
func (s *CompressedInput) ProcessFile(fn string) error {
	// Use the Sizer on the file to acquire the length
	sz, err := s.Sizer(fn)
	if err != nil {
		return err
	}
	s.stats.NewFile(sz)
	s.files <- fn
	return nil
}

// Signal compressedInput that we've finished enqueuing files, and it can exit
// whenever it has finished processing what was already enqueued. This can