datareceivers

Documentation

Index

• func NewDataDogDataReceiver() testbed.DataReceiver
• func NewJaegerDataReceiver(port int) testbed.DataReceiver
• func NewOCDataReceiver(port int) testbed.DataReceiver
• func NewPrometheusDataReceiver(port int) testbed.DataReceiver
• func NewZipkinDataReceiver(port int) testbed.DataReceiver
• type CarbonDataReceiver
  • func NewCarbonDataReceiver(port int) *CarbonDataReceiver
  • func (cr *CarbonDataReceiver) GenConfigYAMLStr() string
  • func (cr *CarbonDataReceiver) ProtocolName() string
  • func (cr *CarbonDataReceiver) Start(_ consumer.Traces, mc consumer.Metrics, _ consumer.Logs) error
  • func (cr *CarbonDataReceiver) Stop() error
• type SFxMetricsDataReceiver
  • func NewSFxMetricsDataReceiver(port int) *SFxMetricsDataReceiver
  • func (sr *SFxMetricsDataReceiver) GenConfigYAMLStr() string
  • func (sr *SFxMetricsDataReceiver) ProtocolName() string
  • func (sr *SFxMetricsDataReceiver) Start(_ consumer.Traces, mc consumer.Metrics, _ consumer.Logs) error
  • func (sr *SFxMetricsDataReceiver) Stop() error
• type SapmDataReceiver
  • func NewSapmDataReceiver(port int, compression string) *SapmDataReceiver
  • func (sr *SapmDataReceiver) GenConfigYAMLStr() string
  • func (sr *SapmDataReceiver) ProtocolName() string
  • func (sr *SapmDataReceiver) Start(tc consumer.Traces, _ consumer.Metrics, _ consumer.Logs) error
  • func (sr *SapmDataReceiver) Stop() error
• type SplunkHECDataReceiver
  • func NewSplunkHECDataReceiver(port int) *SplunkHECDataReceiver
  • func (sr *SplunkHECDataReceiver) GenConfigYAMLStr() string
  • func (sr *SplunkHECDataReceiver) ProtocolName() string
  • func (sr *SplunkHECDataReceiver) Start(_ consumer.Traces, _ consumer.Metrics, lc consumer.Logs) error
  • func (sr *SplunkHECDataReceiver) Stop() error
• type SyslogDataReceiver
  • func NewSyslogDataReceiver(protocol string, port int) *SyslogDataReceiver
  • func (cr *SyslogDataReceiver) GenConfigYAMLStr() string
  • func (cr *SyslogDataReceiver) ProtocolName() string
  • func (cr *SyslogDataReceiver) Start(_ consumer.Traces, _ consumer.Metrics, lc consumer.Logs) error
  • func (cr *SyslogDataReceiver) Stop() error

Functions

func NewDataDogDataReceiver

func NewDataDogDataReceiver() testbed.DataReceiver

NewDataDogDataReceiver creates a new DD DataReceiver that will listen on the specified port after Start is called.

func NewJaegerDataReceiver

func NewJaegerDataReceiver(port int) testbed.DataReceiver

NewJaegerDataReceiver creates a new Jaeger DataReceiver that will listen on the specified port after Start is called.

func NewOCDataReceiver

func NewOCDataReceiver(port int) testbed.DataReceiver

NewOCDataReceiver creates a new ocDataReceiver that will listen on the specified port after Start is called.

func NewPrometheusDataReceiver

func NewPrometheusDataReceiver(port int) testbed.DataReceiver

func NewZipkinDataReceiver

func NewZipkinDataReceiver(port int) testbed.DataReceiver

NewZipkinDataReceiver creates a new Zipkin DataReceiver that will listen on the specified port after Start is called.

Types

type CarbonDataReceiver

type CarbonDataReceiver struct {
	testbed.DataReceiverBase
	// contains filtered or unexported fields
}

CarbonDataReceiver implements Carbon format receiver.

func NewCarbonDataReceiver

func NewCarbonDataReceiver(port int) *CarbonDataReceiver

NewCarbonDataReceiver creates a new CarbonDataReceiver that will listen on the specified port after Start is called.

func (*CarbonDataReceiver) GenConfigYAMLStr

func (cr *CarbonDataReceiver) GenConfigYAMLStr() string

GenConfigYAMLStr returns exporter config for the agent.

func (*CarbonDataReceiver) ProtocolName

func (cr *CarbonDataReceiver) ProtocolName() string

ProtocolName returns protocol name as it is specified in Collector config.

func (*CarbonDataReceiver) Start

func (cr *CarbonDataReceiver) Start(_ consumer.Traces, mc consumer.Metrics, _ consumer.Logs) error

Start the receiver.

