Skip to content

Commit 1fa7805

Browse files
committed
feat: add action name to ResourceEvent metrics tags
1 parent f2eb591 commit 1fa7805

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

micrometer-support/src/main/java/io/javaoperatorsdk/operator/monitoring/micrometer/MicrometerMetrics.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import io.javaoperatorsdk.operator.processing.GroupVersionKind;
1717
import io.javaoperatorsdk.operator.processing.event.Event;
1818
import io.javaoperatorsdk.operator.processing.event.ResourceID;
19+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEvent;
1920
import io.micrometer.core.instrument.Meter;
2021
import io.micrometer.core.instrument.MeterRegistry;
2122
import io.micrometer.core.instrument.Tag;
@@ -127,9 +128,17 @@ private static String getScope(ResourceID resourceID) {
127128

128129
@Override
129130
public void receivedEvent(Event event, Map<String, Object> metadata) {
131+
final String[] tags;
132+
if (event instanceof ResourceEvent) {
133+
tags = new String[] {"event", event.getClass().getSimpleName(), "action",
134+
((ResourceEvent) event).getAction().toString()};
135+
} else {
136+
tags = new String[] {"event", event.getClass().getSimpleName()};
137+
}
138+
130139
incrementCounter(event.getRelatedCustomResourceID(), "events.received",
131140
metadata,
132-
"event", event.getClass().getSimpleName());
141+
tags);
133142
}
134143

135144
@Override

0 commit comments

Comments
 (0)