queue

package

v0.0.73 Latest Latest Go to latest Published: Dec 18, 2018 License: AGPL-3.0 Imports: 5 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

github.com/greatnonprofits-nfp/mailroom

Links

Open Source Insights

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 ¶

View Source

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)
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

queue.go

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