()
| 82 | } |
| 83 | |
| 84 | func (c *ClusterChecker) Start() { |
| 85 | c.wg.Add(1) |
| 86 | go c.probeLoop() |
| 87 | c.wg.Add(1) |
| 88 | go c.migrationLoop() |
| 89 | } |
| 90 | |
| 91 | func (c *ClusterChecker) WithPingInterval(interval time.Duration) *ClusterChecker { |
| 92 | c.options.pingInterval = interval |