source

Documentation

Index

• type File
  • func (File) Continuable() bool
  • func (File) HasState() bool
• type FileSource
• type LogSource
• type Pipe
  • func (p Pipe) Close() error
  • func (p Pipe) Continuable() bool
  • func (p Pipe) HasState() bool
  • func (p Pipe) Name() string
  • func (p Pipe) Read(b []byte) (int, error)
  • func (p Pipe) Stat() (os.FileInfo, error)

Types

type File

type File struct {
	*os.File
}

func (File) Continuable

func (File) Continuable() bool

func (File) HasState

func (File) HasState() bool

type FileSource

type FileSource interface {
	LogSource
	Stat() (os.FileInfo, error)
	Continuable() bool // can we continue processing after EOF?
	HasState() bool    // does this source have a state?
}

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 (Pipe) Close

func (p Pipe) Close() error

func (Pipe) Continuable

func (p Pipe) Continuable() bool

func (Pipe) HasState

func (p Pipe) HasState() bool

func (Pipe) Name

func (p Pipe) Name() string

func (Pipe) Read

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

func (Pipe) Stat

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