Skip to content

Commit f50727b

Browse files
authored
feat: add default stop handler (#1572)
1 parent f9f7b52 commit f50727b

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ConfigurationService.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@
55
import java.util.concurrent.ExecutorService;
66
import java.util.concurrent.Executors;
77

8+
import org.slf4j.Logger;
9+
import org.slf4j.LoggerFactory;
10+
811
import io.fabric8.kubernetes.api.model.HasMetadata;
912
import io.fabric8.kubernetes.client.Config;
1013
import io.fabric8.kubernetes.client.CustomResource;
@@ -150,6 +153,12 @@ default Optional<LeaderElectionConfiguration> getLeaderElectionConfiguration() {
150153
}
151154

152155
default Optional<InformerStoppedHandler> getInformerStoppedHandler() {
153-
return Optional.empty();
156+
return Optional.of((informer, ex) -> {
157+
if (ex != null) {
158+
Logger log = LoggerFactory.getLogger(ConfigurationService.class);
159+
log.error("Fatal error in informer: {}. Stopping the operator", informer, ex);
160+
System.exit(1);
161+
}
162+
});
154163
}
155164
}

0 commit comments

Comments
 (0)