Skip to content

Commit 6df09b3

Browse files
committed
fix: grammar issue
Signed-off-by: Chris Laprun <metacosm@gmail.com>
1 parent 12960ca commit 6df09b3

File tree

21 files changed

+93
-68
lines changed

21 files changed

+93
-68
lines changed

docs/content/en/docs/documentation/reconciler.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -239,7 +239,7 @@ However, there are cases when controllers do not strictly follow those patterns,
239239
and you don't want to use finalizers. For those cases, you typically want to clean up your caches when the primary
240240
resource is deleted.
241241

242-
For such use cases you can set [`triggerReconcilerOnAllEvent`](https://github.com/operator-framework/java-operator-sdk/blob/main/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/ControllerConfiguration.java#L81)
242+
For such use cases you can set [`triggerReconcilerOnAllEvents`](https://github.com/operator-framework/java-operator-sdk/blob/main/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/ControllerConfiguration.java#L107)
243243
to `true`, as a result, the `reconcile` method will be triggered on ALL events (so also `Delete` events), making it
244244
possible to support the above use cases.
245245

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -319,8 +319,8 @@ private <P extends HasMetadata> ResolvedControllerConfiguration<P> controllerCon
319319
final var dependentFieldManager =
320320
fieldManager.equals(CONTROLLER_NAME_AS_FIELD_MANAGER) ? name : fieldManager;
321321

322-
var triggerReconcilerOnAllEvent =
323-
annotation != null && annotation.triggerReconcilerOnAllEvent();
322+
var triggerReconcilerOnAllEvents =
323+
annotation != null && annotation.triggerReconcilerOnAllEvents();
324324

325325
InformerConfiguration<P> informerConfig =
326326
InformerConfiguration.builder(resourceClass)
@@ -342,7 +342,7 @@ private <P extends HasMetadata> ResolvedControllerConfiguration<P> controllerCon
342342
dependentFieldManager,
343343
this,
344344
informerConfig,
345-
triggerReconcilerOnAllEvent);
345+
triggerReconcilerOnAllEvents);
346346
}
347347

348348
/**

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

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,15 @@ default String fieldManager() {
108108

109109
<C> C getConfigurationFor(DependentResourceSpec<?, P, C> spec);
110110

111+
/**
112+
* @deprecated use {@link #triggerReconcilerOnAllEvents()} instead
113+
*/
114+
@Deprecated(forRemoval = true)
111115
default boolean triggerReconcilerOnAllEvent() {
116+
return triggerReconcilerOnAllEvents();
117+
}
118+
119+
default boolean triggerReconcilerOnAllEvents() {
112120
return false;
113121
}
114122
}

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