func (*CarbonDataReceiver) Stop

func (cr *CarbonDataReceiver) Stop() error

Stop the receiver.

type SFxMetricsDataReceiver

type SFxMetricsDataReceiver struct {
	testbed.DataReceiverBase
	// contains filtered or unexported fields
}

SFxMetricsDataReceiver implements SignalFx format receiver.

func NewSFxMetricsDataReceiver

func NewSFxMetricsDataReceiver(port int) *SFxMetricsDataReceiver

NewSFxMetricsDataReceiver creates a new SFxMetricsDataReceiver that will listen on the specified port after Start is called.

func (*SFxMetricsDataReceiver) GenConfigYAMLStr

func (sr *SFxMetricsDataReceiver) GenConfigYAMLStr() string

GenConfigYAMLStr returns exporter config for the agent.

func (*SFxMetricsDataReceiver) ProtocolName

func (sr *SFxMetricsDataReceiver) ProtocolName() string

ProtocolName returns protocol name as it is specified in Collector config.

func (*SFxMetricsDataReceiver) Start

func (sr *SFxMetricsDataReceiver) Start(_ consumer.Traces, mc consumer.Metrics, _ consumer.Logs) error

Start the receiver.

func (*SFxMetricsDataReceiver) Stop

func (sr *SFxMetricsDataReceiver) Stop() error

Stop the receiver.

type SapmDataReceiver

type SapmDataReceiver struct {
	testbed.DataReceiverBase
	// contains filtered or unexported fields
}

SapmDataReceiver implements Sapm format receiver.

func NewSapmDataReceiver

func NewSapmDataReceiver(port int, compression string) *SapmDataReceiver

NewSapmDataReceiver creates a new SapmDataReceiver.

func (*SapmDataReceiver) GenConfigYAMLStr

func (sr *SapmDataReceiver) GenConfigYAMLStr() string

GenConfigYAMLStr returns exporter config for the agent.

func (*SapmDataReceiver) ProtocolName

func (sr *SapmDataReceiver) ProtocolName() string

ProtocolName returns protocol name as it is specified in Collector config.

func (*SapmDataReceiver) Start

func (sr *SapmDataReceiver) Start(tc consumer.Traces, _ consumer.Metrics, _ consumer.Logs) error

Start the receiver.

func (*SapmDataReceiver) Stop

func (sr *SapmDataReceiver) Stop() error

Stop the receiver.

type SplunkHECDataReceiver

type SplunkHECDataReceiver struct {
	testbed.DataReceiverBase
	// contains filtered or unexported fields
}

SplunkHECDataReceiver implements Splunk HEC format receiver.

func NewSplunkHECDataReceiver

func NewSplunkHECDataReceiver(port int) *SplunkHECDataReceiver

NewSplunkHECDataReceiver creates a new SplunkHECDataReceiver that will listen on the specified port after Start is called.

func (*SplunkHECDataReceiver) GenConfigYAMLStr

func (sr *SplunkHECDataReceiver) GenConfigYAMLStr() string

GenConfigYAMLStr returns exporter config for the agent.

func (*SplunkHECDataReceiver) ProtocolName

func (sr *SplunkHECDataReceiver) ProtocolName() string

ProtocolName returns protocol name as it is specified in Collector config.

func (*SplunkHECDataReceiver) Start

func (sr *SplunkHECDataReceiver) Start(_ consumer.Traces, _ consumer.Metrics, lc consumer.Logs) error

Start the receiver.

func (*SplunkHECDataReceiver) Stop

func (sr *SplunkHECDataReceiver) Stop() error

Stop the receiver.

type SyslogDataReceiver

type SyslogDataReceiver struct {
	testbed.DataReceiverBase
	// contains filtered or unexported fields
}

SyslogDataReceiver implements Syslog format receiver.

func NewSyslogDataReceiver

func NewSyslogDataReceiver(protocol string, port int) *SyslogDataReceiver

NewSyslogDataReceiver creates a new SyslogDataReceiver that will listen on the specified port after Start is called.

func (*SyslogDataReceiver) GenConfigYAMLStr

func (cr *SyslogDataReceiver) GenConfigYAMLStr() string

GenConfigYAMLStr returns receiver config for the agent.

func (*SyslogDataReceiver) ProtocolName

func (cr *SyslogDataReceiver) ProtocolName() string

ProtocolName returns protocol name as it is specified in Collector config.

func (*SyslogDataReceiver) Start

func (cr *SyslogDataReceiver) Start(_ consumer.Traces, _ consumer.Metrics, lc consumer.Logs) error

Start the receiver.

func (*SyslogDataReceiver) Stop

func (cr *SyslogDataReceiver) Stop() error

Stop the receiver.