pubqueue

Documentation

Index

• type Data
• type DropBehavior
  • func NewDropBehavior(b string) (DropBehavior, error)
  • func (x DropBehavior) String() string
• type Queue
  • func New(maxSize int, dropBehavior DropBehavior) *Queue
  • func (s *Queue) Enqueue(d *Data)
  • func (s *Queue) Len() int
  • func (s *Queue) Pop() *Data

Types

type Data

type Data struct {
	Topic   string
	Payload interface{}
}

type DropBehavior

type DropBehavior int

const (
	Oldest DropBehavior = iota
	Newest
	Unknown
)

func NewDropBehavior

func NewDropBehavior(b string) (DropBehavior, error)

func (DropBehavior) String

func (x DropBehavior) String() string

type Queue

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

func New

func New(maxSize int, dropBehavior DropBehavior) *Queue

func (*Queue) Enqueue

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

func (*Queue) Len

func (s *Queue) Len() int

func (*Queue) Pop

func (s *Queue) Pop() *Data