isRetriableListTopicsError returns true for controller errors and transient transport failures where reconnecting and retrying can succeed.
(err error)
| 271 | // isRetriableListTopicsError returns true for controller errors and transient |
| 272 | // transport failures where reconnecting and retrying can succeed. |
| 273 | func isRetriableListTopicsError(err error) bool { |
| 274 | if isRetriableControllerError(err) || shouldCloseBrokerConn(err) { |
| 275 | return true |
| 276 | } |
| 277 | |
| 278 | return isTimeoutError(err) |
| 279 | } |
| 280 | |
| 281 | // isRetriableBrokerError returns `true` if the given error is a retryable |
| 282 | // transport error or a timeout. |
nothing calls this directly
no test coverage detected