kafka

Documentation

Index

• Constants
• func NewKafkaExporter(config *configuration.GatewayConfig) exporters.Exporter
• type KafkaExporter
  • func (e *KafkaExporter) Export(leaf *ctree.Leaf)
  • func (e *KafkaExporter) Name() string
  • func (e *KafkaExporter) Start(cache *cache.Cache) error

Constants

const Name = "kafka"

Functions

func NewKafkaExporter

func NewKafkaExporter(config *configuration.GatewayConfig) exporters.Exporter

Types

type KafkaExporter

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

func (*KafkaExporter) Export

func (e *KafkaExporter) Export(leaf *ctree.Leaf)

func (*KafkaExporter) Name

func (e *KafkaExporter) Name() string

func (*KafkaExporter) Start

func (e *KafkaExporter) Start(cache *cache.Cache) error