mqtt

type Handler func(topic string, msg map[string]any) error

type PubSub interface {
	Publish(ctx context.Context, topic string, msg any) error
	Subscribe(ctx context.Context, topic string, handler Handler) error
	Unsubscribe(ctx context.Context, topic string) error
	Disconnect(ctx context.Context) error
}

type TLSConfig struct {
	CAPath             string
	CertPath           string
	KeyPath            string
	InsecureSkipVerify bool
}