wip

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/alleventmode/AbstractAllEventReconciler.java

@@ -9,44 +9,12 @@ public class AbstractAllEventReconciler {
   public static final String NO_MORE_EXCEPTION_ANNOTATION_KEY = "no.more.exception";
 
   protected volatile boolean useFinalizer = true;
-  protected volatile boolean throwExceptionOnFirstDeleteEvent = false;
-  protected volatile boolean throwExceptionIfNoAnnotation = false;
 
-  protected volatile boolean waitAfterFirstRetry = false;
-  protected volatile boolean continuerOnRetryWait = false;
-  protected volatile boolean waiting = false;
-
-  protected volatile boolean isFirstDeleteEvent = true;
+  private final AtomicInteger eventCounter = new AtomicInteger(0);
 
-  private boolean resourceEventPresent = false;
   private boolean deleteEventPresent = false;
   private boolean eventOnMarkedForDeletion = false;
-
-  private final AtomicInteger eventCounter = new AtomicInteger(0);
-
-  public boolean isResourceEventPresent() {
-    return resourceEventPresent;
-  }
-
-  public void setResourceEventPresent(boolean resourceEventPresent) {
-    this.resourceEventPresent = resourceEventPresent;
-  }
-
-  public boolean isDeleteEventPresent() {
-    return deleteEventPresent;
-  }
-
-  public void setDeleteEventPresent(boolean deleteEventPresent) {
-    this.deleteEventPresent = deleteEventPresent;
-  }
-
-  public boolean isEventOnMarkedForDeletion() {
-    return eventOnMarkedForDeletion;
-  }
-
-  public void setEventOnMarkedForDeletion(boolean eventOnMarkedForDeletion) {
-    this.eventOnMarkedForDeletion = eventOnMarkedForDeletion;
-  }
+  private boolean resourceEventPresent = false;
 
   public int getEventCount() {
     return eventCounter.get();
@@ -64,51 +32,27 @@ public void setUseFinalizer(boolean useFinalizer) {
     this.useFinalizer = useFinalizer;
   }
 
-  public boolean isFirstDeleteEvent() {
-    return isFirstDeleteEvent;
-  }
-
-  public void setFirstDeleteEvent(boolean firstDeleteEvent) {
-    isFirstDeleteEvent = firstDeleteEvent;
-  }
-
-  public boolean isThrowExceptionOnFirstDeleteEvent() {
-    return throwExceptionOnFirstDeleteEvent;
-  }
-
-  public void setThrowExceptionOnFirstDeleteEvent(boolean throwExceptionOnFirstDeleteEvent) {
-    this.throwExceptionOnFirstDeleteEvent = throwExceptionOnFirstDeleteEvent;
-  }
-
-  public boolean isThrowExceptionIfNoAnnotation() {
-    return throwExceptionIfNoAnnotation;
-  }
-
-  public void setThrowExceptionIfNoAnnotation(boolean throwExceptionIfNoAnnotation) {
-    this.throwExceptionIfNoAnnotation = throwExceptionIfNoAnnotation;
-  }
-
-  public boolean isWaitAfterFirstRetry() {
-    return waitAfterFirstRetry;
+  public boolean isDeleteEventPresent() {
+    return deleteEventPresent;
   }
 
-  public void setWaitAfterFirstRetry(boolean waitAfterFirstRetry) {
-    this.waitAfterFirstRetry = waitAfterFirstRetry;
+  public void setDeleteEventPresent(boolean deleteEventPresent) {
+    this.deleteEventPresent = deleteEventPresent;
   }
 
-  public boolean isContinuerOnRetryWait() {
-    return continuerOnRetryWait;
+  public boolean isEventOnMarkedForDeletion() {
+    return eventOnMarkedForDeletion;
   }
 
-  public void setContinuerOnRetryWait(boolean continuerOnRetryWait) {
-    this.continuerOnRetryWait = continuerOnRetryWait;
+  public void setEventOnMarkedForDeletion(boolean eventOnMarkedForDeletion) {
+    this.eventOnMarkedForDeletion = eventOnMarkedForDeletion;
   }
 
-  public boolean isWaiting() {
-    return waiting;
+  public boolean isResourceEventPresent() {
+    return resourceEventPresent;
   }
 
-  public void setWaiting(boolean waiting) {
-    this.waiting = waiting;
+  public void setResourceEventPresent(boolean resourceEventPresent) {
+    this.resourceEventPresent = resourceEventPresent;
   }
 }

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/alleventmode/onlyreconcile/AllEventReconciler.java

@@ -19,6 +19,15 @@ public class AllEventReconciler extends AbstractAllEventReconciler
 
   private static final Logger log = LoggerFactory.getLogger(AllEventReconciler.class);
 
+  private volatile boolean throwExceptionOnFirstDeleteEvent = false;
+  private volatile boolean throwExceptionIfNoAnnotation = false;
+
+  private volatile boolean waitAfterFirstRetry = false;
+  private volatile boolean continuerOnRetryWait = false;
+  private volatile boolean waiting = false;
+
+  private volatile boolean isFirstDeleteEvent = true;
+
   @Override
   public UpdateControl<AllEventCustomResource> reconcile(
       AllEventCustomResource primary, Context<AllEventCustomResource> context)
@@ -72,4 +81,52 @@ && isThrowExceptionOnFirstDeleteEvent()) {
     log.info("Reconciliation finished");
     return UpdateControl.noUpdate();
   }
+
+  public boolean isFirstDeleteEvent() {
+    return isFirstDeleteEvent;
+  }
+
+  public void setFirstDeleteEvent(boolean firstDeleteEvent) {
+    isFirstDeleteEvent = firstDeleteEvent;
+  }
+
+  public boolean isThrowExceptionOnFirstDeleteEvent() {
+    return throwExceptionOnFirstDeleteEvent;
+  }
+
+  public void setThrowExceptionOnFirstDeleteEvent(boolean throwExceptionOnFirstDeleteEvent) {
+    this.throwExceptionOnFirstDeleteEvent = throwExceptionOnFirstDeleteEvent;
+  }
+
+  public boolean isThrowExceptionIfNoAnnotation() {
+    return throwExceptionIfNoAnnotation;
+  }
+
+  public void setThrowExceptionIfNoAnnotation(boolean throwExceptionIfNoAnnotation) {
+    this.throwExceptionIfNoAnnotation = throwExceptionIfNoAnnotation;
+  }
+
+  public boolean isWaitAfterFirstRetry() {
+    return waitAfterFirstRetry;
+  }
+
+  public void setWaitAfterFirstRetry(boolean waitAfterFirstRetry) {
+    this.waitAfterFirstRetry = waitAfterFirstRetry;
+  }
+
+  public boolean isContinuerOnRetryWait() {
+    return continuerOnRetryWait;
+  }
+
+  public void setContinuerOnRetryWait(boolean continuerOnRetryWait) {
+    this.continuerOnRetryWait = continuerOnRetryWait;
+  }
+
+  public boolean isWaiting() {
+    return waiting;
+  }
+
+  public void setWaiting(boolean waiting) {
+    this.waiting = waiting;
+  }
 }