Skip to content

Commit 3a6e333

Browse files
csvirimetacosm
andauthored
improve: logging for tracing issues with events (#2260)
Signed-off-by: Attila Mészáros <[email protected]> Co-authored-by: Chris Laprun <[email protected]>
1 parent 6d24455 commit 3a6e333

File tree

2 files changed

+21
-13
lines changed

2 files changed

+21
-13
lines changed

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

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -285,11 +285,12 @@ private void updatePostExecutionControlWithReschedule(
285285

286286
private PostExecutionControl<P> handleCleanup(P resource,
287287
Context<P> context) {
288-
log.debug(
289-
"Executing delete for resource: {} with version: {}",
290-
getName(resource),
291-
getVersion(resource));
292-
288+
if (log.isDebugEnabled()) {
289+
log.debug(
290+
"Executing delete for resource: {} with version: {}",
291+
ResourceID.fromResource(resource),
292+
getVersion(resource));
293+
}
293294
DeleteControl deleteControl = controller.cleanup(resource, context);
294295
final var useFinalizer = controller.useFinalizer();
295296
if (useFinalizer) {
@@ -345,7 +346,7 @@ ControllerConfiguration<P> configuration() {
345346

346347
public P conflictRetryingUpdate(P resource, Function<P, Boolean> modificationFunction) {
347348
if (log.isDebugEnabled()) {
348-
log.debug("Removing finalizer on resource: {}", ResourceID.fromResource(resource));
349+
log.debug("Conflict retrying update for: {}", ResourceID.fromResource(resource));
349350
}
350351
int retryIndex = 0;
351352
while (true) {
@@ -393,10 +394,12 @@ public R getResource(String namespace, String name) {
393394
}
394395

395396
public R updateResource(R resource) {
396-
log.debug(
397-
"Trying to replace resource {}, version: {}",
398-
getName(resource),
399-
resource.getMetadata().getResourceVersion());
397+
if (log.isDebugEnabled()) {
398+
log.debug(
399+
"Trying to replace resource {}, version: {}",
400+
ResourceID.fromResource(resource),
401+
resource.getMetadata().getResourceVersion());
402+
}
400403
return resource(resource).lockResourceVersion(resource.getMetadata().getResourceVersion())
401404
.update();
402405
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/ControllerResourceEventSource.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,12 @@ public synchronized void start() {
6666

6767
public void eventReceived(ResourceAction action, T resource, T oldResource) {
6868
try {
69-
log.debug("Event received for resource: {}", getName(resource));
69+
if (log.isDebugEnabled()) {
70+
log.debug("Event received for resource: {} version: {} uuid: {} action: {}",
71+
ResourceID.fromResource(resource),
72+
getVersion(resource), resource.getMetadata().getUid(), action);
73+
log.trace("Event Old resource: {},\n new resource: {}", oldResource, resource);
74+
}
7075
MDCUtils.addResourceInfo(resource);
7176
controller.getEventSourceManager().broadcastOnResourceEvent(action, resource, oldResource);
7277
if ((legacyFilters == null ||
@@ -75,8 +80,8 @@ && isAcceptedByFilters(action, resource, oldResource)) {
7580
getEventHandler().handleEvent(
7681
new ResourceEvent(action, ResourceID.fromResource(resource), resource));
7782
} else {
78-
log.debug("Skipping event handling resource {} with version: {}", getUID(resource),
79-
getVersion(resource));
83+
log.debug("Skipping event handling resource {}",
84+
ResourceID.fromResource(resource));
8085
}
8186
} finally {
8287
MDCUtils.removeResourceInfo();

0 commit comments

Comments
 (0)