Documentation
¶
Index ¶
- func HashID(metric telegraf.Metric) uint64
- type DirDefObject
- func (ddo DirDefObject) AddToRtQueue(fileName string)
- func (ddo DirDefObject) FileProcessor(id int)
- func (ddo DirDefObject) HistoryHandler(dir string, files []string)
- func (ddo *DirDefObject) IsDirExclude(strMatch string) bool
- func (ddo *DirDefObject) IsDirInclude(strMatch string) bool
- func (ddo *DirDefObject) IsDirMatch(strMatch string) bool
- func (ddo *DirDefObject) IsFileExclude(strMatch string) bool
- func (ddo *DirDefObject) IsFileInclude(strMatch string) bool
- func (ddo *DirDefObject) IsFileMatch(strMatch string) bool
- func (ddo *DirDefObject) OSReadDir(root string) (map[string][]string, error)
- func (ddo *DirDefObject) ProcessFile(id int, fileName string, acc telegraf.Accumulator) error
- func (ddo DirDefObject) RealtimeHandler(dir string)
- func (ddo DirDefObject) Start(acc telegraf.Accumulator, parser parsers.Parser, ...) error
- type DirMon
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DirDefObject ¶
type DirDefObject struct {
Directory string
DirInclude []string
DirExclude []string
FileInclude []string
FileExclude []string
NumProcessors int
FieldReplace map[string]string
FileRegex map[string]string
FileTagRegex map[string]string
MetricTagRegex map[string]string
TempExtension string
// contains filtered or unexported fields
}
func (DirDefObject) AddToRtQueue ¶
func (ddo DirDefObject) AddToRtQueue(fileName string)
func (DirDefObject) FileProcessor ¶
func (ddo DirDefObject) FileProcessor(id int)
func (DirDefObject) HistoryHandler ¶
func (ddo DirDefObject) HistoryHandler(dir string, files []string)
func (*DirDefObject) IsDirExclude ¶
func (ddo *DirDefObject) IsDirExclude(strMatch string) bool
func (*DirDefObject) IsDirInclude ¶
func (ddo *DirDefObject) IsDirInclude(strMatch string) bool
func (*DirDefObject) IsDirMatch ¶
func (ddo *DirDefObject) IsDirMatch(strMatch string) bool
func (*DirDefObject) IsFileExclude ¶
func (ddo *DirDefObject) IsFileExclude(strMatch string) bool
func (*DirDefObject) IsFileInclude ¶
func (ddo *DirDefObject) IsFileInclude(strMatch string) bool
func (*DirDefObject) IsFileMatch ¶
func (ddo *DirDefObject) IsFileMatch(strMatch string) bool
func (*DirDefObject) OSReadDir ¶
func (ddo *DirDefObject) OSReadDir(root string) (map[string][]string, error)
func (*DirDefObject) ProcessFile ¶
func (ddo *DirDefObject) ProcessFile(id int, fileName string, acc telegraf.Accumulator) error
func (DirDefObject) RealtimeHandler ¶
func (ddo DirDefObject) RealtimeHandler(dir string)
func (DirDefObject) Start ¶
func (ddo DirDefObject) Start(acc telegraf.Accumulator, parser parsers.Parser, gFieldReplace map[string]string) error
type DirMon ¶
type DirMon struct {
Directory []DirDefObject
FieldReplace map[string]string
parsers.Parser
// contains filtered or unexported fields
}
func (*DirMon) Description ¶
func (*DirMon) SampleConfig ¶
Click to show internal directories.
Click to hide internal directories.