Documentation ¶
Index ¶
- Constants
- Variables
- func InitHandler(ctx context.Context, raw config.ConfigRaw, control config.Control) (config.TypeInputConfig, error)
- type InputConfig
- func (t *InputConfig) CheckSaveSinceDBInfos() (err error)
- func (t *InputConfig) CheckSaveSinceDBInfosLoop(ctx context.Context) (err error)
- func (self *InputConfig) LoadSinceDBInfos() (err error)
- func (self *InputConfig) SaveSinceDBInfos() (err error)
- func (t *InputConfig) Start(ctx context.Context, msgChan chan<- logevent.LogEvent) (err error)
- type SinceDBInfo
Constants ¶
View Source
const ModuleName = "file"
ModuleName is the name used in config file
Variables ¶
View Source
var (
ErrorGlobFailed1 = errutil.NewFactory("glob(%q) failed")
)
errors
Functions ¶
Types ¶
type InputConfig ¶
type InputConfig struct { config.InputConfig Path string `json:"path"` StartPos string `json:"start_position,omitempty"` // one of ["beginning", "end"] SinceDBPath string `json:"sincedb_path,omitempty"` SinceDBWriteInterval int `json:"sincedb_write_interval,omitempty"` SinceDBInfos map[string]*SinceDBInfo `json:"-"` SinceDBLastSaveTime time.Time `json:"-"` // contains filtered or unexported fields }
InputConfig holds the configuration json fields and internal objects
func DefaultInputConfig ¶
func DefaultInputConfig() InputConfig
DefaultInputConfig returns an InputConfig struct with default values
func (*InputConfig) CheckSaveSinceDBInfos ¶
func (t *InputConfig) CheckSaveSinceDBInfos() (err error)
func (*InputConfig) CheckSaveSinceDBInfosLoop ¶
func (t *InputConfig) CheckSaveSinceDBInfosLoop(ctx context.Context) (err error)
func (*InputConfig) LoadSinceDBInfos ¶
func (self *InputConfig) LoadSinceDBInfos() (err error)
func (*InputConfig) SaveSinceDBInfos ¶
func (self *InputConfig) SaveSinceDBInfos() (err error)
type SinceDBInfo ¶
type SinceDBInfo struct {
Offset int64 `json:"offset,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.