Documentation
¶
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
DirsPath []string `json:"dirspath"`
FileType string `json:"filetype"`
StartPos string `json:"startpos"`
SincePath string `json:"sincepath"`
Intervals int `json:"intervals"`
SinceDBInfos map[string]*SinceDBInfo
SinceLastSaveTime time.Time
// contains filtered or unexported fields
}
Define fileinput' config.
func (*InputConfig) CheckSaveSinceDBInfos ¶
func (ic *InputConfig) CheckSaveSinceDBInfos() (err error)
check since data info.
func (*InputConfig) LoadSinceData ¶
func (ic *InputConfig) LoadSinceData() (err error)
load current since data.
func (*InputConfig) LoopCheckSaveSinceInfos ¶
func (ic *InputConfig) LoopCheckSaveSinceInfos(ctx context.Context) (err error)
load check save since data
func (*InputConfig) SaveSinceDBInfos ¶
func (ic *InputConfig) SaveSinceDBInfos() (err error)
save since data info.
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.