queue

Documentation

Index

• Constants
• type QueueConnector
  • func NewQueueConnector(dialer string) *QueueConnector
  • func (qc *QueueConnector) StartWorker()

Constants

const (
	// machinery task queue
	QueueName = "machinery_tasks"
)

Types

type QueueConnector

type QueueConnector struct {
	Server *machinery.Server
	// contains filtered or unexported fields
}

func NewQueueConnector

func NewQueueConnector(dialer string) *QueueConnector

func (*QueueConnector) StartWorker

func (qc *QueueConnector) StartWorker()

StartWorker - starts worker to process registered tasks