queue

package

v0.0.2 Latest Latest Go to latest Published: Jul 3, 2020 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/ilibs/go-starter-common

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
driver
nsq
protocol_buffers

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL