()
| 265 | } |
| 266 | |
| 267 | func (i *ClusterIterator) fetchRoutingTablePeriodically() { |
| 268 | defer i.wg.Done() |
| 269 | |
| 270 | for { |
| 271 | select { |
| 272 | case <-i.ctx.Done(): |
| 273 | return |
| 274 | case <-time.After(time.Second): |
| 275 | if err := i.fetchRoutingTable(); err != nil { |
| 276 | i.logger.Printf("[ERROR] Failed to fetch the latest version of the routing table: %s", err) |
| 277 | } |
| 278 | } |
| 279 | } |
| 280 | } |
| 281 | |
| 282 | func (i *ClusterIterator) fetchRoutingTable() error { |
| 283 | routingTable, err := i.clusterClient.RoutingTable(i.ctx) |
no test coverage detected