datasenders

package
v0.100.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 6, 2024 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDatadogDataSender added in v0.71.0 

func NewDatadogDataSender() testbed.TraceDataSender

NewDatadogDataSender creates a new Zipkin exporter sender that will send to the specified port after Start is called.

func NewJaegerGRPCDataSender added in v0.34.0 

func NewJaegerGRPCDataSender(host string, port int) testbed.TraceDataSender

NewJaegerGRPCDataSender creates a new Jaeger exporter sender that will send to the specified port after Start is called.

func NewLocalFileStorageExtension added in v0.25.0 

func NewLocalFileStorageExtension() map[string]string

func NewOCMetricDataSender added in v0.34.0 

func NewOCMetricDataSender(host string, port int) testbed.MetricDataSender

NewOCMetricDataSender creates a new OpenCensus metric exporter sender that will send to the specified port after Start is called.

func NewOCTraceDataSender added in v0.34.0 

func NewOCTraceDataSender(host string, port int) testbed.TraceDataSender

NewOCTraceDataSender creates a new ocTracesDataSender that will send to the specified port after Start is called.

func NewPrometheusDataSender added in v0.34.0 

func NewPrometheusDataSender(host string, port int) testbed.MetricDataSender

NewPrometheusDataSender creates a new Prometheus sender that will expose data on the specified port after Start is called.

func NewZipkinDataSender added in v0.34.0 

func NewZipkinDataSender(host string, port int) testbed.TraceDataSender

NewZipkinDataSender creates a new Zipkin exporter sender that will send to the specified port after Start is called.

Types

type CarbonDataSender 

type CarbonDataSender struct {
	testbed.DataSenderBase
	consumer.Metrics
}

CarbonDataSender implements MetricDataSender for Carbon metrics protocol.

func NewCarbonDataSender 

func NewCarbonDataSender(port int) *CarbonDataSender

NewCarbonDataSender creates a new Carbon metric protocol sender that will send to the specified port after Start is called.

func (*CarbonDataSender) GenConfigYAMLStr 

func (cs *CarbonDataSender) GenConfigYAMLStr() string

GenConfigYAMLStr returns receiver config for the agent.

func (*CarbonDataSender) ProtocolName 

func (cs *CarbonDataSender) ProtocolName() string

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

func (*CarbonDataSender) Start 

func (cs *CarbonDataSender) Start() error

Start the sender.

type FileLogK8sWriter added in v0.22.0 

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

FileLogK8sWriter represents abstract container k8s writer

func NewCRIContainerdWriter added in v0.22.0 

func NewCRIContainerdWriter() *FileLogK8sWriter

NewCRIContainerdWriter returns FileLogK8sWriter with configuration to parse only CRI-Containerd logs (no extracting metadata from filename)

func NewFileLogK8sWriter added in v0.22.0 

func NewFileLogK8sWriter(config string) *FileLogK8sWriter

NewFileLogK8sWriter creates a new data sender that will write kubernetes containerd log entries to a file, to be tailed by FileLogReceiver and sent to the collector.

config is an Otelcol config appended to the receivers section after executing fmt.Sprintf on it. This implies few things:

  • it should contain `%s` which will be replaced with the filename
  • all `%` should be represented as `%%`
  • indentation style matters. Spaces have to be used for indentation and it should start with two spaces indentation

Example config: |` | filelog: | include: [ %s ] | start_at: beginning | operators: | type: regex_parser | regex: ^(?P<log>.*)$ | `

func NewKubernetesCRIContainerdNoAttributesOpsWriter added in v0.22.0 

func NewKubernetesCRIContainerdNoAttributesOpsWriter() *FileLogK8sWriter

NewKubernetesCRIContainerdNoAttributesOpsWriter returns FileLogK8sWriter with configuration to parse only CRI-Containerd kubernetes logs without reformatting attributes

func NewKubernetesCRIContainerdWriter added in v0.22.0 

func NewKubernetesCRIContainerdWriter() *FileLogK8sWriter

NewKubernetesCRIContainerdWriter returns FileLogK8sWriter with configuration to parse only CRI-Containerd kubernetes logs

func NewKubernetesContainerWriter added in v0.22.0 

func NewKubernetesContainerWriter() *FileLogK8sWriter

