internal/io/fs/readfile_zstd.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//go:build !nozstd

package fs

import (
	"bufio"
	"io"
	"os"

	"github.com/DataDog/zstd"
	"github.com/mimecast/dtail/internal/io/dlog"
)

func (f *readFile) makeZstdReader(fd *os.File) (reader *bufio.Reader, decompressor io.Closer, err error) {
	dlog.Common.Info(f.FilePath(), "Detected zstd compression format")
	zstdReader := zstd.NewReader(fd)
	decompressor = zstdReader
	reader = bufio.NewReader(zstdReader)
	return
}