Versions in this module Expand all Collapse all v0 v0.0.1 Feb 6, 2022 Changes in this version + const Connect + const Disconnect + const Kafka + const Publish + const Subscribe + const Unsubscribe + func InitKafka() *kafka + type BridgeMQ interface + Publish func(e *Elements) error + func NewBridgeMQ(name string) BridgeMQ + type Elements struct + Action string + ClientID string + Payload string + Size int32 + Timestamp int64 + Topic string + Username string