receiver

Documentation

Overview

Package parser is for parsing the OpenTelemetry Collector configuration.

Index

• func BuilderFor(name string) parser.Builder
• func For(logger logr.Logger, name string, config map[interface{}]interface{}) (parser.ComponentPortParser, error)
• func IsRegistered(name string) bool
• func NewAWSXrayReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewCarbonReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewCollectdReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewFluentForwardReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewGenericReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewInfluxdbReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewJaegerReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewOTLPReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewOpenCensusReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewSAPMReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewSignalFxReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewSkywalkingReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewSplunkHecReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewStatsdReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewWavefrontReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewZipkinReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func NewZipkinScribeReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser
• func Register(name string, builder parser.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 SkywalkingReceiverParser
  • func (o *SkywalkingReceiverParser) ParserName() string
  • func (o *SkywalkingReceiverParser) Ports() ([]corev1.ServicePort, error)

Functions

func BuilderFor

func BuilderFor(name string) parser.Builder

BuilderFor returns a parser builder for the given receiver name.

func For

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

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

func IsRegistered

func IsRegistered(name string) bool

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

func NewAWSXrayReceiverParser

func NewAWSXrayReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser

NewAWSXrayReceiverParser builds a new parser for AWS xray receivers, from the contrib repository.

func NewCarbonReceiverParser

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

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{}) parser.ComponentPortParser

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

func NewFluentForwardReceiverParser

func NewFluentForwardReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser

NewFluentForwardReceiverParser builds a new parser for FluentForward receivers, from the contrib repository.

func NewGenericReceiverParser

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

NewGenericReceiverParser builds a new parser for generic receivers.

func NewInfluxdbReceiverParser

func NewInfluxdbReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser

NewInfluxdbReceiverParser builds a new parser for Influxdb receivers, from the contrib repository.

func NewJaegerReceiverParser

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

NewJaegerReceiverParser builds a new parser for Jaeger receivers.

func NewOTLPReceiverParser

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

NewOTLPReceiverParser builds a new parser for OTLP receivers.

func NewOpenCensusReceiverParser

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

NewOpenCensusReceiverParser builds a new parser for OpenCensus receivers.

func NewSAPMReceiverParser

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

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{}) parser.ComponentPortParser

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

func NewSkywalkingReceiverParser

func NewSkywalkingReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser

NewSkywalkingReceiverParser builds a new parser for Skywalking receivers.

func NewSplunkHecReceiverParser

func NewSplunkHecReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser

NewSplunkHecReceiverParser builds a new parser for Splunk Hec receivers, from the contrib repository.

func NewStatsdReceiverParser

func NewStatsdReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) parser.ComponentPortParser

NewStatsdReceiverParser builds a new parser for Statsd receivers, from the contrib repository.

func NewWavefrontReceiverParser

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

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{}) parser.ComponentPortParser

NewZipkinReceiverParser builds a new parser for Zipkin receivers.

func NewZipkinScribeReceiverParser

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

NewZipkinScribeReceiverParser builds a new parser for ZipkinScribe receivers.

func Register

func Register(name string, builder parser.Builder)

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

Types

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 SkywalkingReceiverParser

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

SkywalkingReceiverParser parses the configuration for Skywalking receivers.

func (*SkywalkingReceiverParser) ParserName

func (o *SkywalkingReceiverParser) ParserName() string

ParserName returns the name of this parser.

func (*SkywalkingReceiverParser) Ports

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

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