pqueue

Documentation

Index

• Constants
• Variables
• type Message
• type PriorityQueue
  • func NewPriorityQueue(capacity uint64, listener chan Message) (*PriorityQueue, error)
  • func (q PriorityQueue) Len() int
  • func (q PriorityQueue) Less(i, j int) bool
  • func (pq *PriorityQueue) Out() chan Message
  • func (q *PriorityQueue) Pop() interface{}
  • func (q *PriorityQueue) Push(x interface{})
  • func (pq *PriorityQueue) Send(m Message, priority uint64) (removed []QueueItem)
  • func (q PriorityQueue) Swap(i, j int)
• type QueueItem

Constants

const StandardQueueCapacity = 2048

Variables

var ListenerShouldNotBeNil = errors.New("Out-channel should not be nil")

Types

type Message

type Message map[string]interface{}

type Message []byte

type PriorityQueue

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

func NewPriorityQueue

func NewPriorityQueue(capacity uint64, listener chan Message) (*PriorityQueue, error)

func (PriorityQueue) Len

func (q PriorityQueue) Len() int

func (PriorityQueue) Less

func (q PriorityQueue) Less(i, j int) bool

func (*PriorityQueue) Out

func (pq *PriorityQueue) Out() chan Message

func (*PriorityQueue) Pop

func (q *PriorityQueue) Pop() interface{}

func (*PriorityQueue) Push

func (q *PriorityQueue) Push(x interface{})

func (*PriorityQueue) Send

func (pq *PriorityQueue) Send(m Message, priority uint64) (removed []QueueItem)

func (PriorityQueue) Swap

func (q PriorityQueue) Swap(i, j int)

type QueueItem

type QueueItem struct {
	Msg       Message
	Timestamp uint64
	Priority  uint64
}