(nodeID string)
| 167 | } |
| 168 | |
| 169 | func (c *ClusterChecker) resetFailureCount(nodeID string) { |
| 170 | c.failureMu.Lock() |
| 171 | delete(c.failureCounts, nodeID) |
| 172 | c.failureMu.Unlock() |
| 173 | } |
| 174 | |
| 175 | func (c *ClusterChecker) sendSyncEvent() { |
| 176 | select { |
no outgoing calls