Skip to content

Commit ada8825

Browse files
committed
Only one Condition type
1 parent c2bdb5d commit ada8825

File tree

9 files changed

+25
-92
lines changed

9 files changed

+25
-92
lines changed
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
1-
package io.javaoperatorsdk.operator.processing.dependent.workflow.condition;
1+
package io.javaoperatorsdk.operator.processing.dependent.workflow;
22

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.api.reconciler.Context;
55
import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
66

7-
public interface ReadyCondition<R, P extends HasMetadata> {
7+
public interface Condition<R, P extends HasMetadata> {
88

99
boolean isMet(DependentResource<R, P> dependentResource, P primary, Context<P> context);
10-
1110
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/DependentResourceNode.java

Lines changed: 11 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -6,29 +6,26 @@
66

77
import io.fabric8.kubernetes.api.model.HasMetadata;
88
import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
9-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.CleanupCondition;
10-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReadyCondition;
11-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReconcileCondition;
129

1310
public class DependentResourceNode<R, P extends HasMetadata> {
1411

1512
private final DependentResource<R, P> dependentResource;
16-
private ReconcileCondition<P> reconcileCondition;
17-
private CleanupCondition cleanupCondition;
18-
private ReadyCondition<R, P> readyCondition;
13+
private Condition reconcileCondition;
14+
private Condition cleanupCondition;
15+
private Condition readyCondition;
1916
private List<DependentResourceNode> dependsOn = new ArrayList<>(1);
2017

2118
public DependentResourceNode(DependentResource<R, P> dependentResource) {
2219
this(dependentResource, null, null);
2320
}
2421

2522
public DependentResourceNode(DependentResource<R, P> dependentResource,
26-
ReconcileCondition<P> reconcileCondition) {
23+
Condition reconcileCondition) {
2724
this(dependentResource, reconcileCondition, null);
2825
}
2926

3027
public DependentResourceNode(DependentResource<R, P> dependentResource,
31-
ReconcileCondition<P> reconcileCondition, CleanupCondition cleanupCondition) {
28+
Condition reconcileCondition, Condition cleanupCondition) {
3229
this.dependentResource = dependentResource;
3330
this.reconcileCondition = reconcileCondition;
3431
this.cleanupCondition = cleanupCondition;
@@ -38,11 +35,11 @@ public DependentResource<R, P> getDependentResource() {
3835
return dependentResource;
3936
}
4037

41-
public Optional<ReconcileCondition<P>> getReconcileCondition() {
38+
public Optional<Condition> getReconcileCondition() {
4239
return Optional.ofNullable(reconcileCondition);
4340
}
4441

45-
public Optional<CleanupCondition> getCleanupCondition() {
42+
public Optional<Condition> getCleanupCondition() {
4643
return Optional.ofNullable(cleanupCondition);
4744
}
4845

@@ -66,21 +63,21 @@ public String toString() {
6663
}
6764

6865
public DependentResourceNode<R, P> setReconcileCondition(
69-
ReconcileCondition<P> reconcileCondition) {
66+
Condition reconcileCondition) {
7067
this.reconcileCondition = reconcileCondition;
7168
return this;
7269
}
7370

74-
public DependentResourceNode<R, P> setCleanupCondition(CleanupCondition cleanupCondition) {
71+
public DependentResourceNode<R, P> setCleanupCondition(Condition cleanupCondition) {
7572
this.cleanupCondition = cleanupCondition;
7673
return this;
7774
}
7875

79-
public Optional<ReadyCondition<R, P>> getReadyCondition() {
76+
public Optional<Condition<R, P>> getReadyCondition() {
8077
return Optional.ofNullable(readyCondition);
8178
}
8279

83-
public DependentResourceNode<R, P> setReadyCondition(ReadyCondition<R, P> readyCondition) {
80+
public DependentResourceNode<R, P> setReadyCondition(Condition readyCondition) {
8481
this.readyCondition = readyCondition;
8582
return this;
8683
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/DependsOnRelation.java

Lines changed: 0 additions & 36 deletions
This file was deleted.

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutor.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import io.javaoperatorsdk.operator.api.reconciler.Context;
1212
import io.javaoperatorsdk.operator.api.reconciler.dependent.Deleter;
1313
import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
14-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReconcileCondition;
1514

1615
public class WorkflowReconcileExecutor<P extends HasMetadata> {
1716

@@ -189,7 +188,7 @@ private boolean alreadyReconciled(
189188

190189

191190
private void handleReconcileCondition(DependentResourceNode<?, ?> dependentResourceNode,
192-
ReconcileCondition reconcileCondition) {
191+
Condition reconcileCondition) {
193192
boolean conditionMet =
194193
reconcileCondition.isMet(dependentResourceNode.getDependentResource(), primary, context);
195194
if (!conditionMet) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/builder/DependentBuilder.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,8 @@
22

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
5+
import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
56
import io.javaoperatorsdk.operator.processing.dependent.workflow.DependentResourceNode;
6-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.CleanupCondition;
7-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReadyCondition;
8-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReconcileCondition;
97

108
public class DependentBuilder<P extends HasMetadata> {
119

@@ -25,17 +23,17 @@ public DependentBuilder<P> dependsOn(DependentResource<?, ?>... dependentResourc
2523
return this;
2624
}
2725

28-
public DependentBuilder<P> withReconcileCondition(ReconcileCondition reconcileCondition) {
26+
public DependentBuilder<P> withReconcileCondition(Condition reconcileCondition) {
2927
node.setReconcileCondition(reconcileCondition);
3028
return this;
3129
}
3230

33-
public DependentBuilder<P> withReadyCondition(ReadyCondition readyCondition) {
31+
public DependentBuilder<P> withReadyCondition(Condition readyCondition) {
3432
node.setReadyCondition(readyCondition);
3533
return this;
3634
}
3735

38-
public DependentBuilder<P> withCleanupCondition(CleanupCondition readyCondition) {
36+
public DependentBuilder<P> withCleanupCondition(Condition readyCondition) {
3937
node.setCleanupCondition(readyCondition);
4038
return this;
4139
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/condition/CleanupCondition.java

Lines changed: 0 additions & 10 deletions
This file was deleted.

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/condition/ReconcileCondition.java

Lines changed: 0 additions & 11 deletions
This file was deleted.

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowCleanupExecutorTest.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
import org.junit.jupiter.api.Test;
44

55
import io.javaoperatorsdk.operator.processing.dependent.workflow.builder.WorkflowBuilder;
6-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.CleanupCondition;
76
import io.javaoperatorsdk.operator.sample.simple.TestCustomResource;
87

98
import static io.javaoperatorsdk.operator.processing.dependent.workflow.ExecutionAssert.assertThat;
@@ -16,9 +15,9 @@ class WorkflowCleanupExecutorTest extends AbstractWorkflowExecutorTest {
1615

1716
protected TestErrorDeleterDependent errorDD = new TestErrorDeleterDependent("ERROR_DELETER");
1817

19-
private final CleanupCondition noMetCleanupCondition =
18+
private final Condition noMetCleanupCondition =
2019
(dependentResource, primary, context) -> false;
21-
private final CleanupCondition metCleanupCondition =
20+
private final Condition metCleanupCondition =
2221
(dependentResource, primary, context) -> true;
2322

2423
@Test

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/dependent/workflow/WorkflowReconcileExecutorTest.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,6 @@
55

66
import io.javaoperatorsdk.operator.AggregatedOperatorException;
77
import io.javaoperatorsdk.operator.processing.dependent.workflow.builder.WorkflowBuilder;
8-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReadyCondition;
9-
import io.javaoperatorsdk.operator.processing.dependent.workflow.condition.ReconcileCondition;
108
import io.javaoperatorsdk.operator.sample.simple.TestCustomResource;
119

1210
import static io.javaoperatorsdk.operator.processing.dependent.workflow.ExecutionAssert.*;
@@ -15,17 +13,17 @@
1513
class WorkflowReconcileExecutorTest extends AbstractWorkflowExecutorTest {
1614

1715
public static final String NOT_READY_YET = "NOT READY YET";
18-
private ReconcileCondition met_reconcile_condition =
16+
private Condition met_reconcile_condition =
1917
(dependentResource, primary, context) -> true;
20-
private ReconcileCondition not_met_reconcile_condition =
18+
private Condition not_met_reconcile_condition =
2119
(dependentResource, primary, context) -> false;
2220

23-
private ReadyCondition<String, TestCustomResource> metReadyCondition =
21+
private Condition<String, TestCustomResource> metReadyCondition =
2422
(dependentResource, primary, context) -> true;
25-
private ReadyCondition<String, TestCustomResource> notMetReadyCondition =
23+
private Condition<String, TestCustomResource> notMetReadyCondition =
2624
(dependentResource, primary, context) -> false;
2725

28-
private ReadyCondition<String, TestCustomResource> notMetReadyConditionWithStatusUpdate =
26+
private Condition<String, TestCustomResource> notMetReadyConditionWithStatusUpdate =
2927
(dependentResource, primary, context) -> false;
3028

3129
@Test

0 commit comments

Comments
 (0)