mqtt

Documentation

Index

• func NewTLSConfig() (config *tls.Config, err error)
• type Client
  • func NewClient(o Options) (Client, error)
• type Message
• type Options
• type Topic
  • func (t *Topic) Key() string
  • func (t *Topic) ToDataFrame() (*data.Frame, error)
• type TopicMap
  • func (tm *TopicMap) AddMessage(path string, message Message)
  • func (tm *TopicMap) Delete(path string)
  • func (tm *TopicMap) Load(path string) (*Topic, bool)
  • func (tm *TopicMap) Store(t *Topic)

Functions

func NewTLSConfig

func NewTLSConfig() (config *tls.Config, err error)

Adapted from https://github.com/eclipse/paho.mqtt.golang/blob/master/cmd/ssl/main.go Also see https://www.eclipse.org/paho/clients/golang/ https://adrianhesketh.com/2019/11/04/aws-iot-with-go/

Types

type Client

type Client interface {
	GetTopic(string) (*Topic, bool)
	IsConnected() bool
	Subscribe(string) *Topic
	Unsubscribe(string)
	Dispose()
}

func NewClient

func NewClient(o Options) (Client, error)

type Message

type Message struct {
	Timestamp time.Time
	Value     []byte
}

type Options

type Options struct {
	URI      string `json:"uri"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type Topic

type Topic struct {
	Path     string `json:"topic"`
	Interval time.Duration
	Messages []Message
	// contains filtered or unexported fields
}

func (*Topic) Key

func (t *Topic) Key() string

func (*Topic) ToDataFrame

func (t *Topic) ToDataFrame() (*data.Frame, error)

type TopicMap

type TopicMap struct {
	sync.Map
}

func (*TopicMap) AddMessage

func (tm *TopicMap) AddMessage(path string, message Message)

func (*TopicMap) Delete

func (tm *TopicMap) Delete(path string)

func (*TopicMap) Load

func (tm *TopicMap) Load(path string) (*Topic, bool)

func (*TopicMap) Store

func (tm *TopicMap) Store(t *Topic)