mqtt

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, o Options) (Client, error)
• type Message
• type Options
• type Topic
  • func (t *Topic) Key() string
  • func (t *Topic) ToDataFrame(logger log.Logger) (*data.Frame, error)
• type TopicMap
  • func (tm *TopicMap) AddMessage(path string, message Message)
  • func (tm *TopicMap) Delete(key string)
  • func (tm *TopicMap) HasSubscription(path string) bool
  • func (tm *TopicMap) Load(key string) (*Topic, bool)
  • func (tm *TopicMap) Store(t *Topic)

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, 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"`
	ClientID      string `json:"clientID"`
	TLSCACert     string `json:"tlsCACert"`
	TLSClientCert string `json:"tlsClientCert"`
	TLSClientKey  string `json:"tlsClientKey"`
	TLSSkipVerify bool   `json:"tlsSkipVerify"`
}

type Topic

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

Topic represents a MQTT topic.

func (*Topic) Key

func (t *Topic) Key() string

Key returns the key for the topic. The key is a combination of the interval string, the path, and the streaming key. For example, if the path is "my/topic" and the interval is 1s, the key will be "1s/my/topic/streamingkey".

func (*Topic) ToDataFrame

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

ToDataFrame converts the topic to a data frame.

type TopicMap

type TopicMap struct {
	sync.Map
}

TopicMap is a thread-safe map of topics

func (*TopicMap) AddMessage

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

AddMessage adds a message to the topic for the given path.

func (*TopicMap) Delete

func (tm *TopicMap) Delete(key string)

Delete deletes the topic for the given key.

func (*TopicMap) HasSubscription

func (tm *TopicMap) HasSubscription(path string) bool

HasSubscription returns true if the topic map has a subscription for the given path.

func (*TopicMap) Load

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

Load returns the topic for the given topic key.

func (*TopicMap) Store

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

Store stores the topic in the map.