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
- type SFxMetricsDataReceiver
- type SapmDataReceiver
- type SplunkHECDataReceiver
- type SyslogDataReceiver
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataDogDataReceiver ¶ added in v0.71.0
func NewDataDogDataReceiver() testbed.DataReceiver
NewDataDogDataReceiver creates a new DD DataReceiver that will listen on the specified port after Start is called.
func NewJaegerDataReceiver ¶ added in v0.34.0
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 ¶ added in v0.34.0
func NewOCDataReceiver(port int) testbed.DataReceiver
NewOCDataReceiver creates a new ocDataReceiver that will listen on the specified port after Start is called.
func NewPrometheusDataReceiver ¶ added in v0.34.0
func NewPrometheusDataReceiver(port int) testbed.DataReceiver
func NewZipkinDataReceiver ¶ added in v0.34.0
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.
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.
type SplunkHECDataReceiver ¶ added in v0.24.0
type SplunkHECDataReceiver struct {
testbed.DataReceiverBase
// contains filtered or unexported fields
}
SplunkHECDataReceiver implements Splunk HEC format receiver.
func NewSplunkHECDataReceiver ¶ added in v0.24.0
func NewSplunkHECDataReceiver(port int) *SplunkHECDataReceiver
NewSplunkHECDataReceiver creates a new SplunkHECDataReceiver that will listen on the specified port after Start is called.
func (*SplunkHECDataReceiver) GenConfigYAMLStr ¶ added in v0.24.0
func (sr *SplunkHECDataReceiver) GenConfigYAMLStr() string
GenConfigYAMLStr returns exporter config for the agent.
func (*SplunkHECDataReceiver) ProtocolName ¶ added in v0.24.0
func (sr *SplunkHECDataReceiver) ProtocolName() string
ProtocolName returns protocol name as it is specified in Collector config.
func (*SplunkHECDataReceiver) Start ¶ added in v0.24.0
func (sr *SplunkHECDataReceiver) Start(_ consumer.Traces, _ consumer.Metrics, lc consumer.Logs) error
Start the receiver.
func (*SplunkHECDataReceiver) Stop ¶ added in v0.24.0
func (sr *SplunkHECDataReceiver) Stop() error
Stop the receiver.
type SyslogDataReceiver ¶ added in v0.88.0
type SyslogDataReceiver struct {
testbed.DataReceiverBase
// contains filtered or unexported fields
}
SyslogDataReceiver implements Syslog format receiver.
func NewSyslogDataReceiver ¶ added in v0.88.0
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 ¶ added in v0.88.0
func (cr *SyslogDataReceiver) GenConfigYAMLStr() string
GenConfigYAMLStr returns receiver config for the agent.
func (*SyslogDataReceiver) ProtocolName ¶ added in v0.88.0
func (cr *SyslogDataReceiver) ProtocolName() string
ProtocolName returns protocol name as it is specified in Collector config.
func (*SyslogDataReceiver) Stop ¶ added in v0.88.0
func (cr *SyslogDataReceiver) Stop() error
Stop the receiver.
Source Files