common

Documentation

Index

• Variables
• func NewMessage(pkt *mqtt.Publish) *mqtt.Message
• type Event
  • func NewEvent(msg *mqtt.Message, count int32, call func(uint64)) *Event
  • func (e *Event) Done()
  • func (e *Event) Packet() *mqtt.Publish
  • func (e *Event) Wait(timeout <-chan time.Time, cancel <-chan struct{}) error
• type Queue

Variables

var (
	ErrAcknowledgeCanceled = errors.New("acknowledge canceled")
	ErrAcknowledgeTimedOut = errors.New("acknowledge timed out")
)

all errors of acknowledgement

Functions

func NewMessage

func NewMessage(pkt *mqtt.Publish) *mqtt.Message

NewMessage creates a new message by packet

Types

type Event

type Event struct {
	*mqtt.Message
	// contains filtered or unexported fields
}

Event event with message and acknowledge

func NewEvent

func NewEvent(msg *mqtt.Message, count int32, call func(uint64)) *Event

NewEvent creates a new event

func (*Event) Done

func (e *Event) Done()

Done the event is acknowledged

func (*Event) Packet

func (e *Event) Packet() *mqtt.Publish

Packet converts to mqtt packet

func (*Event) Wait

func (e *Event) Wait(timeout <-chan time.Time, cancel <-chan struct{}) error

Wait waits until acknowledged (returns true), cancelled or timed out

type Queue

type Queue interface {
	Push(*Event) error
	ID() string
}

Queue interfaces