From 052fe5fb54c324c297771f5e810be7b279287abc Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期四, 22 十月 2020 16:34:43 +0800
Subject: [PATCH] add SyncVirtualIp
---
agent.go | 5 +++++
1 files changed, 5 insertions(+), 0 deletions(-)
diff --git a/agent.go b/agent.go
index 938cfa3..a2ae892 100644
--- a/agent.go
+++ b/agent.go
@@ -44,6 +44,7 @@
QueryEventUpdateDBData = "UpdateDBData"
UserEventSyncSql = "SyncSql"
UserEventSyncDbTablePersonCache = "SyncCache"
+ UserEventSyncVirtualIp = "SyncVirtualIp" //婕傜Щip淇敼
)
// Agent warps the serf agent
@@ -116,6 +117,7 @@
}
var SyncDbTablePersonCacheChan = make(chan []byte,512)
+var SyncVirtualIpChan = make(chan []byte, 512)
// HandleEvent Handles serf.EventMemberJoin events,
// which will wait for members to join until the number of group members is equal to "groupExpect"
@@ -157,6 +159,9 @@
} else if ev.Name == UserEventSyncDbTablePersonCache {
logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload))
SyncDbTablePersonCacheChan <- ev.Payload
+ } else if ev.Name == UserEventSyncVirtualIp {
+ logger.Info("LTime:", ev.LTime, " Recevie virtualIp change")
+ SyncVirtualIpChan <- ev.Payload
}
--
Gitblit v1.8.0