mqtt

Documentation

Index

• type SendPayload
• type Service
  • func New(u, clientID, cert, key string, db mqtt.DB, cli rpc, sCh <-chan []byte) (Service, error)
  • func (s Service) Close() error

Types

type SendPayload

type SendPayload struct {
	Topic   string
	Payload []byte
}

type Service

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

func New

func New(u, clientID, cert, key string, db mqtt.DB, cli rpc, sCh <-chan []byte) (Service, error)

func (Service) Close

func (s Service) Close() error