fsutil

Documentation

Index

• type PollingFileAppendReader
  • func NewPollingFileAppendReader(path string, interval time.Duration) (*PollingFileAppendReader, error)
  • func (r *PollingFileAppendReader) Close() error

Types

type PollingFileAppendReader

type PollingFileAppendReader struct {
	io.Reader
	// contains filtered or unexported fields
}

PollingFileAppendReader polls a file for updates. When the size of the file changes it reads the new content and makes it available via Read()

func NewPollingFileAppendReader

func NewPollingFileAppendReader(path string, interval time.Duration) (*PollingFileAppendReader, error)

NewPollingFileAppendReader creates a new reader for the provided path which polls at the desired interval

func (*PollingFileAppendReader) Close

func (r *PollingFileAppendReader) Close() error

Close the reader