Operator API change

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java

@@ -77,14 +77,24 @@ public Operator(KubernetesClient kubernetesClient, ConfigurationService configur
         .ifPresent(c -> leaderElectionManager.init(c, this.kubernetesClient));
   }
 
+  /**
+   * Uses {@link ConfigurationService#getTerminationTimeoutSeconds()} for graceful shutdown timeout
+   */
+  @Deprecated(forRemoval = true)
+  public void installShutdownHook() {
+    installShutdownHook(
+        Duration.ofSeconds(ConfigurationServiceProvider.instance().getTerminationTimeoutSeconds()));
+  }
+
   /**
    * Adds a shutdown hook that automatically calls {@link #stop()} when the app shuts down.
    *
-   * @deprecated This feature should not be used anymore
+   * @param gracefulShutdownTimeout - timeout to wait for executor threads to complete actual
+   *        reconciliations
    */
-  public void installShutdownHook() {
+  public void installShutdownHook(Duration gracefulShutdownTimeout) {
     if (!leaderElectionManager.isLeaderElectionEnabled()) {
-      Runtime.getRuntime().addShutdownHook(new Thread(this::stop));
+      Runtime.getRuntime().addShutdownHook(new Thread(() -> stop(gracefulShutdownTimeout)));
     } else {
       log.warn("Leader election is on, shutdown hook will not be installed.");
     }

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

@@ -121,6 +121,7 @@ public HasMetadata clone(HasMetadata object) {
    *
    * @return the number of seconds to wait before terminating reconciliation threads
    */
+  @Deprecated(forRemoval = true)
   default int getTerminationTimeoutSeconds() {
     return DEFAULT_TERMINATION_TIMEOUT_SECONDS;
   }