queue

Documentation

Index

• 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
• type FailedQueuer

Functions

func Flush

func Flush() error

func Forget

func Forget(id uint) error

func Initialize

func Initialize()

func NewConsumer

func NewConsumer(topicName string, channelName string, paramPtr proto.Message, handler func(paramPtr proto.Message) error) *consumer

func NewProducer

func NewProducer(topicName string, channelName string, param proto.Message, retries uint32, delay zone.Duration) *producer

func Queue

func Queue() queuer

func Retry

func Retry(id uint) error

Types

type FailedProcessor

type FailedProcessor interface {
	FailedToDatabase(topicName string, channelName string, msg *message.Message, errStr string) error
	FailedQueuer
}

type FailedQueuer

type FailedQueuer interface {
	RetryTopic() string
	RetryHash() string
	RetryChannel() string
	RetryRetries() uint32
	RetryDelay() zone.Duration
	RetryParamProtoBytes() []byte
	FailedQueueById(id uint) (failedQueuerPtr FailedQueuer, err error)
	DeleteQueueById(id uint) error
}