queue

Documentation

Index

• Constants
• func AddTask(rc redis.Conn, queue string, taskType string, orgID int, task interface{}, ...) error
• func MarkTaskComplete(rc redis.Conn, queue string, orgID int) 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, orgID int, 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, orgID int) 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"`
	OrgID int             `json:"org_id"`
	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