connect

type Connection interface {
	// Connect to MQTT server
	Connect() error
	// Disconnect from MQTT Server
	Disconnect(timeout uint)

	Publish(topic string, payload interface{}) mqtt.Token

	Subscribe(topic string, handler mqtt.MessageHandler) error
}

type ConnectionConfiguration struct {
	KeyPair  KeyPair
	Endpoint string
	Port     int
	ClientId string
}

type KeyPair struct {
	PrivateKeyPath    string
	CertificatePath   string
	CACertificatePath string
}