kafka_output

Documentation

Index

• type Config
• type KafkaOutput
  • func (k *KafkaOutput) Close() error
  • func (k *KafkaOutput) Init(cfg map[string]interface{}, logger *log.Logger) error
  • func (k *KafkaOutput) Metrics() []prometheus.Collector
  • func (k *KafkaOutput) String() string
  • func (k *KafkaOutput) Write(rsp proto.Message, meta outputs.Meta)

Types

type Config

type Config struct {
	Address  string `mapstructure:"address,omitempty"`
	Topic    string `mapstructure:"topic,omitempty"`
	Name     string `mapstructure:"name,omitempty"`
	MaxRetry int    `mapstructure:"max-retry,omitempty"`
	Timeout  int    `mapstructure:"timeout,omitempty"`
	Format   string `mapstructure:"format,omitempty"`
}

Config //

type KafkaOutput

type KafkaOutput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

KafkaOutput //

func (*KafkaOutput) Close

func (k *KafkaOutput) Close() error

Close //

func (*KafkaOutput) Init

func (k *KafkaOutput) Init(cfg map[string]interface{}, logger *log.Logger) error

Init /

func (*KafkaOutput) Metrics

func (k *KafkaOutput) Metrics() []prometheus.Collector

Metrics //

func (*KafkaOutput) String

func (k *KafkaOutput) String() string

func (*KafkaOutput) Write

func (k *KafkaOutput) Write(rsp proto.Message, meta outputs.Meta)

Write //