processor

Documentation

Index

• type KafkaProcessor
  • func NewKafkaProcessor(address []string, topic string, codec string, logQueue *queue.LogQueue) *KafkaProcessor
  • func (processor *KafkaProcessor) Close() error
  • func (processor *KafkaProcessor) Process() error
  • func (processor *KafkaProcessor) Run() error

Types

type KafkaProcessor

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

Kafka log processor

func NewKafkaProcessor

func NewKafkaProcessor(address []string, topic string, codec string, logQueue *queue.LogQueue) *KafkaProcessor

New kafka processor function

func (*KafkaProcessor) Close

func (processor *KafkaProcessor) Close() error

Close kafka producer

func (*KafkaProcessor) Process

func (processor *KafkaProcessor) Process() error

Process go routine function

func (*KafkaProcessor) Run

func (processor *KafkaProcessor) Run() error

Run to process log