metricbeat

Documentation

Index

• func New(globalConfig define.Config, taskConfig define.TaskConfig) define.Task
• type Gather
  • func (g *Gather) Run(ctx context.Context, e chan<- define.Event)
• type Tool
  • func (t *Tool) Init(mbConfig *configs.MetricBeatConfig, globalConf define.Config, ...) error
  • func (t *Tool) KeepOneDimension(name string, data common.MapStr)
  • func (t *Tool) Run(ctx context.Context, e chan<- define.Event) error

Functions

func New

func New(globalConfig define.Config, taskConfig define.TaskConfig) define.Task

Types

type Gather

type Gather struct {
	tasks.BaseTask
	// contains filtered or unexported fields
}

func (*Gather) Run

func (g *Gather) Run(ctx context.Context, e chan<- define.Event)

type Tool

type Tool struct {
	// contains filtered or unexported fields
}

func (*Tool) Init

func (t *Tool) Init(mbConfig *configs.MetricBeatConfig, globalConf define.Config, taskConf define.TaskConfig) error

Init 初始化参数 处理配置文件中的 modules

func (*Tool) KeepOneDimension

func (t *Tool) KeepOneDimension(name string, data common.MapStr)

KeepOneDimension 只在测试模式 && Prometheus场景需要这么处理 指标名+维度字段名 作为唯一的key 不同维度值只保留一个，但是如果有多的维度名，那么需要保留

func (*Tool) Run

func (t *Tool) Run(ctx context.Context, e chan<- define.Event) error