jobque

Documentation

Index

• type Item
• type JobQueue
  • func New(rclient *redis.Client) *JobQueue
  • func (q *JobQueue) Dequeue(n int, timeout time.Duration) ([]*Item, error)
  • func (q *JobQueue) Enqueue(item Item) error
  • func (q *JobQueue) Size() (int, error)

Types

type Item

type Item struct {
	Url string `json:"url"`
}

type JobQueue

type JobQueue struct {
	// contains filtered or unexported fields
}

func New

func New(rclient *redis.Client) *JobQueue

func (*JobQueue) Dequeue

func (q *JobQueue) Dequeue(n int, timeout time.Duration) ([]*Item, error)

func (*JobQueue) Enqueue

func (q *JobQueue) Enqueue(item Item) error

func (*JobQueue) Size

func (q *JobQueue) Size() (int, error)