add SyncVirtualIp

liuxiaolong

2020-10-22 052fe5fb54c324c297771f5e810be7b279287abc

add SyncVirtualIp

 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
        }