receiver

Documentation

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 NewGenericReceiverParser(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 NewStatsdReceiverParser(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 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)

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 NewGenericReceiverParser

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

NewGenericReceiverParser builds a new parser for generic receivers.

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 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 NewZipkinReceiverParser

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

NewZipkinReceiverParser builds a new parser for Zipkin 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.