processor

Documentation

Overview

Package parser is for parsing the OpenTelemetry Collector configuration.

Index

• func IsRegistered(name string) bool
• func Register(name string, builder Builder)
• type Builder
  • func BuilderFor(name string) Builder
• type K8sAttributesParser
  • func (o *K8sAttributesParser) GetRBACRules() []rbacv1.PolicyRule
  • func (o *K8sAttributesParser) ParserName() string
• type ProcessorParser
  • func For(logger logr.Logger, name string, config map[interface{}]interface{}) (ProcessorParser, error)
  • func NewK8sAttributesParser(logger logr.Logger, name string, config map[interface{}]interface{}) ProcessorParser
  • func NewResourceDetectionParser(logger logr.Logger, name string, config map[interface{}]interface{}) ProcessorParser
• type ResourceDetectionParser
  • func (o *ResourceDetectionParser) GetRBACRules() []rbacv1.PolicyRule
  • func (o *ResourceDetectionParser) ParserName() string

Functions

func IsRegistered

func IsRegistered(name string) bool

IsRegistered checks whether a parser is registered with the given name.

func Register

func Register(name string, builder Builder)

Register adds a new parser builder to the list of known builders.

Types

type Builder

type Builder func(logr.Logger, string, map[interface{}]interface{}) ProcessorParser

Builder specifies the signature required for parser builders.

func BuilderFor

func BuilderFor(name string) Builder

BuilderFor returns a parser builder for the given processor name.

type K8sAttributesParser

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

PrometheusExporterParser parses the configuration for k8sattributes processor.

func (*K8sAttributesParser) GetRBACRules

func (o *K8sAttributesParser) GetRBACRules() []rbacv1.PolicyRule

func (*K8sAttributesParser) ParserName

func (o *K8sAttributesParser) ParserName() string

ParserName returns the name of this parser.

type ProcessorParser

type ProcessorParser interface {
	ParserName() string
	GetRBACRules() []rbacv1.PolicyRule
}

ProcessorParser specifies the methods to implement to parse a processor.

func For

func For(logger logr.Logger, name string, config map[interface{}]interface{}) (ProcessorParser, error)

For returns a new parser for the given processor name + config.

func NewK8sAttributesParser

func NewK8sAttributesParser(logger logr.Logger, name string, config map[interface{}]interface{}) ProcessorParser

NewK8sAttributesParser builds a new parser k8sattributes processor.

func NewResourceDetectionParser

func NewResourceDetectionParser(logger logr.Logger, name string, config map[interface{}]interface{}) ProcessorParser

NewPrometheusExporterParser builds a new parser for OTLP receivers.

type ResourceDetectionParser

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

PrometheusExporterParser parses the configuration for OTLP receivers.

func (*ResourceDetectionParser) GetRBACRules

func (o *ResourceDetectionParser) GetRBACRules() []rbacv1.PolicyRule

func (*ResourceDetectionParser) ParserName

func (o *ResourceDetectionParser) ParserName() string

ParserName returns the name of this parser.