inMemoryQueue

Documentation

Index

• Variables
• type ConcurrentQueue
  • func NewConcurrentQueue(maxLength int) *ConcurrentQueue
  • func (c *ConcurrentQueue) Close() error
  • func (c *ConcurrentQueue) Dequeue() (*Item, error)
  • func (c *ConcurrentQueue) Enqueue(data []byte) (*Item, error)
  • func (c *ConcurrentQueue) IsFull() bool
  • func (c *ConcurrentQueue) Length() uint64
• type Item

Variables

var (
	// ErrEmpty is returned when the stack or queue is empty.
	ErrEmpty = errors.New("inMemoryQueue.go: queue is empty")
)

Types

type ConcurrentQueue

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

ConcurrentQueue concurrent queue

func NewConcurrentQueue

func NewConcurrentQueue(maxLength int) *ConcurrentQueue

func (*ConcurrentQueue) Close

func (c *ConcurrentQueue) Close() error

func (*ConcurrentQueue) Dequeue

func (c *ConcurrentQueue) Dequeue() (*Item, error)

func (*ConcurrentQueue) Enqueue

func (c *ConcurrentQueue) Enqueue(data []byte) (*Item, error)

func (*ConcurrentQueue) IsFull

func (c *ConcurrentQueue) IsFull() bool

func (*ConcurrentQueue) Length

func (c *ConcurrentQueue) Length() uint64

type Item

type Item = queue.Item