基于serf的数据库同步模块库
liuxiaolong
2020-09-16 4f3a5a019ca1e5a3c81acdd4124253e7a86bc6d0
set SyncDbTablePersonCacheChan size 512
1个文件已修改
2 ■■■ 已修改文件
agent.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
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"