queue

Documentation

Index

• func Delete(uid string)
• func GetByID(uid string) interface{}
• func GetFirst() interface{}
• func GetLast() interface{}
• func IsInQueue(uid string) bool
• func Put(uid string, data interface{})
• type Queue
  • func NewQueue() (q *Queue)
  • func (q *Queue) Delete(uid string)
  • func (q *Queue) GetByID(uid string) interface{}
  • func (q *Queue) GetFirst() interface{}
  • func (q *Queue) GetLast() interface{}
  • func (*Queue) Init() *Queue
  • func (q *Queue) IsInQueue(uid string) bool
  • func (q *Queue) Put(uid string, data interface{})

Functions

func Delete

func Delete(uid string)

Delete removes value from queue.

func GetByID

func GetByID(uid string) interface{}

GetByID returns element from Queue by uid.

func GetFirst

func GetFirst() interface{}

GetFirst returns first element from Queue.

func GetLast

func GetLast() interface{}

GetLast returns last element from Queue.

func IsInQueue

func IsInQueue(uid string) bool

IsInQueue checks is element with given uid in Queue.

func Put

func Put(uid string, data interface{})

Put adds value to queue.

Types

type Queue

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

Queue is a simple concurrency-safe FIFO implementation.

func NewQueue

func NewQueue() (q *Queue)

NewQueue init empty Queue.

func (*Queue) Delete

func (q *Queue) Delete(uid string)

Delete removes value from queue.

func (*Queue) GetByID

func (q *Queue) GetByID(uid string) interface{}

GetByID returns element from Queue by uid.

func (*Queue) GetFirst

func (q *Queue) GetFirst() interface{}

GetFirst returns first element from Queue.

func (*Queue) GetLast

func (q *Queue) GetLast() interface{}

GetLast returns last element from Queue.

func (*Queue) Init

func (*Queue) Init() *Queue

Init inits empty Queue.

func (*Queue) IsInQueue

func (q *Queue) IsInQueue(uid string) bool

IsInQueue checks is element with given uid in Queue.

func (*Queue) Put

func (q *Queue) Put(uid string, data interface{})

Put adds value to queue.