Pārlūkot izejas kodu

add ingress id to model

abhishek9686 10 mēneši atpakaļ
vecāks
revīzija
cd2d026fc8
2 mainītis faili ar 4 papildinājumiem un 2 dzēšanām
  1. 2 1
      logic/peers.go
  2. 2 1
      models/mqtt.go

+ 2 - 1
logic/peers.go

@@ -293,7 +293,8 @@ func GetPeerUpdateForHost(network string, host *models.Host, allNodes []models.N
 			extPeers, extPeerIDAndAddrs, egressRoutes, extUserIps, err = GetExtPeers(&node, &node)
 			if err == nil {
 				hostPeerUpdate.FwUpdate.IngressInfo[node.ID.String()] = models.IngressInfo{
-					UserIps: extUserIps,
+					IngressID: node.ID.String(),
+					UserIps:   extUserIps,
 				}
 				hostPeerUpdate.EgressRoutes = append(hostPeerUpdate.EgressRoutes, egressRoutes...)
 				hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, extPeers...)

+ 2 - 1
models/mqtt.go

@@ -28,7 +28,8 @@ type HostPeerUpdate struct {
 
 // IngressInfo - struct for ingress info
 type IngressInfo struct {
-	UserIps []net.IP
+	IngressID string   `json:"ingress_id"`
+	UserIps   []net.IP `json:"user_ips"`
 }
 
 // EgressInfo - struct for egress info