Documentation
¶
Overview ¶
Input-plug: fileinput The plug's function is real-time monitoring of the specified file, once the data is updated to record the data.
Index ¶
Constants ¶
View Source
const (
ModuleName = "file"
)
Variables ¶
This section is empty.
Functions ¶
func InitHandler ¶
func InitHandler(confraw *utils.ConfigRaw) (retconf utils.TypeInputConfig, err error)
Init fileinput Handler.
Types ¶
type InputConfig ¶
type InputConfig struct {
utils.InputConfig
Path string `json:"path"`
StartPos string `json:"start_position"`
SincePath string `json:"since_path"`
SinceInterval int `json:"since_interval"`
SinceDBInfos map[string]*SinceDBInfo
SinceLastSaveTime time.Time
// contains filtered or unexported fields
}
Define fileinput' config.
func (*InputConfig) CheckSaveSinceDBInfos ¶
func (self *InputConfig) CheckSaveSinceDBInfos() (err error)
func (*InputConfig) LoadSinceData ¶
func (self *InputConfig) LoadSinceData() (err error)
func (*InputConfig) LoopCheckSaveSinceInfos ¶
func (self *InputConfig) LoopCheckSaveSinceInfos() (err error)
func (*InputConfig) SaveSinceDBInfos ¶
func (self *InputConfig) SaveSinceDBInfos() (err error)
func (*InputConfig) Start ¶
func (ic *InputConfig) Start()
Input's start,and this is the main function of input.
type SinceDBInfo ¶
type SinceDBInfo struct {
Offset int64 `json:"offset"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.