opqueue

Documentation

Index

• type MemQueue
  • func (q *MemQueue) Add(data *operation.QueuedOperation, protocolVersion uint64) (uint, error)
  • func (q *MemQueue) Len() uint
  • func (q *MemQueue) Peek(num uint) (operation.QueuedOperationsAtTime, error)
  • func (q *MemQueue) Remove(num uint) (ops operation.QueuedOperationsAtTime, ack func() uint, nack func(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 *operation.QueuedOperation, protocolVersion uint64) (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) (operation.QueuedOperationsAtTime, 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) (ops operation.QueuedOperationsAtTime, ack func() uint, nack func(error), err error)

Remove removes (up to) the given number of items from the head of the queue.