input

Documentation

Index

• func ConnectToTask(in *Input) channel.Connector
• func RemoveInput(id string)
• type ContainerStdoutFields
• type Input
  • func GetInput(taskCfg *config.TaskConfig, taskNode *base.TaskNode, beatDone chan struct{}, ...) (*Input, error)
  • func NewInput(taskCfg *config.TaskConfig, taskNode *base.TaskNode, beatDone chan struct{}, ...) (*Input, error)
  • func (in *Input) Close() error
  • func (in *Input) Done() <-chan struct{}
  • func (in *Input) OnEvent(data *util.Data) bool
  • func (in *Input) Reload()
  • func (in *Input) Run()
  • func (in *Input) Start()

Functions

func ConnectToTask

func ConnectToTask(in *Input) channel.Connector

ConnectToTask 返回任务实例，用于接收采集事件 OnEvent

func RemoveInput

func RemoveInput(id string)

RemoveInput : 移除全局缓存

Types

type ContainerStdoutFields

type ContainerStdoutFields struct {
	Log    string `json:"log"`
	Stream string `json:"stream"`
	Time   string `json:"time"`
}

ContainerStdoutFields container 标准输出字段

type Input

type Input struct {
	*base.Node

	IsContainerStd    bool
	IsCRIContainerStd bool
	// contains filtered or unexported fields
}

func GetInput

func GetInput(
	taskCfg *config.TaskConfig,
	taskNode *base.TaskNode,
	beatDone chan struct{},
	states []file.State,
) (*Input, error)

func NewInput

func NewInput(
	taskCfg *config.TaskConfig,
	taskNode *base.TaskNode,
	beatDone chan struct{},
	states []file.State,
) (*Input, error)

func (*Input) Close

func (in *Input) Close() error

Close 由Filebeat在停止采集插件后调用

func (*Input) Done

func (in *Input) Done() <-chan struct{}

Done 返回任务状态channel

func (*Input) OnEvent

func (in *Input) OnEvent(data *util.Data) bool

OnEvent 处理input runner发送的事件

func (*Input) Reload

func (in *Input) Reload()

Reload : Input不做reload处理，配置如果有变化，直接删除新建

func (*Input) Run

func (in *Input) Run()

func (*Input) Start

func (in *Input) Start()

Start 启动runner 创建后则自动启动