NewKubernetesContainerWriter returns FileLogK8sWriter with configuration to recognize and parse kubernetes container logs

func (*FileLogK8sWriter) Capabilities added in v0.27.0 

func (f *FileLogK8sWriter) Capabilities() consumer.Capabilities

func (*FileLogK8sWriter) ConsumeLogs added in v0.22.0 

func (f *FileLogK8sWriter) ConsumeLogs(_ context.Context, logs plog.Logs) error

func (*FileLogK8sWriter) Flush added in v0.22.0 

func (f *FileLogK8sWriter) Flush()

func (*FileLogK8sWriter) GenConfigYAMLStr added in v0.22.0 

func (f *FileLogK8sWriter) GenConfigYAMLStr() string

func (*FileLogK8sWriter) GetEndpoint added in v0.22.0 

func (f *FileLogK8sWriter) GetEndpoint() net.Addr

func (*FileLogK8sWriter) ProtocolName added in v0.22.0 

func (f *FileLogK8sWriter) ProtocolName() string

func (*FileLogK8sWriter) Start added in v0.22.0 

func (f *FileLogK8sWriter) Start() error

type FileLogWriter added in v0.21.0 

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

func NewFileLogWriter added in v0.21.0 

func NewFileLogWriter() *FileLogWriter

NewFileLogWriter creates a new data sender that will write log entries to a file, to be tailed by FluentBit and sent to the collector.

func (*FileLogWriter) Capabilities added in v0.27.0 

func (f *FileLogWriter) Capabilities() consumer.Capabilities

func (*FileLogWriter) ConsumeLogs added in v0.21.0 

func (f *FileLogWriter) ConsumeLogs(_ context.Context, logs plog.Logs) error

func (*FileLogWriter) Flush added in v0.21.0 

func (f *FileLogWriter) Flush()

func (*FileLogWriter) GenConfigYAMLStr added in v0.21.0 

func (f *FileLogWriter) GenConfigYAMLStr() string

func (*FileLogWriter) GetEndpoint added in v0.21.0 

func (f *FileLogWriter) GetEndpoint() net.Addr

func (*FileLogWriter) ProtocolName added in v0.21.0 

func (f *FileLogWriter) ProtocolName() string

func (*FileLogWriter) Start added in v0.21.0 

func (f *FileLogWriter) Start() error

type FluentLogsForwarder added in v0.24.0 

type FluentLogsForwarder struct {
	testbed.DataSenderBase
	// contains filtered or unexported fields
}

FluentLogsForwarder forwards logs to fluent forwader

func NewFluentLogsForwarder added in v0.24.0 

func NewFluentLogsForwarder(t *testing.T, port int) *FluentLogsForwarder

func (*FluentLogsForwarder) Capabilities added in v0.27.0 

func (f *FluentLogsForwarder) Capabilities() consumer.Capabilities

func (*FluentLogsForwarder) ConsumeLogs added in v0.24.0 

func (f *FluentLogsForwarder) ConsumeLogs(_ context.Context, logs plog.Logs) error

func (*FluentLogsForwarder) Flush added in v0.24.0 

func (f *FluentLogsForwarder) Flush()

func (*FluentLogsForwarder) GenConfigYAMLStr added in v0.24.0 

func (f *FluentLogsForwarder) GenConfigYAMLStr() string

func (*FluentLogsForwarder) ProtocolName added in v0.24.0 

func (f *FluentLogsForwarder) ProtocolName() string

func (*FluentLogsForwarder) Start added in v0.24.0 

func (f *FluentLogsForwarder) Start() error

func (*FluentLogsForwarder) Stop added in v0.24.0 

func (f *FluentLogsForwarder) Stop() error

type SFxMetricsDataSender 

type SFxMetricsDataSender struct {
	testbed.DataSenderBase
	consumer.Metrics
}

SFxMetricsDataSender implements MetricDataSender for SignalFx metrics protocol.

func NewSFxMetricDataSender 

func NewSFxMetricDataSender(port int) *SFxMetricsDataSender

NewSFxMetricDataSender creates a new SignalFx metric protocol sender that will send to the specified port after Start is called.

func (*SFxMetricsDataSender) GenConfigYAMLStr 

