fix: do not handle irrelevant errors

influxdata · Jan 14, 2022 · 65161d6 · 65161d6
1 parent 200df6a
commit 65161d6
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/client/controller.rs b/src/client/controller.rs
@@ -96,13 +96,16 @@ impl ControllerClient {
             };
 
             match error {
+                // broken connection
                 Error::Request(RequestError::Poisoned(_) | RequestError::IO(_))
                 | Error::Connection(_) => self.invalidate_cached_controller_broker().await,
-                Error::ServerError(ProtocolError::LeaderNotAvailable, _) => {}
-                Error::ServerError(ProtocolError::OffsetNotAvailable, _) => {}
+
+                // our broker is actually not the controller
                 Error::ServerError(ProtocolError::NotController, _) => {
                     self.invalidate_cached_controller_broker().await;
                 }
+
+                // fatal
                 _ => {
                     error!(
                         e=%error,