浏览代码

update Action name to SignalPull

Max Ma 1 年之前
父节点
当前提交
73303221bc
共有 2 个文件被更改,包括 3 次插入3 次删除
  1. 2 2
      models/host.go
  2. 1 1
      mq/publishers.go

+ 2 - 2
models/host.go

@@ -116,8 +116,8 @@ const (
 	UpdateKeys HostMqAction = "UPDATE_KEYS"
 	// RequestPull - request a pull from a host
 	RequestPull HostMqAction = "REQ_PULL"
-	// JoinPull - request a pull from a host without restart
-	JoinPull HostMqAction = "JOIN_PULL"
+	// SignalPull - request a pull from a host without restart
+	SignalPull HostMqAction = "SIGNAL_PULL"
 	// UpdateMetrics - updates metrics data
 	UpdateMetrics HostMqAction = "UPDATE_METRICS"
 )

+ 1 - 1
mq/publishers.go

@@ -29,7 +29,7 @@ func PublishPeerUpdate(replacePeers bool) error {
 		host := host
 		go func(host models.Host) {
 			hostUpdate := models.HostUpdate{
-				Action: models.JoinPull,
+				Action: models.SignalPull,
 				Host:   host,
 			}
 			if err = HostUpdate(&hostUpdate); err != nil {