queue

type Queue ¶

type Queue struct {
	sync.Mutex
	Timeout  time.Duration
	Strategy Strategy
	// contains filtered or unexported fields
}

Queue is a queue that implements bucket based depth-first or breadth-first queue.

The breadth-first queues allow defining scores on whose basis the bucket is distributed. Lower scores are picked up first, and higher scores which have a greater chance of being just random noise are picked up later in depth first.

Depth-first queue uses a simple stack for LIFO operations and distributes items as they come in.

func New(strategyName string, timeout int) (*Queue, error)

func (q *Queue) Len() int

func (q *Queue) Pop() chan interface{}

func (q *Queue) Push(x interface{}, priority int)

type Strategy ¶

type Strategy int

Strategy of the queue

const (
	BreadthFirst Strategy = iota
	DepthFirst
)

func (s Strategy) String() string