opqueue

Documentation

Index

• type MemQueue
  • func (q *MemQueue) Add(data *batch.OperationInfo) (uint, error)
  • func (q *MemQueue) Len() uint
  • func (q *MemQueue) Peek(num uint) ([]*batch.OperationInfo, error)
  • func (q *MemQueue) Remove(num uint) (uint, uint, error)

Types

type MemQueue

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

MemQueue implements an in-memory operation queue

func (*MemQueue) Add

func (q *MemQueue) Add(data *batch.OperationInfo) (uint, error)

Add adds the given data to the tail of the queue and returns the new length of the queue

func (*MemQueue) Len

func (q *MemQueue) Len() uint

Len returns the length of the queue.

func (*MemQueue) Peek

func (q *MemQueue) Peek(num uint) ([]*batch.OperationInfo, error)

Peek returns (up to) the given number of operations from the head of the queue but does not remove them.

func (*MemQueue) Remove

func (q *MemQueue) Remove(num uint) (uint, uint, error)

Remove removes (up to) the given number of items from the head of the queue. Returns the actual number of items that were removed and the new length of the queue.