queue

Documentation

Index

• type SingleDeliveryQueue
  • func NewSingleDeliveryQueue(size int) *SingleDeliveryQueue
  • func (q *SingleDeliveryQueue) DequeueAll() (*carbon.Payload, bool)
  • func (q *SingleDeliveryQueue) Enqueue(data *carbon.Payload)
  • func (q *SingleDeliveryQueue) HaveData() bool
  • func (q *SingleDeliveryQueue) Len() uint64
• type SingleDeliveryQueueByte
  • func NewSingleDeliveryQueueByte(size int) *SingleDeliveryQueueByte
  • func (q *SingleDeliveryQueueByte) Dequeue() ([]byte, bool)
  • func (q *SingleDeliveryQueueByte) DequeueAll() ([][]byte, bool)
  • func (q *SingleDeliveryQueueByte) Enqueue(data []byte)
  • func (q *SingleDeliveryQueueByte) EnqueueMany(data [][]byte)
  • func (q *SingleDeliveryQueueByte) HaveData() bool
  • func (q *SingleDeliveryQueueByte) Len() uint64

Types

type SingleDeliveryQueue

type SingleDeliveryQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSingleDeliveryQueue

func NewSingleDeliveryQueue(size int) *SingleDeliveryQueue

func (*SingleDeliveryQueue) DequeueAll

func (q *SingleDeliveryQueue) DequeueAll() (*carbon.Payload, bool)

func (*SingleDeliveryQueue) Enqueue

func (q *SingleDeliveryQueue) Enqueue(data *carbon.Payload)

func (*SingleDeliveryQueue) HaveData

func (q *SingleDeliveryQueue) HaveData() bool

func (*SingleDeliveryQueue) Len

func (q *SingleDeliveryQueue) Len() uint64

type SingleDeliveryQueueByte

type SingleDeliveryQueueByte struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSingleDeliveryQueueByte

func NewSingleDeliveryQueueByte(size int) *SingleDeliveryQueueByte

func (*SingleDeliveryQueueByte) Dequeue

func (q *SingleDeliveryQueueByte) Dequeue() ([]byte, bool)

func (*SingleDeliveryQueueByte) DequeueAll

func (q *SingleDeliveryQueueByte) DequeueAll() ([][]byte, bool)

func (*SingleDeliveryQueueByte) Enqueue

func (q *SingleDeliveryQueueByte) Enqueue(data []byte)

func (*SingleDeliveryQueueByte) EnqueueMany

func (q *SingleDeliveryQueueByte) EnqueueMany(data [][]byte)

func (*SingleDeliveryQueueByte) HaveData

func (q *SingleDeliveryQueueByte) HaveData() bool

func (*SingleDeliveryQueueByte) Len

func (q *SingleDeliveryQueueByte) Len() uint64