internal/fs/catfile.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

package fs

import "sync"

// CatFile is for reading a whole file.
type CatFile struct {
	readFile
}

// NewCatFile returns a new file catter.
func NewCatFile(filePath string, globID string, serverMessages chan<- string, limiter chan struct{}) CatFile {
	var mutex sync.Mutex

	return CatFile{
		readFile: readFile{
			filePath:       filePath,
			stop:           make(chan struct{}),
			globID:         globID,
			serverMessages: serverMessages,
			retry:          false,
			canSkipLines:   false,
			seekEOF:        false,
			limiter:        limiter,
			mutex:          &mutex,
		},
	}
}