pkg/priorityqueue/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
	Body() []byte
	Context() []byte
	Ack()
	Nack()
}