Merge pull request #3307 from gravitl/release-v0.30.0

add config to check for reset peer udpate
gravitl · Jan 21, 2025 · 648758c · 648758c
2 parents 77d5705 + 557270a
commit 648758c
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/controllers/hosts.go b/controllers/hosts.go
@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"os"
 
 	"github.com/google/uuid"
 	"github.com/gorilla/mux"
@@ -181,7 +182,11 @@ func pull(w http.ResponseWriter, r *http.Request) {
 		}
 	}
 	if sendPeerUpdate {
-		if err := mq.PublishPeerUpdate(true); err != nil {
+		reset := true
+		if os.Getenv("RESET_PEER_UPDATE") != "" {
+			reset = os.Getenv("RESET_PEER_UPDATE") == "true"
+		}
+		if err := mq.PublishPeerUpdate(reset); err != nil {
 			logger.Log(0, "fail to publish peer update: ", err.Error())
 		}
 	}