source

type File ¶

type File struct {
	*os.File
}

func (File) Continuable() bool

type FileSource ¶

type FileSource interface {
	LogSource
	Stat() (os.FileInfo, error)
	Continuable() bool // can we continue processing after EOF?
}

type LogSource ¶

type LogSource interface {
	io.ReadCloser
	Name() string
}

type Pipe ¶

type Pipe struct {
	File *os.File
}

restrict file to minimal interface of FileSource to prevent possible casts to additional interfaces supported by underlying file

func (p Pipe) Close() error

func (p Pipe) Continuable() bool

func (p Pipe) Name() string

func (p Pipe) Read(b []byte) (int, error)

func (p Pipe) Stat() (os.FileInfo, error)