mqtt

Documentation

Index

• func SetDisconnectsEnabled(enabled bool)
• func SetDisconnectsInterval(interval time.Duration)
• func SetMaxDisconnects(N uint32)
• type ACL
• type AWS
• type Alerts
• type Connection
• type Encryption
• type MQTTD
  • func (m *MQTTD) Close()
  • func (mqttd *MQTTD) Run(u uhppote.IUHPPOTE, devices []uhppote.Device, authorized []string) error
• type SystemMonitor
  • func NewSystemMonitor(mqttd *MQTTD) *SystemMonitor
  • func (m *SystemMonitor) Alert(monitor monitoring.Monitor, msg string) error
  • func (m *SystemMonitor) Alive(monitor monitoring.Monitor, msg string) error
• type Topics

Functions

func SetDisconnectsEnabled

func SetDisconnectsEnabled(enabled bool)

func SetDisconnectsInterval

func SetDisconnectsInterval(interval time.Duration)

func SetMaxDisconnects

func SetMaxDisconnects(N uint32)

Types

type ACL

type ACL struct {
	Verify map[acl.Verification]bool
}

type AWS

type AWS struct {
	Credentials *aws.Credentials
	Region      string
}

type Alerts

type Alerts struct {
	QOS      byte
	Retained bool
}

type Connection

type Connection struct {
	Broker   string
	ClientID string
	UserName string
	Password string
}

type Encryption

type Encryption struct {
	SignOutgoing    bool
	EncryptOutgoing bool
	EventsKeyID     string
	SystemKeyID     string
	HOTP            *auth.HOTP
	RSA             *auth.RSA
	Nonce           auth.Nonce
}

type MQTTD

type MQTTD struct {
	ServerID       string
	Connection     Connection
	TLS            *tls.Config
	Topics         Topics
	Alerts         Alerts
	HMAC           auth.HMAC
	Encryption     Encryption
	Authentication string
	Permissions    auth.Permissions
	AWS            AWS
	ACL            ACL
	EventMap       string
	Protocol       string
	Debug          bool
	// contains filtered or unexported fields
}

func (*MQTTD) Close

func (m *MQTTD) Close()

func (*MQTTD) Run

func (mqttd *MQTTD) Run(u uhppote.IUHPPOTE, devices []uhppote.Device, authorized []string) error

type SystemMonitor

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

func NewSystemMonitor

func NewSystemMonitor(mqttd *MQTTD) *SystemMonitor

func (*SystemMonitor) Alert

func (m *SystemMonitor) Alert(monitor monitoring.Monitor, msg string) error

func (*SystemMonitor) Alive

func (m *SystemMonitor) Alive(monitor monitoring.Monitor, msg string) error

type Topics

type Topics struct {
	Requests string
	Replies  string
	Events   struct {
		Feed string
		Live string
	}
	System string
}