in computer-k8s-operator/src/main/java/org/apache/hugegraph/computer/k8s/operator/OperatorEntrypoint.java [153:186]
public synchronized void shutdown() {
LOG.info("The Operator shutdown...");
Iterator<AbstractController<?>> iterator = this.controllers.iterator();
while (iterator.hasNext()) {
AbstractController<?> controller = iterator.next();
if (controller != null) {
controller.shutdown();
}
iterator.remove();
}
if (this.controllerPool != null) {
this.controllerPool.shutdown();
this.controllerPool = null;
}
if (this.informerFactory != null) {
this.informerFactory.stopAllRegisteredInformers();
this.informerFactory = null;
}
if (this.kubeClient != null) {
this.kubeClient.close();
this.kubeClient = null;
}
if (this.httpServer != null) {
this.httpServer.stop(0);
this.httpServer = null;
}
LogManager.shutdown();
}