Skip to content

Commit 40f19f5

Browse files
author
Soroosh Sarabadani
committed
Use getDefaultFinalizerName in the code to get the controller finalizer name.
1 parent e3f343b commit 40f19f5

File tree

5 files changed

+11
-11
lines changed

5 files changed

+11
-11
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ private <R extends CustomResource> void registerController(ResourceController<R>
5555
Class<R> resClass = ControllerUtils.getCustomResourceClass(controller);
5656
CustomResourceDefinitionContext crd = getCustomResourceDefinitionForController(controller);
5757
KubernetesDeserializer.registerCustomKind(crd.getVersion(), crd.getKind(), resClass);
58-
String finalizer = ControllerUtils.getDefaultFinalizer(controller);
58+
String finalizer = ControllerUtils.getFinalizer(controller);
5959
MixedOperation client = k8sClient.customResources(crd, resClass, CustomResourceList.class, ControllerUtils.getCustomResourceDoneableClass(controller));
6060
EventDispatcher eventDispatcher = new EventDispatcher(controller,
6161
finalizer, new EventDispatcher.CustomResourceFacade(client), ControllerUtils.getGenerationEventProcessing(controller));

operator-framework/src/test/java/io/javaoperatorsdk/operator/EventDispatcherTest.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ class EventDispatcherTest {
2828
@BeforeEach
2929
void setup() {
3030
eventDispatcher = new EventDispatcher(controller,
31-
Controller.DEFAULT_FINALIZER, customResourceFacade, false);
31+
controller.getDefaultFinalizerName(), customResourceFacade, false);
3232

3333
testCustomResource = getResource();
3434

@@ -45,7 +45,7 @@ void callCreateOrUpdateOnNewResource() {
4545

4646
@Test
4747
void updatesOnlyStatusSubResource() {
48-
testCustomResource.getMetadata().getFinalizers().add(Controller.DEFAULT_FINALIZER);
48+
testCustomResource.getMetadata().getFinalizers().add(controller.getDefaultFinalizerName());
4949
when(controller.createOrUpdateResource(eq(testCustomResource), any()))
5050
.thenReturn(UpdateControl.updateStatusSubResource(testCustomResource));
5151

@@ -67,13 +67,13 @@ void adsDefaultFinalizerOnCreateIfNotThere() {
6767
eventDispatcher.handleEvent(customResourceEvent(Watcher.Action.MODIFIED, testCustomResource));
6868
verify(controller, times(1))
6969
.createOrUpdateResource(argThat(testCustomResource ->
70-
testCustomResource.getMetadata().getFinalizers().contains(Controller.DEFAULT_FINALIZER)), any());
70+
testCustomResource.getMetadata().getFinalizers().contains(controller.getDefaultFinalizerName())), any());
7171
}
7272

7373
@Test
7474
void callsDeleteIfObjectHasFinalizerAndMarkedForDelete() {
7575
testCustomResource.getMetadata().setDeletionTimestamp("2019-8-10");
76-
testCustomResource.getMetadata().getFinalizers().add(Controller.DEFAULT_FINALIZER);
76+
testCustomResource.getMetadata().getFinalizers().add(controller.getDefaultFinalizerName());
7777

7878
eventDispatcher.handleEvent(customResourceEvent(Watcher.Action.MODIFIED, testCustomResource));
7979

@@ -183,7 +183,7 @@ void doesNotMarkNewGenerationInCaseOfException() {
183183

184184
void generationAwareMode() {
185185
eventDispatcher = new EventDispatcher(controller,
186-
Controller.DEFAULT_FINALIZER, customResourceFacade, true);
186+
controller.getDefaultFinalizerName(), customResourceFacade, true);
187187
}
188188

189189
private void markForDeletion(CustomResource customResource) {
@@ -202,7 +202,7 @@ CustomResource getResource() {
202202
.withDeletionGracePeriodSeconds(10L)
203203
.withGeneration(10L)
204204
.withName("name")
205-
.withFinalizers(Controller.DEFAULT_FINALIZER)
205+
.withFinalizers(controller.getDefaultFinalizerName())
206206
.withNamespace("namespace")
207207
.withResourceVersion("resourceVersion")
208208
.withSelfLink("selfLink")

operator-framework/src/test/java/io/javaoperatorsdk/operator/SubResourceUpdateIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public SubResourceTestCustomResource createTestCustomResource(String id) {
104104
resource.setMetadata(new ObjectMetaBuilder()
105105
.withName("subresource-" + id)
106106
.withNamespace(TEST_NAMESPACE)
107-
.withFinalizers(Controller.DEFAULT_FINALIZER)
107+
.withFinalizers("finalizer")
108108
.build());
109109
resource.setKind("SubresourceSample");
110110
resource.setSpec(new SubResourceTestCustomResourceSpec());

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/TestCustomResourceController.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public boolean deleteResource(TestCustomResource resource, Context<TestCustomRes
5555
public UpdateControl<TestCustomResource> createOrUpdateResource(TestCustomResource resource,
5656
Context<TestCustomResource> context) {
5757
numberOfExecutions.addAndGet(1);
58-
if (!resource.getMetadata().getFinalizers().contains(Controller.DEFAULT_FINALIZER)) {
58+
if (!resource.getMetadata().getFinalizers().contains(this.getDefaultFinalizerName())) {
5959
throw new IllegalStateException("Finalizer is not present.");
6060
}
6161

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/subresource/SubResourceTestCustomResourceController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public class SubResourceTestCustomResourceController implements ResourceControll
1919

2020
public static final String CRD_NAME = "subresourcesample.sample.javaoperatorsdk";
2121
private static final Logger log = LoggerFactory.getLogger(SubResourceTestCustomResourceController.class);
22-
private AtomicInteger numberOfExecutions = new AtomicInteger(0);
22+
private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
2323

2424
@Override
2525
public boolean deleteResource(SubResourceTestCustomResource resource, Context<SubResourceTestCustomResource> context) {
@@ -30,7 +30,7 @@ public boolean deleteResource(SubResourceTestCustomResource resource, Context<Su
3030
public UpdateControl<SubResourceTestCustomResource> createOrUpdateResource(SubResourceTestCustomResource resource,
3131
Context<SubResourceTestCustomResource> context) {
3232
numberOfExecutions.addAndGet(1);
33-
if (!resource.getMetadata().getFinalizers().contains(Controller.DEFAULT_FINALIZER)) {
33+
if (!resource.getMetadata().getFinalizers().contains(this.getDefaultFinalizerName())) {
3434
throw new IllegalStateException("Finalizer is not present.");
3535
}
3636
log.info("Value: " + resource.getSpec().getValue());

0 commit comments

Comments
 (0)