nq

Sep 26, 2021

Changes in this version

type Pusher

+ func (p *Pusher) Ping() error

Sep 26, 2021

Changes in this version

+ func MustNewQueue(c NqConf, handler ConsumeHandler, opts ...QueueOption) queue.MessageQueue

+ func NewQueue(c NqConf, handler ConsumeHandler, opts ...QueueOption) (queue.MessageQueue, error)

+ type ConsumeHandle func(key, value string) error

+ type ConsumeHandler interface

+ Consume func(key, value string) error

+ func WithHandle(handle ConsumeHandle) ConsumeHandler

+ type MessageHandler struct

+ func (mh *MessageHandler) Consume(key, val string) error

+ type NqConf struct

+ Brokers []string

+ Channel string

+ Conns int

+ Consumers int

+ Group string

+ Offset string

+ Processors int

+ Topic string

+ type PushOption func(options *chunkOptions)

+ func WithChunkSize(chunkSize int) PushOption

+ func WithFlushInterval(interval time.Duration) PushOption

+ type Pusher struct

+ func NewPusher(addrs string, topic string, opts ...PushOption) *Pusher

+ func (p *Pusher) Close() error

+ func (p *Pusher) Name() string

+ func (p *Pusher) Push(v string) error

+ type QueueOption func(*queueOptions)

+ func WithMetrics(metrics *stat.Metrics) QueueOption