queue

Documentation

Index

• type Queue
  • func NewSimpleSyncQueue() Queue

Types

type Queue

type Queue interface {
	// Enqueue will add an item to the queue for processing. If the item being enqueued already exists then
	// it will be ignored.
	Enqueue(item interface{})
	// Dequeue will get an item from the queue. If there are no items on the queue then it will wait.
	Dequeue() (interface{}, bool)
	// Shutdown will cause the queue processing to shutdown.
	Shutdown()
}

Queue is the interface for a queue.

func NewSimpleSyncQueue

func NewSimpleSyncQueue() Queue

NewSimpleSyncQueue create a new simple sync queue.