common/priority_queue/interface.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

package priorityqueue

type Queue interface {
	Insert(item Item)
	GetMax() Item
}

type Item interface {
	ID() string
	Priority() uint64
	Ack()
	Nack()
	Body() []byte
	Context() []byte
}