gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2024-11-10 17:48:25 +08:00
Code Issues Projects Releases Packages Wiki Activity

migrate emqx

Browse source
This commit is contained in:
abhishek9686 2024-03-01 14:59:47 +07:00
parent 81af1d92c0
commit 2e3b640a9a
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
migrate/migrate.go
View file

@ -4,6 +4,7 @@ import (
"encoding/json"
"fmt"
"log"
"time"
"golang.org/x/exp/slog"
@ -300,11 +301,13 @@ func MigrateEmqx() {
err := mq.SendPullSYN()
if err != nil {
logger.Log(0, "failed to send pull syn to clients", "error", err.Error())
slog.Info("proceeding to kicking out clients from emqx")
err := mq.KickOutClients()
if err != nil {
logger.Log(0, "failed to migrate emqx: ", "kickout-error", err.Error())
}
}
time.Sleep(time.Second * 3)
slog.Info("proceeding to kicking out clients from emqx")
err = mq.KickOutClients()
if err != nil {
logger.Log(0, "failed to migrate emqx: ", "kickout-error", err.Error())
}
}