internal

Documentation

Index

• func MQTTPublish(client mqtt.Client, topic string, message []byte)
• func MQTTSetup(config Config) (*mqtt.Client, error)
• type Config
• type Email
  • func ReadEmail(reader io.Reader) (*Email, error)

Functions

func MQTTPublish

func MQTTPublish(client mqtt.Client, topic string, message []byte)

func MQTTSetup

func MQTTSetup(config Config) (*mqtt.Client, error)

Types

type Config

type Config struct {
	Broker         string `json:"broker"`
	Port           uint   `json:"port"`
	ClientIDPrefix string `json:"clientIdPrefix"`
	Topic          string `json:"topic"`
	UseSSL         bool   `json:"useSSL"`
	Username       string `json:"username"`
	Password       string `json:"password"`
}

type Email

type Email struct {
	Headers   map[string]string `json:"headers"`
	BodyParts map[string]string `json:"bodyParts"`
}

func ReadEmail

func ReadEmail(reader io.Reader) (*Email, error)