Add paho client, add broker config

Add a queue struct
Add broker config.
CovenantSQL · laodouya · laodouya · laodouya · Jun 21, 2019 · laodouya
diff --git a/conf/config.go b/conf/config.go
@@ -106,6 +106,14 @@ type DNSSeed struct {
 	BPCount        int      `yaml:"BPCount"`
 }

+type MQTTBrokerInfo struct {
diff --git a/sqlchain/chain.go b/sqlchain/chain.go
@@ -1020,6 +1020,10 @@ func (c *Chain) AddResponse(resp *types.SignedResponseHeader) (err error) {
 	return c.ai.addResponse(c.rt.getHeightFromTime(resp.GetRequestTimestamp()), resp)
 }

+func (c *Chain) GetPeerLeaderID() proto.NodeID {
diff --git a/worker/broker.go b/worker/broker.go
+	"github.com/gogf/gf/g/container/gqueue"
+)
+
+type MQTTAPI string
diff --git a/worker/broker.go b/worker/broker.go
+type MQTTAPI string
+
+const (
+	//Publish API
diff --git a/worker/broker.go b/worker/broker.go
+const (
+	//Publish API
+	MQTTNewest MQTTAPI = "newest"
+	DSNList    MQTTAPI = "dsnlist"
diff --git a/worker/broker.go b/worker/broker.go
+type SubscribeEvent struct {
+	ClientID   proto.NodeID
+	DatabaseID proto.DatabaseID
+	ApiName    MQTTAPI
diff --git a/worker/broker.go b/worker/broker.go
+	Payload    BrokerPayload
+}
+
+type MQTTClient struct {
diff --git a/worker/broker.go b/worker/broker.go
+	return dests
+}
+
+func NewMQTTClient(config *conf.MQTTBrokerInfo, dbms *DBMS) (c *MQTTClient) {
diff --git a/worker/broker.go b/worker/broker.go
+	}
+}
+
+func (c *MQTTClient) PublishDSN(apiName MQTTAPI, databaseID proto.DatabaseID, payload BrokerPayload, requestClient proto.NodeID) error {
diff --git a/worker/broker.go b/worker/broker.go
+	return nil
+}
+
+func (c *MQTTClient) Close() {