disk_monitor

type DiskMonitor struct {
	// contains filtered or unexported fields
}

type DiskNotifier interface {
	Prepare(logger *zaplog.Logger, fileName string)
	Change(logger *zaplog.Logger, fileName string, data []byte) error
	Finish(logger *zaplog.Logger, fileName string)
}

type DiskNotifierChangeFunc func(logger *zaplog.Logger, fileName string, data []byte) error

type MonitorOption func(cc *MonitorOptions) MonitorOption

type MonitorOptions struct {
	// log interface
	Logger *zaplog.Logger
	// file ext
	FileExt string
	// monitor file or paths
	Paths []string
	// retry time limit, 0:disable retry
	RetryLimit int
	// retry interval
	RetryInterval time.Duration
	// monitor notify interface
	Notifier DiskNotifier
	// app stopper
	Stoper app.Stoper
}