kafkalog

Documentation

Index

• Constants
• func Init(hosts []string, duration, queueLen int) error
• func New(ctx logger.Context) (logger.Logger, error)
• func NewAsyncProducer(hosts []string) (sarama.AsyncProducer, error)
• func ValidateLogOpt(cfg map[string]string) error
• type KafkaLogger
  • func (k *KafkaLogger) Close() error
  • func (k *KafkaLogger) Log(msg *logger.Message) error
  • func (k *KafkaLogger) Name() string
  • func (k *KafkaLogger) ReadLogs(config logger.ReadConfig) *logger.LogWatcher
• type KafkaLogs
  • func (d *KafkaLogs) Encode() ([]byte, error)
  • func (d *KafkaLogs) Length() int

Constants

const Name = "kafkalog"

Functions

func Init

func Init(hosts []string, duration, queueLen int) error

func New

func New(ctx logger.Context) (logger.Logger, error)

func NewAsyncProducer

func NewAsyncProducer(hosts []string) (sarama.AsyncProducer, error)

func ValidateLogOpt

func ValidateLogOpt(cfg map[string]string) error

ValidateLogOpt looks for json specific log options max-file & max-size.

Types

type KafkaLogger

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

func (*KafkaLogger) Close

func (k *KafkaLogger) Close() error

func (*KafkaLogger) Log

func (k *KafkaLogger) Log(msg *logger.Message) error

func (*KafkaLogger) Name

func (k *KafkaLogger) Name() string

func (*KafkaLogger) ReadLogs

func (k *KafkaLogger) ReadLogs(config logger.ReadConfig) *logger.LogWatcher

type KafkaLogs

type KafkaLogs struct {
	Log    []byte
	Stream string
	// contains filtered or unexported fields
}

func (*KafkaLogs) Encode

func (d *KafkaLogs) Encode() ([]byte, error)

func (*KafkaLogs) Length

func (d *KafkaLogs) Length() int