safequeue

Documentation

Index

• type SafeQueue
  • func NewSafeQueue(shardSize int) *SafeQueue
  • func (queue *SafeQueue) DirtyLength() uint64
  • func (queue *SafeQueue) DirtyPop() (item *amqp.Message)
  • func (queue *SafeQueue) DirtyPurge()
  • func (queue *SafeQueue) HeadItem() (res *amqp.Message)
  • func (queue *SafeQueue) Length() uint64
  • func (queue *SafeQueue) Pop() (item *amqp.Message)
  • func (queue *SafeQueue) Purge()
  • func (queue *SafeQueue) Push(item *amqp.Message)
  • func (queue *SafeQueue) PushHead(item *amqp.Message)

Types

type SafeQueue

type SafeQueue struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SafeQueue represents simple FIFO queue TODO Is that implementation faster? test simple slice queue

func NewSafeQueue

func NewSafeQueue(shardSize int) *SafeQueue

NewSafeQueue returns new instance of queue

func (*SafeQueue) DirtyLength

func (queue *SafeQueue) DirtyLength() uint64

DirtyLength returns queue length This method is not thread safe

func (*SafeQueue) DirtyPop

func (queue *SafeQueue) DirtyPop() (item *amqp.Message)

DirtyPop retrieves message from head This method is not thread safe

func (*SafeQueue) DirtyPurge

func (queue *SafeQueue) DirtyPurge()

DirtyPurge clear queue This method is not thread safe

func (*SafeQueue) HeadItem

func (queue *SafeQueue) HeadItem() (res *amqp.Message)

HeadItem returns current head message This method is not thread safe

func (*SafeQueue) Length

func (queue *SafeQueue) Length() uint64

Length returns queue length

func (*SafeQueue) Pop

func (queue *SafeQueue) Pop() (item *amqp.Message)

Pop retrieves message from head

func (*SafeQueue) Purge

func (queue *SafeQueue) Purge()

Purge clear queue

func (*SafeQueue) Push

func (queue *SafeQueue) Push(item *amqp.Message)

Push adds message into queue tail

func (*SafeQueue) PushHead

func (queue *SafeQueue) PushHead(item *amqp.Message)

PushHead adds message into queue head