pubqueue

Nov 2, 2018

Changes in this version

+ type Data struct

+ Payload interface{}

+ Topic string

+ type DropBehavior int

+ const Newest

+ const Oldest

+ const Unknown

+ func NewDropBehavior(b string) (DropBehavior, error)

+ func (x DropBehavior) String() string

+ type Queue struct

+ func New(maxSize int, dropBehavior DropBehavior) *Queue

+ func (s *Queue) Enqueue(d *Data)

+ func (s *Queue) Len() int

+ func (s *Queue) Pop() *Data