messages

Documentation

Index

• Variables
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Close() error
  • func (q *Queue) Pop() (*packet.Publish, error)
  • func (q *Queue) Put(timestamp time.Time, p *packet.Publish) error

Variables

var (
	ErrQueueEmpty = errors.New("queue empty")
	ErrQueueFull  = errors.New("queue is full")
)

Types

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Pop

func (q *Queue) Pop() (*packet.Publish, error)

func (*Queue) Put

func (q *Queue) Put(timestamp time.Time, p *packet.Publish) error