Lines changed: 14 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public class ControllerConfigurationOverrider<R extends HasMetadata> {
4545
private Duration reconciliationMaxInterval;
4646
private Map<DependentResourceSpec, Object> configurations;
4747
private final InformerConfiguration<R>.Builder config;
48-
private boolean triggerReconcilerOnAllEvent;
48+
private boolean triggerReconcilerOnAllEvents;
4949

5050
private ControllerConfigurationOverrider(ControllerConfiguration<R> original) {
5151
this.finalizer = original.getFinalizerName();
@@ -58,7 +58,7 @@ private ControllerConfigurationOverrider(ControllerConfiguration<R> original) {
5858
this.rateLimiter = original.getRateLimiter();
5959
this.name = original.getName();
6060
this.fieldManager = original.fieldManager();
61-
this.triggerReconcilerOnAllEvent = original.triggerReconcilerOnAllEvent();
61+
this.triggerReconcilerOnAllEvents = original.triggerReconcilerOnAllEvents();
6262
}
6363

6464
public ControllerConfigurationOverrider<R> withFinalizer(String finalizer) {
@@ -171,9 +171,18 @@ public ControllerConfigurationOverrider<R> withFieldManager(String dependentFiel
171171
return this;
172172
}
173173

174+
/**
175+
* @deprecated use {@link #withTriggerReconcilerOnAllEvents(boolean)} instead
176+
*/
177+
@Deprecated(forRemoval = true)
174178
public ControllerConfigurationOverrider<R> withTriggerReconcilerOnAllEvent(
175-
boolean triggerReconcilerOnAllEvent) {
176-
this.triggerReconcilerOnAllEvent = triggerReconcilerOnAllEvent;
179+
boolean triggerReconcilerOnAllEvents) {
180+
return withTriggerReconcilerOnAllEvents(triggerReconcilerOnAllEvents);
181+
}
182+
183+
public ControllerConfigurationOverrider<R> withTriggerReconcilerOnAllEvents(
184+
boolean triggerReconcilerOnAllEvents) {
185+
this.triggerReconcilerOnAllEvents = triggerReconcilerOnAllEvents;
177186
return this;
178187
}
179188

@@ -221,7 +230,7 @@ public ControllerConfiguration<R> build() {
221230
fieldManager,
222231
original.getConfigurationService(),
223232
config.buildForController(),
224-
triggerReconcilerOnAllEvent,
233+
triggerReconcilerOnAllEvents,
225234
original.getWorkflowSpec().orElse(null));
226235
}
227236

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public class ResolvedControllerConfiguration<P extends HasMetadata>
4444
private final Map<DependentResourceSpec, Object> configurations;
4545
private final ConfigurationService configurationService;
4646
private final String fieldManager;
47-
private final boolean triggerReconcilerOnAllEvent;
47+
private final boolean triggerReconcilerOnAllEvents;
4848
private WorkflowSpec workflowSpec;
4949

5050
public ResolvedControllerConfiguration(ControllerConfiguration<P> other) {
@@ -60,7 +60,7 @@ public ResolvedControllerConfiguration(ControllerConfiguration<P> other) {
6060
other.fieldManager(),
6161
other.getConfigurationService(),
6262
other.getInformerConfig(),
63-
other.triggerReconcilerOnAllEvent(),
63+
other.triggerReconcilerOnAllEvents(),
6464
other.getWorkflowSpec().orElse(null));
6565
}
6666

@@ -76,7 +76,7 @@ public ResolvedControllerConfiguration(
7676
String fieldManager,
7777
ConfigurationService configurationService,
7878
InformerConfiguration<P> informerConfig,
79-
boolean triggerReconcilerOnAllEvent,
79+
boolean triggerReconcilerOnAllEvents,
8080
WorkflowSpec workflowSpec) {
8181
this(
8282
name,
@@ -90,7 +90,7 @@ public ResolvedControllerConfiguration(
9090
fieldManager,
9191
configurationService,
9292
informerConfig,
93-
triggerReconcilerOnAllEvent);
93+
triggerReconcilerOnAllEvents);
9494
setWorkflowSpec(workflowSpec);
9595
}
9696

@@ -106,7 +106,7 @@ protected ResolvedControllerConfiguration(
106106
String fieldManager,
107107
ConfigurationService configurationService,
108108
InformerConfiguration<P> informerConfig,
109-
boolean triggerReconcilerOnAllEvent) {
109+
boolean triggerReconcilerOnAllEvents) {
110110
this.informerConfig = informerConfig;
111111
this.configurationService = configurationService;
112112
this.name = ControllerConfiguration.ensureValidName(name, associatedReconcilerClassName);
@@ -119,7 +119,7 @@ protected ResolvedControllerConfiguration(
119119
this.finalizer =
120120
ControllerConfiguration.ensureValidFinalizerName(finalizer, getResourceTypeName());
121121
this.fieldManager = fieldManager;
122-
this.triggerReconcilerOnAllEvent = triggerReconcilerOnAllEvent;
122+
this.triggerReconcilerOnAllEvents = triggerReconcilerOnAllEvents;
123123
}
124124

125125
protected ResolvedControllerConfiguration(
@@ -231,7 +231,7 @@ public String fieldManager() {
231231
}
232232

233233
@Override
234-
public boolean triggerReconcilerOnAllEvent() {
235-
return triggerReconcilerOnAllEvent;
234+
public boolean triggerReconcilerOnAllEvents() {
235+
return triggerReconcilerOnAllEvents;
236236
}
237237
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/Context.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ default <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
9191
/**
9292
* To check if the primary resource is already deleted. This value can be true only if you turn on
9393
* {@link
94-
* io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration#triggerReconcilerOnAllEvent()}
94+
* io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration#triggerReconcilerOnAllEvents()}
9595
*
9696
* @return true Delete event received for primary resource
9797
* @since 5.2.0

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/ControllerConfiguration.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,10 +93,16 @@ MaxReconciliationInterval maxReconciliationInterval() default
9393
*/
9494
String fieldManager() default CONTROLLER_NAME_AS_FIELD_MANAGER;
9595

96+
/**
97+
* @deprecated use {@link #triggerReconcilerOnAllEvents()} instead
98+
*/
99+
@Deprecated(forRemoval = true)
100+
boolean triggerReconcilerOnAllEvent() default false;
101+
96102
/**
97103
* By settings to true, reconcile method will be triggered on every event, thus even for Delete
98104
* event. You cannot use {@link Cleaner} or managed dependent resources in that case. See
99105
* documentation for further details.
100106
*/
101-
boolean triggerReconcilerOnAllEvent() default false;
107+
boolean triggerReconcilerOnAllEvents() default false;
102108
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/Controller.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -77,10 +77,10 @@ public class Controller<P extends HasMetadata>
7777
private static final String STATUS = "status";
7878
private static final String BOTH = "both";
7979
public static final String CLEANER_NOT_SUPPORTED_ON_ALL_EVENT_ERROR_MESSAGE =
80-
"Cleaner is not supported when triggerReconcilerOnAllEvent enabled.";
80+
"Cleaner is not supported when triggerReconcilerOnAllEvents enabled.";
8181
public static final String
8282
MANAGED_WORKFLOWS_NOT_SUPPORTED_TRIGGER_RECONCILER_ON_ALL_EVENT_ERROR_MESSAGE =
83-
"Managed workflows are not supported when triggerReconcilerOnAllEvent enabled.";
83+
"Managed workflows are not supported when triggerReconcilerOnAllEvents enabled.";
8484

8585
private final Reconciler<P> reconciler;
8686
private final ControllerConfiguration<P> configuration;
@@ -117,7 +117,7 @@ public Controller(
117117
explicitWorkflowInvocation =
118118
configuration.getWorkflowSpec().map(WorkflowSpec::isExplicitInvocation).orElse(false);
119119

120-
if (configuration.triggerReconcilerOnAllEvent()) {
120+
if (configuration.triggerReconcilerOnAllEvents()) {
121121
if (isCleaner) {
122122
throw new OperatorException(CLEANER_NOT_SUPPORTED_ON_ALL_EVENT_ERROR_MESSAGE);
123123
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public synchronized void handleEvent(Event event) {
146146
}
147147

148148
private void handleMarkedEventForResource(ResourceState state) {
149-
if (state.deleteEventPresent() && !triggerOnAllEvent()) {
149+
if (state.deleteEventPresent() && !triggerOnAllEvents()) {
150150
cleanupForDeletedEvent(state.getId());
151151
} else if (!state.processedMarkForDeletionPresent()) {
152152
submitReconciliationExecution(state);
@@ -181,7 +181,7 @@ private void submitReconciliationExecution(ResourceState state) {
181181
state.getRetry(),
182182
state.deleteEventPresent(),
183183
state.isDeleteFinalStateUnknown());
184-
state.unMarkEventReceived(triggerOnAllEvent());
184+
state.unMarkEventReceived(triggerOnAllEvents());
185185
metrics.reconcileCustomResource(latest, state.getRetry(), metricsMetadata);
186186
log.debug("Executing events for custom resource. Scope: {}", executionScope);
187187
executor.execute(new ReconcilerExecutor(resourceID, executionScope));
@@ -208,7 +208,7 @@ private void submitReconciliationExecution(ResourceState state) {
208208

209209
@SuppressWarnings("unchecked")
210210
private P getResourceFromState(ResourceState state) {
211-
if (triggerOnAllEvent()) {
211+
if (triggerOnAllEvents()) {
212212
log.debug("Getting resource from state for {}", state.getId());
213213
return (P) state.getLastKnownResource();
214214
} else {
@@ -239,10 +239,10 @@ private void handleEventMarking(Event event, ResourceState state) {
239239
// removed, but also the informers websocket is disconnected and later reconnected. So
240240
// meanwhile the resource could be deleted and recreated. In this case we just mark a new
241241
// event as below.
242-
state.markEventReceived(triggerOnAllEvent());
242+
state.markEventReceived(triggerOnAllEvents());
243243
}
244244
} else if (!state.deleteEventPresent() && !state.processedMarkForDeletionPresent()) {
245-
state.markEventReceived(triggerOnAllEvent());
245+
state.markEventReceived(triggerOnAllEvents());
246246
} else if (isTriggerOnAllEventAndDeleteEventPresent(state)) {
247247
state.markAdditionalEventAfterDeleteEvent();
248248
} else if (log.isDebugEnabled()) {
@@ -286,15 +286,15 @@ synchronized void eventProcessingFinished(
286286
// Either way we don't want to retry.
287287
if (isRetryConfigured()
288288
&& postExecutionControl.exceptionDuringExecution()
289-
&& (!state.deleteEventPresent() || triggerOnAllEvent())) {
289+
&& (!state.deleteEventPresent() || triggerOnAllEvents())) {
290290
handleRetryOnException(
291291
executionScope, postExecutionControl.getRuntimeException().orElseThrow());
292292
return;
293293
}
294294
cleanupOnSuccessfulExecution(executionScope);
295295
metrics.finishedReconciliation(executionScope.getResource(), metricsMetadata);
296-
if ((triggerOnAllEvent() && executionScope.isDeleteEvent())
297-
|| (!triggerOnAllEvent() && state.deleteEventPresent())) {
296+
if ((triggerOnAllEvents() && executionScope.isDeleteEvent())
297+
|| (!triggerOnAllEvents() && state.deleteEventPresent())) {
298298
cleanupForDeletedEvent(executionScope.getResourceID());
299299
} else if (postExecutionControl.isFinalizerRemoved()) {
300300
state.markProcessedMarkForDeletion();
@@ -310,7 +310,7 @@ synchronized void eventProcessingFinished(
310310
}
311311

312312
private boolean isTriggerOnAllEventAndDeleteEventPresent(ResourceState state) {
313-
return triggerOnAllEvent() && state.deleteEventPresent();
313+
return triggerOnAllEvents() && state.deleteEventPresent();
314314
}
315315

316316
/**
@@ -370,8 +370,8 @@ private void handleRetryOnException(ExecutionScope<P> executionScope, Exception
370370
var resourceID = state.getId();
371371
boolean eventPresent =
372372
state.eventPresent()
373-
|| (triggerOnAllEvent() && state.isAdditionalEventPresentAfterDeleteEvent());
374-
state.markEventReceived(triggerOnAllEvent());
373+
|| (triggerOnAllEvents() && state.isAdditionalEventPresentAfterDeleteEvent());
374+
state.markEventReceived(triggerOnAllEvents());
375375

376376
retryAwareErrorLogging(state.getRetry(), eventPresent, exception, executionScope);
377377
if (eventPresent) {
@@ -517,7 +517,7 @@ public void run() {
517517
// we try to get the most up-to-date resource from cache
518518
var actualResource = cache.get(resourceID);
519519
if (actualResource.isEmpty()) {
520-
if (triggerOnAllEvent()) {
520+
if (triggerOnAllEvents()) {
521521
log.debug(
522522
"Resource not found in the cache, checking for delete event resource: {}",
523523
resourceID);
@@ -578,7 +578,7 @@ public synchronized boolean isRunning() {
578578
}
579579

580580
// shortening
581-
private boolean triggerOnAllEvent() {
582-
return controllerConfiguration.triggerReconcilerOnAllEvent();
581+
private boolean triggerOnAllEvents() {
582+
return controllerConfiguration.triggerReconcilerOnAllEvents();
583583
}
584584
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public class EventSourceManager<P extends HasMetadata>
5555
public EventSourceManager(Controller<P> controller) {
5656
this(
5757
controller,
58-
new EventSources<>(controller.getConfiguration().triggerReconcilerOnAllEvent()));
58+
new EventSources<>(controller.getConfiguration().triggerReconcilerOnAllEvents()));
5959
}
6060

6161
EventSourceManager(Controller<P> controller, EventSources<P> eventSources) {

0 commit comments

Comments
 (0)