queue

Documentation

Index

• Variables
• type Queue
  • func New(initialSize int64) 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{})

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 Queue

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

func New

func New(initialSize int64) 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{})