processor

Documentation

Index

• func RemoveProcessors(id string)
• type Processors
  • func GetProcessors(taskCfg *config.TaskConfig, taskNode *base.TaskNode) (*Processors, error)
  • func NewProcessors(taskCfg *config.TaskConfig, taskNode *base.TaskNode) (*Processors, error)
  • func (p *Processors) Handle(event *beat.Event) *beat.Event
  • func (p *Processors) MergeProcessorsConfig(taskCfg *config.TaskConfig) error
  • func (p *Processors) Run()

Functions

func RemoveProcessors

func RemoveProcessors(id string)

RemoveProcessors 移除全局缓存

Types

type Processors

type Processors struct {
	*base.Node
	// contains filtered or unexported fields
}

Processors 兼容数据平台过滤规则

func GetProcessors

func GetProcessors(taskCfg *config.TaskConfig, taskNode *base.TaskNode) (*Processors, error)

GetProcessors 获取processor

func NewProcessors

func NewProcessors(taskCfg *config.TaskConfig, taskNode *base.TaskNode) (*Processors, error)

NewProcessors 新建processor

func (*Processors) Handle

func (p *Processors) Handle(event *beat.Event) *beat.Event

Handle 处理采集事件

func (*Processors) MergeProcessorsConfig

func (p *Processors) MergeProcessorsConfig(taskCfg *config.TaskConfig) error

MergeProcessorsConfig 合并多个任务的Processor配置 理论上Merge这里不存在任何动作，因为Processor的配置是一样的

func (*Processors) Run

func (p *Processors) Run()

Run 循环处理数据