queue

Documentation

Index

• Variables
• type Item
• type Queue
  • func NewRingQueue(initialSize int64) Queue
  • func NewUnLockQueue(max uint64) Queue
• type RingQueue
  • func (q *RingQueue) IsEmpty() bool
  • func (q *RingQueue) Length() int64
  • func (q *RingQueue) Pop() (interface{}, bool)
  • func (q *RingQueue) PopMany(count int64) ([]interface{}, bool)
  • func (q *RingQueue) Push(item interface{}) bool
• type UnLockQueue
  • func (q *UnLockQueue) IsEmpty() bool
  • func (q *UnLockQueue) Length() int64
  • func (q *UnLockQueue) Maxlen() uint64
  • func (q *UnLockQueue) Pop() (val interface{}, ok bool)
  • func (q *UnLockQueue) PopMany(count int64) ([]interface{}, bool)
  • func (q *UnLockQueue) Push(val interface{}) bool

Variables

var (
	ErrExceedingMessageSizeLimit = fmt.Errorf("message exceeds the max page size limit")
	ErrOutOfSequenceRange        = fmt.Errorf("out of sequence range")
	ErrExceedingTotalSizeLimit   = fmt.Errorf("queue data size exceeds the max size limit")
	ErrMsgNotFound               = fmt.Errorf("message not found")
)

Types

type Item

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

type Queue

type Queue interface {
	Push(item interface{}) bool                // queue 结尾put 数据， 如果失败返回false, 插入成功返回true
	Pop() (interface{}, bool)                  // 获取消息数据
	Length() int64                             // queue 长度
	IsEmpty() bool                             // queue是否为空
	PopMany(count int64) ([]interface{}, bool) // 获取多条消息数据
}

func NewRingQueue

func NewRingQueue(initialSize int64) Queue

func NewUnLockQueue

func NewUnLockQueue(max uint64) Queue

type RingQueue

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

func (*RingQueue) IsEmpty

func (q *RingQueue) IsEmpty() bool

func (*RingQueue) Length

func (q *RingQueue) Length() int64

func (*RingQueue) Pop

func (q *RingQueue) Pop() (interface{}, bool)

func (*RingQueue) PopMany

func (q *RingQueue) PopMany(count int64) ([]interface{}, bool)

func (*RingQueue) Push

func (q *RingQueue) Push(item interface{}) bool

type UnLockQueue

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

lock free queue

func (*UnLockQueue) IsEmpty

func (q *UnLockQueue) IsEmpty() bool

func (*UnLockQueue) Length

func (q *UnLockQueue) Length() int64

func (*UnLockQueue) Maxlen

func (q *UnLockQueue) Maxlen() uint64

func (*UnLockQueue) Pop

func (q *UnLockQueue) Pop() (val interface{}, ok bool)

get queue functions

func (*UnLockQueue) PopMany

func (q *UnLockQueue) PopMany(count int64) ([]interface{}, bool)

func (*UnLockQueue) Push

func (q *UnLockQueue) Push(val interface{}) bool

Push queue functions