func (sf *SFxMetricsDataSender) GenConfigYAMLStr() string

GenConfigYAMLStr returns receiver config for the agent.

func (*SFxMetricsDataSender) ProtocolName 

func (sf *SFxMetricsDataSender) ProtocolName() string

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

func (*SFxMetricsDataSender) Start 

func (sf *SFxMetricsDataSender) Start() error

Start the sender.

type SapmDataSender 

type SapmDataSender struct {
	testbed.DataSenderBase
	consumer.Traces
	// contains filtered or unexported fields
}

SapmDataSender implements TraceDataSender for SAPM protocol.

func NewSapmDataSender 

func NewSapmDataSender(port int, compression string) *SapmDataSender

NewSapmDataSender creates a new Sapm protocol sender that will send to the specified port after Start is called.

func (*SapmDataSender) GenConfigYAMLStr 

func (je *SapmDataSender) GenConfigYAMLStr() string

GenConfigYAMLStr returns receiver config for the agent.

func (*SapmDataSender) ProtocolName 

func (je *SapmDataSender) ProtocolName() string

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

func (*SapmDataSender) Start 

func (je *SapmDataSender) Start() error

Start the sender.

type SyslogWriter added in v0.24.0 

type SyslogWriter struct {
	testbed.DataSenderBase
	// contains filtered or unexported fields
}

func NewSyslogWriter added in v0.24.0 

func NewSyslogWriter(network string, host string, port int, batchSize int) *SyslogWriter

func (*SyslogWriter) Capabilities added in v0.27.0 

func (f *SyslogWriter) Capabilities() consumer.Capabilities

func (*SyslogWriter) ConsumeLogs added in v0.24.0 

func (f *SyslogWriter) ConsumeLogs(_ context.Context, logs plog.Logs) error

func (*SyslogWriter) Flush added in v0.24.0 

func (f *SyslogWriter) Flush()

func (*SyslogWriter) GenConfigYAMLStr added in v0.24.0 

func (f *SyslogWriter) GenConfigYAMLStr() string

func (*SyslogWriter) GetEndpoint added in v0.24.0 

func (f *SyslogWriter) GetEndpoint() net.Addr

func (*SyslogWriter) ProtocolName added in v0.24.0 

func (f *SyslogWriter) ProtocolName() string

func (*SyslogWriter) Send added in v0.24.0 

func (f *SyslogWriter) Send(lr plog.LogRecord) error

func (*SyslogWriter) SendCheck added in v0.24.0 

func (f *SyslogWriter) SendCheck() error

func (*SyslogWriter) Start added in v0.24.0 

func (f *SyslogWriter) Start() (err error)

type TCPUDPWriter added in v0.27.0 

type TCPUDPWriter struct {
	testbed.DataSenderBase
	// contains filtered or unexported fields
}

func NewTCPUDPWriter added in v0.27.0 

func NewTCPUDPWriter(network string, host string, port int, batchSize int) *TCPUDPWriter

func (*TCPUDPWriter) Capabilities added in v0.27.0 

func (f *TCPUDPWriter) Capabilities() consumer.Capabilities

func (*TCPUDPWriter) ConsumeLogs added in v0.27.0 

func (f *TCPUDPWriter) ConsumeLogs(_ context.Context, logs plog.Logs) error

func (*TCPUDPWriter) Flush added in v0.27.0 

func (f *TCPUDPWriter) Flush()

func (*TCPUDPWriter) GenConfigYAMLStr added in v0.27.0 

func (f *TCPUDPWriter) GenConfigYAMLStr() string

func (*TCPUDPWriter) GetEndpoint added in v0.27.0 

func (f *TCPUDPWriter) GetEndpoint() net.Addr

func (*TCPUDPWriter) ProtocolName added in v0.27.0 

func (f *TCPUDPWriter) ProtocolName() string

func (*TCPUDPWriter) Send added in v0.27.0 

func (f *TCPUDPWriter) Send(lr plog.LogRecord) error

func (*TCPUDPWriter) SendCheck added in v0.27.0 

func (f *TCPUDPWriter) SendCheck() error

func (*TCPUDPWriter) Start added in v0.27.0 

func (f *TCPUDPWriter) Start() (err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.