mqttcm

Documentation

Index

• func Setup(ctx context.Context, name, statusChannel string, subscribe []string, ...) (*autopaho.ConnectionManager, error)
• func StatusMessageJSON(online bool) ([]byte, error)
• type MQTTTopics
  • func NewTopics(depEnv api.DeploymentEnvironment) *MQTTTopics
  • func (t *MQTTTopics) DataResponse(name, id string) string
  • func (t *MQTTTopics) DataResponseSubscription() string
  • func (t *MQTTTopics) ParseRequestTopic(topic string) (string, string, error)
  • func (t *MQTTTopics) Request(name, check string) string
  • func (t *MQTTTopics) RequestSubscription(name string) string
  • func (t *MQTTTopics) Status(name string) string
  • func (t *MQTTTopics) StatusAPITest(name string) string
  • func (t *MQTTTopics) StatusSubscription() string
• type StatusMessage

Functions

func Setup

func Setup(ctx context.Context, name, statusChannel string, subscribe []string, router paho.Router, conf config.MQConfigger, cp apitls.CertificateProvider) (*autopaho.ConnectionManager, error)

func StatusMessageJSON

func StatusMessageJSON(online bool) ([]byte, error)

Types

type MQTTTopics

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

func NewTopics

func NewTopics(depEnv api.DeploymentEnvironment) *MQTTTopics

func (*MQTTTopics) DataResponse

func (t *MQTTTopics) DataResponse(name, id string) string

func (*MQTTTopics) DataResponseSubscription

func (t *MQTTTopics) DataResponseSubscription() string

func (*MQTTTopics) ParseRequestTopic

func (t *MQTTTopics) ParseRequestTopic(topic string) (string, string, error)

func (*MQTTTopics) Request

func (t *MQTTTopics) Request(name, check string) string

func (*MQTTTopics) RequestSubscription

func (t *MQTTTopics) RequestSubscription(name string) string

func (*MQTTTopics) Status

func (t *MQTTTopics) Status(name string) string

func (*MQTTTopics) StatusAPITest

func (t *MQTTTopics) StatusAPITest(name string) string

func (*MQTTTopics) StatusSubscription

func (t *MQTTTopics) StatusSubscription() string

type StatusMessage

type StatusMessage struct {
	Online    bool
	Version   version.Info
	UpdatedMQ time.Time
}