consumer

Documentation

Index

• func AddConsumer(c *LogConsumer)
• func StopConsumers()
• type LogConsumer
  • func NewLogConsumer(name string, nsqConfig nsqworker.ConsumerConfig, fileName string) *LogConsumer
  • func (c *LogConsumer) Close()
  • func (c *LogConsumer) Handler(message []byte) error

Functions

func AddConsumer

func AddConsumer(c *LogConsumer)

func StopConsumers

func StopConsumers()

Types

type LogConsumer

type LogConsumer struct {
	Name      string
	NsqConfig nsqworker.ConsumerConfig
	LogFile   *lumberjack.Logger
	//Logger    zerolog.Logger
	Logger2  *zap.Logger
	Consumer *nsq.Consumer
}

func NewLogConsumer

func NewLogConsumer(name string, nsqConfig nsqworker.ConsumerConfig, fileName string) *LogConsumer

func (*LogConsumer) Close

func (c *LogConsumer) Close()

func (*LogConsumer) Handler

func (c *LogConsumer) Handler(message []byte) error