parser

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 GenericReceiver
  • func (g *GenericReceiver) ParserName() string
  • func (g *GenericReceiver) Ports() ([]corev1.ServicePort, error)
• type JaegerReceiverParser
  • func (j *JaegerReceiverParser) ParserName() string
  • func (j *JaegerReceiverParser) Ports() ([]corev1.ServicePort, error)
• type OTLPReceiverParser
  • func (o *OTLPReceiverParser) ParserName() string
  • func (o *OTLPReceiverParser) Ports() ([]corev1.ServicePort, error)
• type ReceiverParser
  • func For(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewCarbonReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewCollectdReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewGenericReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewJaegerReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewOTLPReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewOpenCensusReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewSAPMReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewSignalFxReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewWavefrontReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewZipkinReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewZipkinScribeReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser

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{}) ReceiverParser

Builder specifies the signature required for parser builders

func BuilderFor

func BuilderFor(name string) Builder

BuilderFor returns a parser builder for the given receiver name

type GenericReceiver

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

GenericReceiver is a special parser for generic receivers. It doesn't self-register and should be created/used directly

func (*GenericReceiver) ParserName

func (g *GenericReceiver) ParserName() string

ParserName returns the name of this parser

func (*GenericReceiver) Ports

func (g *GenericReceiver) Ports() ([]corev1.ServicePort, error)

Ports returns all the service ports for all protocols in this parser

type JaegerReceiverParser

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

JaegerReceiverParser parses the configuration for Jaeger-specific receivers

func (*JaegerReceiverParser) ParserName

func (j *JaegerReceiverParser) ParserName() string

ParserName returns the name of this parser

func (*JaegerReceiverParser) Ports

func (j *JaegerReceiverParser) Ports() ([]corev1.ServicePort, error)

Ports returns all the service ports for all protocols in this parser

type OTLPReceiverParser

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

OTLPReceiverParser parses the configuration for OTLP receivers

func (*OTLPReceiverParser) ParserName

func (o *OTLPReceiverParser) ParserName() string

ParserName returns the name of this parser

func (*OTLPReceiverParser) Ports

func (o *OTLPReceiverParser) Ports() ([]corev1.ServicePort, error)

Ports returns all the service ports for all protocols in this parser

type ReceiverParser

type ReceiverParser interface {
	// Ports returns the service ports parsed based on the receiver's configuration
	Ports() ([]corev1.ServicePort, error)

	// ParserName returns the name of this parser
	ParserName() string
}

ReceiverParser is an interface that should be implemented by all receiver parsers

func For

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

For returns a new parser for the given receiver name + config

func NewCarbonReceiverParser

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

NewCarbonReceiverParser builds a new parser for Carbon receivers, from the contrib repository

func NewCollectdReceiverParser

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

NewCollectdReceiverParser builds a new parser for Collectd receivers, from the contrib repository

func NewGenericReceiverParser

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

NewGenericReceiverParser builds a new parser for generic receivers

func NewJaegerReceiverParser

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

NewJaegerReceiverParser builds a new parser for Jaeger receivers

func NewOTLPReceiverParser

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

NewOTLPReceiverParser builds a new parser for OTLP receivers

func NewOpenCensusReceiverParser

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

NewOpenCensusReceiverParser builds a new parser for OpenCensus receivers

func NewSAPMReceiverParser

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

NewSAPMReceiverParser builds a new parser for SAPM receivers, from the contrib repository

func NewSignalFxReceiverParser

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

NewSignalFxReceiverParser builds a new parser for SignalFx receivers, from the contrib repository

func NewWavefrontReceiverParser

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

NewWavefrontReceiverParser builds a new parser for Wavefront receivers, from the contrib repository

func NewZipkinReceiverParser

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

NewZipkinReceiverParser builds a new parser for Zipkin receivers

func NewZipkinScribeReceiverParser

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

NewZipkinScribeReceiverParser builds a new parser for ZipkinScribe receivers