kafka

Documentation

Index

• type Executor
  • func New() *Executor
  • func (o *Executor) Logs(lines ...*base.Line) error
  • func (o *Executor) SetFormatter(formatter formatters.Formatter)

Types

type Executor

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

Executor send log lines to kafka with specified topic.

You can subscribe kafka message than redirect to aliyun log service or elasticsearch by logstash.

func New

func New() *Executor

func (*Executor) Logs

func (o *Executor) Logs(lines ...*base.Line) error

func (*Executor) SetFormatter

func (o *Executor) SetFormatter(formatter formatters.Formatter)