()
| 505 | } |
| 506 | |
| 507 | func (c *Client) resetReconnectFailures() { |
| 508 | if c == nil { |
| 509 | return |
| 510 | } |
| 511 | c.mu.Lock() |
| 512 | c.reconnectFailures = 0 |
| 513 | c.mu.Unlock() |
| 514 | } |
| 515 | |
| 516 | func (c *Client) GetConfig(ctx context.Context) ([]byte, error) { |
| 517 | c.refreshBestClusterNode(ctx) |
no outgoing calls
no test coverage detected