receiver

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 NewAWSXrayReceiverParser(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 NewFluentForwardReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewGenericReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewInfluxdbReceiverParser(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 NewSkywalkingReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewSplunkHecReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser
  • func NewStatsdReceiverParser(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
• type SkywalkingReceiverParser
  • func (o *SkywalkingReceiverParser) ParserName() string
  • func (o *SkywalkingReceiverParser) Ports() ([]corev1.ServicePort, error)

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 NewAWSXrayReceiverParser

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

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

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

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

NewGenericReceiverParser builds a new parser for generic receivers.

func NewInfluxdbReceiverParser

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

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

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

NewSkywalkingReceiverParser builds a new parser for Skywalking receivers.

func NewSplunkHecReceiverParser

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

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

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

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.