Skip to content

Commit 3356896

Browse files
csvirimetacosm
authored andcommitted
feat!: adapt monitoring code to new implementation
- record: * received events * deleted events * reconciliation attempts with retry information * reconciliation successes * reconciliation failure with exception information - move metrics-related code to monitoring package - cleaned-up obsolete/deprecated code
1 parent c5217ff commit 3356896

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,6 @@ public void handleEvent(Event event) {
105105
handleEventMarking(event);
106106
if (!eventMarker.deleteEventPresent(resourceID)) {
107107
submitReconciliationExecution(resourceID);
108-
metrics.finishedReconciliation(resourceID);
109108
} else {
110109
cleanupForDeletedEvent(resourceID);
111110
}
@@ -183,6 +182,7 @@ void eventProcessingFinished(
183182
return;
184183
}
185184
cleanupOnSuccessfulExecution(executionScope);
185+
metrics.finishedReconciliation(customResourceID);
186186
if (eventMarker.deleteEventPresent(customResourceID)) {
187187
cleanupForDeletedEvent(executionScope.getCustomResourceID());
188188
} else {

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
public class DefaultEventSourceManager<R extends CustomResource<?, ?>>
1919
implements EventSourceManager<R>, Closeable {
2020

21-
2221
private static final Logger log = LoggerFactory.getLogger(DefaultEventSourceManager.class);
2322

2423
private final ReentrantLock lock = new ReentrantLock();

0 commit comments

Comments
 (0)