| | |
| | | BroadcastInterval = 5 |
| | | MaxQueryRespSize = 50 * 1024 * 1024 |
| | | MaxQuerySize = 50 * 1024 * 1024 |
| | | MaxUserEventSize = 9 * 1024 |
| | | MaxUserEventSize = 9 * 1024 * 10 |
| | | ReplayOnJoinDefault = false |
| | | SnapshotPathDefault = "./serfSnapShot" |
| | | MaxEventBufferCount = 2048 |
| | |
| | | Mode: ModeSingle, |
| | | Config: agentConf, |
| | | ClusterPort: DefaultClusterPort, |
| | | Ctx: context.Background(), |
| | | } |
| | | } |
| | | |
| | |
| | | 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 |