support

Documentation

Index

• Constants
• func GetQueueName(connection, queue string) string
• func GetServer(connection string, queue string) (*machinery.Server, error)
• type Task
  • func (receiver *Task) Delay(delay time.Time) queue.Task
  • func (receiver *Task) Dispatch() error
  • func (receiver *Task) DispatchSync() error
  • func (receiver *Task) OnConnection(connection string) queue.Task
  • func (receiver *Task) OnQueue(queue string) queue.Task
• type Worker
  • func (receiver *Worker) Run() error

Constants

const DriverRedis string = "redis"

const DriverSync string = "sync"

Functions

func GetQueueName

func GetQueueName(connection, queue string) string

func GetServer

func GetServer(connection string, queue string) (*machinery.Server, error)

Types

type Task

type Task struct {
	Job   queue.Job
	Jobs  []queue.Jobs
	Chain bool
	Args  []queue.Arg
	// contains filtered or unexported fields
}

func (*Task) Delay

func (receiver *Task) Delay(delay time.Time) queue.Task

func (*Task) Dispatch

func (receiver *Task) Dispatch() error

func (*Task) DispatchSync

func (receiver *Task) DispatchSync() error

func (*Task) OnConnection

func (receiver *Task) OnConnection(connection string) queue.Task

func (*Task) OnQueue

func (receiver *Task) OnQueue(queue string) queue.Task

type Worker

type Worker struct {
	// Specify connection
	Connection string
	// Specify queue
	Queue string
	// Concurrent num
	Concurrent int
}

func (*Worker) Run

func (receiver *Worker) Run() error