(interval time.Duration)
| 89 | } |
| 90 | |
| 91 | func (c *ClusterChecker) WithPingInterval(interval time.Duration) *ClusterChecker { |
| 92 | c.options.pingInterval = interval |
| 93 | if c.options.pingInterval < 200*time.Millisecond { |
| 94 | c.options.pingInterval = 200 * time.Millisecond |
| 95 | } |
| 96 | return c |
| 97 | } |
| 98 | |
| 99 | func (c *ClusterChecker) WithMaxFailureCount(count int64) *ClusterChecker { |
| 100 | c.options.maxFailureCount = count |
no outgoing calls