input

package

v1.0.0 Latest Latest Go to latest Published: Sep 14, 2024 License: MIT Imports: 17 Imported by: 0

Details

Rendered for

View Source

const (
	FilePositionHead = int64(0)
	FilePositionEnd  = int64(-1)
)

View Source

var (
	CounterRead         = uint64(0)  // 计数器，读的行数
	CounterLastOpenFile atomic.Value // 最后一次打开的文件
	ScanTickerDuration  = 5 * time.Second
)

This section is empty.

type FileWatcher struct {
	FileTail *tail.Tail

	File *file.File
	// contains filtered or unexported fields
}

func NewFileWatcher(f *file.File) (fw *FileWatcher, err error)

func (fw *FileWatcher) Restart() error

func (fw *FileWatcher) Start()

type Input struct {
	WatchFiles sync.Map // 所有打开的文件 <filename, *FileWatcher>
	// contains filtered or unexported fields
}

Input task data

var SingleInstance *Input // Input模块

func New(ctx context.Context, conf map[string]*keyword.TaskConfig, states []file.State) (*Input, error)

New construct a new input

func (client *Input) AddInput(_ <-chan interface{})

func (client *Input) AddOutput(_ chan<- interface{})

func (client *Input) ID() string

func (client *Input) Reload(_ interface{})

Reload reload task

func (client *Input) Start() error

func (client *Input) Stop()

Stop stops the input and with it all harvesters

func (client *Input) Wait()

Wait wg.wait for task

Path	Synopsis
file