Versions in this module Expand all Collapse all v0 v0.0.2 Jul 3, 2020 Changes in this version + func Flush() error + func Forget(id uint) error + func Initialize() + func NewConsumer(topicName string, channelName string, paramPtr proto.Message, ...) *consumer + func NewProducer(topicName string, channelName string, param proto.Message, retries uint32, ...) *producer + func Queue() queuer + func Retry(id uint) error + type FailedProcessor interface + FailedToDatabase func(topicName string, channelName string, msg *message.Message, errStr string) error + type FailedQueuer interface + DeleteQueueById func(id uint) error + FailedQueueById func(id uint) (failedQueuerPtr FailedQueuer, err error) + RetryChannel func() string + RetryDelay func() zone.Duration + RetryHash func() string + RetryParamProtoBytes func() []byte + RetryRetries func() uint32 + RetryTopic func() string
Go to main page