nsq

Apr 1, 2020

Changes in this version

type MqTaskConfigs

+ Concurrency int

+ Configs map[string]interface{}

Dec 18, 2019

Changes in this version

type BaseNsqWriter

+ func (writer *BaseNsqWriter) Stop()

type MqReceiver

+ Stop func()

type NsqReceiver

+ func (r *NsqReceiver) Stop()

type NsqWriter

+ Stop func()

type ReceiverManager

+ func (a *ReceiverManager) Stop()

Oct 15, 2019

Changes in this version

+ type BaseNsqWriter struct

+ func (writer *BaseNsqWriter) Publish(topic string, jsonObj interface{}) error

+ func (writer *BaseNsqWriter) PublishString(topic string, msg string) error

+ func (writer *BaseNsqWriter) Refresh()

Jul 10, 2019

Changes in this version

+ func SetLog(l logger)

type MqReceiver

+ func NewNsqReceiver(config *MqHostConfigs) MqReceiver

+ type NsqWriter struct

+ func NewNsqWriter(addrs []string) *NsqWriter

+ func (writer *NsqWriter) Publish(topic string, jsonObj interface{}) error

+ func (writer *NsqWriter) PublishString(topic string, msg string) error

+ func (writer *NsqWriter) Refresh()

Jul 4, 2019

Changes in this version

+ func SetLogLv(lv nsq.LogLevel)

type MqTaskConfigs

+ Channel string

+ Handler nsq.HandlerFunc

+ Host *MqHostConfigs

+ Topic string

Jun 27, 2019

Changes in this version

+ type MqHostConfigs struct

+ Lookup []string

+ Nsq []string

+ func (c *MqHostConfigs) IsValid()

+ type MqReceiver interface

+ AddTask func(task ...MqTask) MqReceiver

+ BaseHost func() (baseHost *MqHostConfigs)

+ Start func()

+ func NewMqReceiver(config *MqHostConfigs) MqReceiver

+ type MqTask interface

+ func NewNsqTask() MqTask

+ type MqTaskConfigs struct

+ type NsqHandler interface

+ TaskConfig func() (config *MqTaskConfigs)

+ type NsqHandlerFunc func() (config *MqTaskConfigs)

+ func (f NsqHandlerFunc) TaskConfig() (config *MqTaskConfigs)

+ type NsqReceiver struct

+ Index int8

+ func (r *NsqReceiver) AddTask(tasks ...MqTask) MqReceiver

+ func (r *NsqReceiver) BaseHost() (baseHost *MqHostConfigs)

+ func (r *NsqReceiver) Start()

+ type NsqTask struct

+ ConErr []error

+ Fatal error

+ type ReceiverManager struct

+ func NewReceiverManager(receiver MqReceiver, h ...NsqHandler) *ReceiverManager

+ func (a *ReceiverManager) Add(h ...NsqHandler)

+ func (a *ReceiverManager) Start()

Apr 29, 2019

Changes in this version

+ type Consumer struct

+ func NewConsumer(topic, channel string) *Consumer

+ func (c *Consumer) Set(option string, value interface{})

+ func (c *Consumer) SetLogger(log logger, level nsq.LogLevel)

+ func (c *Consumer) SetMap(options map[string]interface{})

+ func (c *Consumer) Start(handler nsq.Handler) error

+ func (c *Consumer) Stop() error

+ type Producer struct

+ func NewNsqProducer(addrs []string) *Producer

+ func (p *Producer) PubMsg(topic string, msg interface{}) error