file

Documentation

Index

• Constants
• func InitHandler(confraw *utils.ConfigRaw) (retconf utils.TypeInputConfig, err error)
• type InputConfig
  • func (ic *InputConfig) CheckSaveSinceDBInfos() (err error)
  • func (ic *InputConfig) LoadSinceData() (err error)
  • func (ic *InputConfig) LoopCheckSaveSinceInfos(ctx context.Context) (err error)
  • func (ic *InputConfig) SaveSinceDBInfos() (err error)
  • func (ic *InputConfig) Start()
• type SinceDBInfo

Constants

const (
	ModuleName = "file"
)

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"`
}