queue

Documentation

Index

• Constants
• func AddTask(rc redis.Conn, queue string, taskType string, taskGroup string, ...) error
• func MarkTaskComplete(rc redis.Conn, queue string, taskGroup string) error
• type Priority
• type Task
  • func PopNextTask(rc redis.Conn, queue string) (*Task, error)

Constants

const (

	// DefaultPriority is the default priority for tasks
	DefaultPriority = Priority(0)

	// HighPriority is the highest priority for tasks
	HighPriority = Priority(-10000000)

	// LowPriority is the lowest priority for tasks
	LowPriority = Priority(+10000000)
)

Functions

func AddTask

func AddTask(rc redis.Conn, queue string, taskType string, taskGroup string, task interface{}, priority Priority) error

AddTask adds the passed in task to our queue for execution

func MarkTaskComplete

func MarkTaskComplete(rc redis.Conn, queue string, taskGroup string) error

MarkTaskComplete marks the passed in task as complete. Callers must call this in order to maintain fair workers across orgs

Types

type Priority

type Priority int

Priority is the priority for the task

type Task

type Task struct {
	Type  string          `json:"type"`
	Group string          `json:"group"`
	Task  json.RawMessage `json:"task"`
}

Task is a utility struct for encoding a task

func PopNextTask

func PopNextTask(rc redis.Conn, queue string) (*Task, error)

PopNextTask pops the next task off our queue