基于serf的数据库同步模块库
zhangzengfei
2023-05-15 0a86db67f14185ab2e08475fcafb64e43f0022dd
config.go
@@ -47,7 +47,7 @@
   BroadcastInterval  = 5
   MaxQueryRespSize   = 50 * 1024 * 1024
   MaxQuerySize       = 50 * 1024 * 1024
   MaxUserEventSize   = 9 * 1024
   MaxUserEventSize   = 9 * 1024 * 10
   ReplayOnJoinDefault = false
   SnapshotPathDefault = "./serfSnapShot"
   MaxEventBufferCount = 2048
@@ -163,7 +163,7 @@
   serfConf.MemberlistConfig.BindPort = bindPort
   serfConf.NodeName = c.NodeName
   serfConf.Tags = map[string]string{TagKeyRPCPort: strconv.Itoa(c.RPCPort)}
   serfConf.Tags = map[string]string{TagKeyRPCPort: strconv.Itoa(c.RPCPort), "role": "slave"}
   if c.ClusterID != "" {
      serfConf.Tags[tagKeyClusterID] = c.ClusterID