rnsq

type BaseConsumer interface {
	Consume(handler Handler) error
	ConsumeWithTopic(topic, channel string, handler Handler, opts ...Option) error
	ConsumeMany(handler Handler, concurrency int) error
	ConsumeManyWithTopic(topic, channel string, handler Handler, concurrency int, opts ...Option) error
	ChangeMaxInFlight(maxInFlight int)
	ChangeMaxInFlightWithTopic(topic, channel string, maxInFlight int)
	SetLogLevel(level string)
	SetLogLevelWithTopic(topic, channel, level string)
	Stats() *ConsumerStates
	StatsWithTopic(topic, channel string) *ConsumerStates
	Stop()

	SetMaxInFlight(maxInFlight int) *defBaseConsumer
	SetMaxAttempts(maxAttempts uint16) *defBaseConsumer
	SetSecret(secret string) *defBaseConsumer
}

type BaseProducer interface {
	Publish(data string) error
	PublishB(data []byte) error
	PublishWithTopic(topic, data string) error
	PublishBWithTopic(topic string, data []byte) error
	PublishAsync(data string) error
	PublishBAsync(data []byte) error
	PublishAsyncWithTopic(topic, data string) error
	PublishBAsyncWithTopic(topic string, data []byte) error
	PublishAsyncWithChan(data string, doneChan chan *nsq.ProducerTransaction, args ...interface{}) error
	PublishBAsyncWithChan(data []byte, doneChan chan *nsq.ProducerTransaction, args ...interface{}) error
	PublishAsyncWithChanWithTopic(topic, data string, doneChan chan *nsq.ProducerTransaction, args ...interface{}) error
	PublishBAsyncWithChanWithTopic(topic string, data []byte, doneChan chan *nsq.ProducerTransaction, args ...interface{}) error
	PublishDelay(data string, delay time.Duration) error
	PublishBDelay(data []byte, delay time.Duration) error
	PublishDelayWithTopic(topic, data string, delay time.Duration) error
	PublishBDelayWithTopic(topic string, data []byte, delay time.Duration) error
	PublishDelayAsync(data string, delay time.Duration) error
	PublishBDelayAsync(data []byte, delay time.Duration) error
	PublishDelayAsyncWithChan(data string, delay time.Duration, doneChan chan *nsq.ProducerTransaction,
		args ...interface{}) error
	PublishBDelayAsyncWithChan(data []byte, delay time.Duration, doneChan chan *nsq.ProducerTransaction,
		args ...interface{}) error
	PublishDelayAsyncWithChanWithTopic(topic, data string, delay time.Duration, doneChan chan *nsq.ProducerTransaction,
		args ...interface{}) error
	PublishBDelayAsyncWithChanWithTopic(topic string, data []byte, delay time.Duration, doneChan chan *nsq.ProducerTransaction,
		args ...interface{}) error
	PublishMulti(messages [][]byte) error
	PublishMultiWithTopic(topic string, messages [][]byte) error
	PublishMultiAsync(messages [][]byte) error
	PublishMultiAsyncWithTopic(topic string, messages [][]byte) error
	PublishMultiAsyncWithChan(messages [][]byte, doneChan chan *nsq.ProducerTransaction,
		args ...interface{}) error
	PublishMultiAsyncWithChanWithTopic(topic string, messages [][]byte, doneChan chan *nsq.ProducerTransaction,
		args ...interface{}) error
	SetLogLevel(level string)
	Stop()
}

type ConnType int

type ConsumerStates struct {
	Received    uint64
	Finished    uint64
	Requeued    uint64
	Connections int
}

type Handler func(*XMessage) error

type Option func(opt *options)

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

type XMessage struct {
	*nsq.Message
}