kafka_output

Documentation

Index

• type Config
• type KafkaOutput
  • func (k *KafkaOutput) Close() error
  • func (k *KafkaOutput) Init(ctx context.Context, cfg map[string]interface{}, logger *log.Logger) error
  • func (k *KafkaOutput) Metrics() []prometheus.Collector
  • func (k *KafkaOutput) String() string
  • func (k *KafkaOutput) Write(ctx context.Context, 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          time.Duration `mapstructure:"timeout,omitempty"`
	RecoveryWaitTime time.Duration `mapstructure:"recovery-wait-time,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(ctx context.Context, 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(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Write //