dirwatcher

Documentation

Index

• Variables
• func FindInitialLogTime(content DirectoryContent, patterns LogPatterns, ...) (initialTime time.Time, err error)
• type DirectoryContent
  • func NewDirectoryContent(dir string, format parsertimeutil.TimeFormat) (DirectoryContent, error)
  • func NewDirectoryContentForRsync(dir string, format parsertimeutil.TimeFormat, patterns LogPatterns) (DirectoryContent, error)
• type DirectoryImporter
  • func NewDirectoryImporter(content DirectoryContent, pub postfix.Publisher, ...) DirectoryImporter
  • func (importer *DirectoryImporter) ImportOnly() error
  • func (importer *DirectoryImporter) Run() error
• type LogPatterns
  • func BuildLogPatterns(patterns []string) LogPatterns

Variables

var DefaultLogPatterns = BuildLogPatterns([]string{"mail.log", "mail.err", "mail.warn", "zimbra.log", "maillog"})

var ErrEmptyFileList = errors.New(`No valid log files found`)

var ErrLogFilesNotFound = errors.New("Could not find any matching log files")

Functions

func FindInitialLogTime

func FindInitialLogTime(content DirectoryContent, patterns LogPatterns, format parsertimeutil.TimeFormat) (initialTime time.Time, err error)

Types

type DirectoryContent

type DirectoryContent interface {
	// contains filtered or unexported methods
}

func NewDirectoryContent

func NewDirectoryContent(dir string, format parsertimeutil.TimeFormat) (DirectoryContent, error)

func NewDirectoryContentForRsync

func NewDirectoryContentForRsync(dir string, format parsertimeutil.TimeFormat, patterns LogPatterns) (DirectoryContent, error)

type DirectoryImporter

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

func NewDirectoryImporter

func NewDirectoryImporter(
	content DirectoryContent,
	pub postfix.Publisher,
	announcer announcer.ImportAnnouncer,
	sum postfix.SumPair,
	format parsertimeutil.TimeFormat,
	patterns LogPatterns,
	clock timeutil.Clock,
) DirectoryImporter

func (*DirectoryImporter) ImportOnly

func (importer *DirectoryImporter) ImportOnly() error

func (*DirectoryImporter) Run

func (importer *DirectoryImporter) Run() error

type LogPatterns

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

func BuildLogPatterns

func BuildLogPatterns(patterns []string) LogPatterns