()
| 287 | } |
| 288 | |
| 289 | func (shard *ringShard) IsDown() bool { |
| 290 | const threshold = 3 |
| 291 | return atomic.LoadInt32(&shard.down) >= threshold |
| 292 | } |
| 293 | |
| 294 | func (shard *ringShard) IsUp() bool { |
| 295 | return !shard.IsDown() |
no outgoing calls
no test coverage detected