filewatch

Nov 26, 2019

Changes in this version

type LogHandlerConfig

+ Src net.IP

Sep 20, 2019

Changes in this version

+ const LineEngine

+ const RegexEngine

+ var ErrAlreadyStarted = errors.New("WatchManager already started")

+ var ErrFailedSeek = errors.New("Failed to seek to the start of the states file")

+ var ErrInvalidStateFile = errors.New("State file exists and is not a regular file")

+ var ErrLocationNotDir = errors.New("Watched Location is not a directory")

+ var ErrNoDirsWatched = errors.New("No locations have been added to the watch list")

+ var ErrNotReady = errors.New("fsnotify watcher is not ready")

+ var ErrNotRunning = errors.New("Not running")

+ func NewFollower(cfg FollowerConfig) (*follower, error)

+ func ReadStateFile(p string) (states map[string]int64, err error)

+ type FileId struct

+ Major uint64

+ Minor uint64

+ type FileName struct

+ BaseName string

+ FilePath string

+ type FilterManager struct

+ func NewFilterManager(stateFile string) (*FilterManager, error)

+ func (f *FilterManager) AddFilter(bname, loc string, mtchs []string, lh handler, ecfg FollowerEngineConfig) error

+ func (f *FilterManager) IsWatched(fpath string) bool

+ func (f *FilterManager) LoadFile(fpath string) (bool, error)

+ func (f *FilterManager) NewFollower(fpath string) (bool, error)

+ func (f *FilterManager) RemoveFollower(fpath string) (bool, error)

+ func (f *FilterManager) RenameFollower(fpath string) error

+ func (fm *FilterManager) Close() (err error)

+ func (fm *FilterManager) Filters() int

+ func (fm *FilterManager) FlushStates() error

+ func (fm *FilterManager) Followed() int

+ func (fm *FilterManager) SetLogger(lgr ingest.IngestLogger)

+ func (fm *FilterManager) SetMaxFilesWatched(max int)

+ type FollowerConfig struct

+ BaseName string

+ FilePath string

+ FilterID int

+ Handler handler

+ State *int64

+ type FollowerEngineConfig struct

+ Engine int

+ EngineArgs string

+ type LineReader struct — linux/amd64, windows/amd64

+ func NewLineReader(cfg ReaderConfig) (*LineReader, error)

+ func (br *LineReader) Close() error

+ func (br *LineReader) Index() int64

+ func (br *LineReader) SeekFile(offset int64) error

+ func (lr *LineReader) Close() error

+ func (lr *LineReader) Index() int64

+ func (lr *LineReader) ReadEntry() (ln []byte, ok bool, sawEOF bool, err error)

+ func (lr *LineReader) ReadEntry() (ln []byte, ok bool, wasEOF bool, err error)

+ func (lr *LineReader) SeekFile(offset int64) error

+ type LogHandler struct

+ func NewLogHandler(cfg LogHandlerConfig, ch chan *entry.Entry) (*LogHandler, error)

+ func (lh *LogHandler) HandleLog(b []byte, catchts time.Time) error

+ type LogHandlerConfig struct

+ AssumeLocalTZ bool

+ Debugger debugOut

+ IgnorePrefixes [][]byte

+ IgnoreTS bool

+ Logger logger

+ Tag entry.EntryTag

+ TimestampFormatOverride string

+ TimezoneOverride string

+ type Reader interface

+ Close func() error

+ Index func() int64

+ ReadEntry func() ([]byte, bool, bool, error)

+ SeekFile func(int64) error

+ func NewReader(cfg ReaderConfig) (Reader, error)

+ type ReaderConfig struct

+ Engine int

+ EngineArgs string

+ Fin *os.File

+ MaxLineLen int

+ StartIndex int64

+ type RegexReader struct

+ func NewRegexReader(cfg ReaderConfig) (*RegexReader, error)

+ func (br *RegexReader) Close() error

+ func (br *RegexReader) Index() int64

+ func (br *RegexReader) SeekFile(offset int64) error

+ func (rr *RegexReader) ReadEntry() (ln []byte, ok bool, wasEOF bool, err error)

+ type WatchConfig struct

+ BaseDir string

+ ConfigName string

+ FileFilter string

+ Hnd handler

+ Recursive bool

+ type WatchManager struct

+ func NewWatcher(stateFilePath string) (*WatchManager, error)

+ func (wm *WatchManager) Add(c WatchConfig) error

+ func (wm *WatchManager) Close() error

+ func (wm *WatchManager) Dump() string

+ func (wm *WatchManager) Filters() int

+ func (wm *WatchManager) Followers() int

+ func (wm *WatchManager) SetLogger(lgr ingest.IngestLogger)

+ func (wm *WatchManager) SetMaxFilesWatched(max int)

+ func (wm *WatchManager) Start() error