queue

Documentation

Index

• type Item
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Add(item Item)
  • func (q *Queue) Process()
  • func (q *Queue) Remove(items ...Item)

Types

type Item

type Item interface {
	ID() string
	Do() bool
	Stop()
}

Item represents a simple item in the queue

type Queue

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Queue is a simple item queue

func NewQueue

func NewQueue() *Queue

NewQueue returns a new queue

func (*Queue) Add

func (q *Queue) Add(item Item)

Add tries to Do the item, if it's not possible, add the item to the queue for future tries

func (*Queue) Process

func (q *Queue) Process()

Process tries to Do all the items in the queue and remove the items successfully done

func (*Queue) Remove

func (q *Queue) Remove(items ...Item)

Remove an item from the queue