nodemetricprocessor

Documentation

Index

• Constants
• func New(config interface{}, telemetry *component.TelemetryTools, ...) processor.Processor
• type Config
• type NodeMetricProcessor
  • func (p *NodeMetricProcessor) Consume(dataGroup *model.DataGroup) error

Constants

const (
	Type = "nodemetricprocessor"
)

Functions

func New

func New(config interface{}, telemetry *component.TelemetryTools, nextConsumer consumer.Consumer) processor.Processor

Types

type Config

type Config struct {
}

type NodeMetricProcessor

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

func (*NodeMetricProcessor) Consume

func (p *NodeMetricProcessor) Consume(dataGroup *model.DataGroup) error