queue

package

v0.0.0-...-e825d84 Latest Latest Go to latest Published: Apr 10, 2019 License: BSD-3-Clause 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

This section is empty.

This section is empty.

func CreateJob(pool *redis.Pool, name string, job []byte) (bool, error)

CreateJob creates a new job for the queue

func EmptyQueue(pool *redis.Pool, name string) (bool, error)

EmptyQueue empty the queue of jobs

func NewPool() *redis.Pool

NewPool Creates a new REDIS Pool

func NewQueue(pool *redis.Pool, name string) (bool, error)

NewQueue creates a new job queue

func RunJobWithHandler(pool *redis.Pool, name string, handler func([]byte) ([]byte, error)) ([]byte, error)

RunJobWithHandler runs the next job of a queue

func WaitAndRunJob(pool *redis.Pool, name string, job []byte) (bool, error)

WaitAndRunJob runs the next job of a queue

type Queue struct {
	Name   string   `json:"name"`
	Offset int      `json:"offset"`
	Jobs   [][]byte `json:"jobs"`
}

Queue represents a proxy queue for requests

func GetQueue(pool *redis.Pool, name string) (*Queue, error)

GetQueue gets the status of a queue

type SimpleJob struct {
	Command string `json:"command"`
	Arg1    int    `json:"arg1"`
	Arg2    int    `json:"arg2"`
}

SimpleJob serialization