inflight

Documentation

Index

• Variables
• type Queue
  • func New(sender func(*packet.Publish) error) *Queue
  • func (q *Queue) Ack(p *packet.PubAck)
  • func (q *Queue) Close() error
  • func (q *Queue) Put(publish *packet.Publish)

Variables

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

Types

type Queue

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

func New

func New(sender func(*packet.Publish) error) *Queue

func (*Queue) Ack

func (q *Queue) Ack(p *packet.PubAck)

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Put

func (q *Queue) Put(publish *packet.Publish)