基于serf的数据库同步模块库
liuxiaolong
2020-09-16 4f3a5a019ca1e5a3c81acdd4124253e7a86bc6d0
agent.go
@@ -114,7 +114,7 @@
   go a.BroadcastMemberlist(BroadcastInterval * time.Second)
}
var SyncDbTablePersonCacheChan = make(chan []byte,0)
var SyncDbTablePersonCacheChan = 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"