queue

Documentation

Index

• type Node
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Destroy()
  • func (q *Queue) Pop(ctx context.Context) (worker.BaseProcess, error)
  • func (q *Queue) Push(w worker.BaseProcess)
  • func (q *Queue) Replace(oldPid int64, newWorker worker.BaseProcess)

Types

type Node

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

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) Destroy

func (q *Queue) Destroy()

func (*Queue) Pop

func (q *Queue) Pop(ctx context.Context) (worker.BaseProcess, error)

func (*Queue) Push

func (q *Queue) Push(w worker.BaseProcess)

func (*Queue) Replace

func (q *Queue) Replace(oldPid int64, newWorker worker.BaseProcess)