priorityqueue

Documentation

Index

• type Item
  • func NewItem(key string, priority int64, creationTime time.Time) Item
• type PriorityQueue
  • func NewPriorityQueue() *PriorityQueue
  • func (pq *PriorityQueue) Add(item Item)
  • func (pq *PriorityQueue) Export() json.RawMessage
  • func (pq *PriorityQueue) Get(key string) Item
  • func (pq *PriorityQueue) Import(rawMsg json.RawMessage) error
  • func (pq *PriorityQueue) Len() int
  • func (pq *PriorityQueue) Peek() Item
  • func (pq *PriorityQueue) Pop() Item
  • func (pq *PriorityQueue) Range(f func(Item) (stopRange bool))
  • func (pq *PriorityQueue) Remove(key string) Item
• type SnapshotObj

Types

type Item

type Item interface {
	Key() string
	Priority() int64
	SetPriority(int64)
	CreationTime() time.Time
	Index() int
	SetIndex(int)
}

Item 是优先队列存储的结构

func NewItem

func NewItem(key string, priority int64, creationTime time.Time) Item

type PriorityQueue

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

PriorityQueue 优先队列

func NewPriorityQueue

func NewPriorityQueue() *PriorityQueue

func (*PriorityQueue) Add

func (pq *PriorityQueue) Add(item Item)

Add 新增 BaseItem

func (*PriorityQueue) Export

func (pq *PriorityQueue) Export() json.RawMessage

func (*PriorityQueue) Get

func (pq *PriorityQueue) Get(key string) Item

Get 根据 key 获取 BaseItem

func (*PriorityQueue) Import

func (pq *PriorityQueue) Import(rawMsg json.RawMessage) error

func (*PriorityQueue) Len

func (pq *PriorityQueue) Len() int

Len 返回队列长度

func (*PriorityQueue) Peek

func (pq *PriorityQueue) Peek() Item

Peek 获取优先级最高的 BaseItem

func (*PriorityQueue) Pop

func (pq *PriorityQueue) Pop() Item

Pop 弹出优先级最高的 BaseItem，并返回

func (*PriorityQueue) Range

func (pq *PriorityQueue) Range(f func(Item) (stopRange bool))

Range range items and apply func to item one by one.

func (*PriorityQueue) Remove

func (pq *PriorityQueue) Remove(key string) Item

Remove 删除 BaseItem

type SnapshotObj

type SnapshotObj struct {
	Key          string    `json:"key"`
	Priority     int64     `json:"priority"`
	CreationTime time.Time `json:"creationTime"`
	Index        int       `json:"index"`
}