otlp_exporter

Documentation

Index

• Constants
• func L7FlowLogToExportResourceSpans(l7 *log_data.L7FlowLog, universalTagsManager *utag.UniversalTagsManager, ...)
• type Counter
• type ExportItem
• type OtlpExporter
  • func NewOtlpExporter(index int, config *exporters_cfg.ExportersCfg, ...) *OtlpExporter
  • func (e *OtlpExporter) Close()
  • func (e *OtlpExporter) GetCounter() interface{}
  • func (e *OtlpExporter) HandleSimpleCommand(op uint16, arg string) string
  • func (e *OtlpExporter) IsExportData(l *log_data.L7FlowLog) bool
  • func (e *OtlpExporter) Put(items ...interface{})
  • func (e *OtlpExporter) Start()

Constants

const (
	QUEUE_BATCH_COUNT = 1024
)

Functions

func L7FlowLogToExportResourceSpans

func L7FlowLogToExportResourceSpans(l7 *log_data.L7FlowLog, universalTagsManager *utag.UniversalTagsManager, dataTypeBits uint32, resSpan ptrace.ResourceSpans)

Types

type Counter

type Counter struct {
	RecvCounter          int64 `statsd:"recv-count"`
	SendCounter          int64 `statsd:"send-count"`
	SendBatchCounter     int64 `statsd:"send-batch-count"`
	ExportUsedTimeNs     int64 `statsd:"export-used-time-ns"`
	DropCounter          int64 `statsd:"drop-count"`
	DropBatchCounter     int64 `statsd:"drop-batch-count"`
	DropNoTraceIDCounter int64 `statsd:"drop-no-traceid-count"`
}

type ExportItem

type ExportItem interface {
	Release()
}

type OtlpExporter

type OtlpExporter struct {
	Addr string

	utils.Closable
	// contains filtered or unexported fields
}

func NewOtlpExporter

func NewOtlpExporter(index int, config *exporters_cfg.ExportersCfg, universalTagsManager *utag.UniversalTagsManager) *OtlpExporter

func (*OtlpExporter) Close

func (e *OtlpExporter) Close()

func (*OtlpExporter) GetCounter

func (e *OtlpExporter) GetCounter() interface{}

func (*OtlpExporter) HandleSimpleCommand

func (e *OtlpExporter) HandleSimpleCommand(op uint16, arg string) string

func (*OtlpExporter) IsExportData

func (e *OtlpExporter) IsExportData(l *log_data.L7FlowLog) bool

func (*OtlpExporter) Put

func (e *OtlpExporter) Put(items ...interface{})

func (*OtlpExporter) Start

func (e *OtlpExporter) Start()