kitty-mqtt

go get github.com/objenious/kitty-mqtt

Status: alpha - breaking changes might happen

kitty-mqtt adds support for any Message Queue to kitty.

MQTT

Connect to MQTT :

tr := mqtt.NewTransport(ctx, "URL").
  Endpoint(topicName, endpoint, Decoder(decodeFunc))
err := kitty.NewServer(tr).Run(ctx)

If your service needs to run on Kubernetes, you also need to have a http transport for keep-alives :

tr := mqtt.NewTransport(ctx, "URL").
  Endpoint(topicName, endpoint, Decoder(decodeFunc))
h := kitty.NewHTTPTransport(kitty.Config{HTTPPort: 8080})
err := kitty.NewServer(tr, h).Run(ctx)