kafka_exporter

Documentation

Index

• Constants
• type Counter
• type KafkaExporter
  • func NewKafkaExporter(index int, config *exporters_cfg.ExporterCfg, ...) *KafkaExporter
  • func (e *KafkaExporter) Close()
  • func (e *KafkaExporter) GetCounter() interface{}
  • func (e *KafkaExporter) HandleSimpleCommand(op uint16, arg string) string
  • func (e *KafkaExporter) Put(items ...interface{})
  • func (e *KafkaExporter) Start()

Constants

const (
	QUEUE_BATCH_COUNT = 1024
)

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 KafkaExporter

type KafkaExporter struct {
	Addr string

	utils.Closable
	// contains filtered or unexported fields
}

func NewKafkaExporter

func NewKafkaExporter(index int, config *exporters_cfg.ExporterCfg, universalTagsManager *utag.UniversalTagsManager) *KafkaExporter

func (*KafkaExporter) Close

func (e *KafkaExporter) Close()

func (*KafkaExporter) GetCounter

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

func (*KafkaExporter) HandleSimpleCommand

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

func (*KafkaExporter) Put

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

func (*KafkaExporter) Start

func (e *KafkaExporter) Start()