Class OperatorJosdkMetrics
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
-
- All Implemented Interfaces:
io.javaoperatorsdk.operator.api.monitoring.Metrics
public class OperatorJosdkMetrics extends java.lang.Object implements io.javaoperatorsdk.operator.api.monitoring.Metrics
Implementation ofMetrics
to monitor and forward JOSDK metrics toMetricRegistry
.
-
-
Constructor Summary
Constructors Constructor Description OperatorJosdkMetrics(KubernetesOperatorMetricGroup operatorMetricGroup, FlinkConfigManager configManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanupDoneFor(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, java.util.Map<java.lang.String,java.lang.Object> metadata)
void
failedReconciliation(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, java.lang.Exception exception, java.util.Map<java.lang.String,java.lang.Object> metadata)
void
finishedReconciliation(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, java.util.Map<java.lang.String,java.lang.Object> metadata)
<T extends java.util.Map<?,?>>
TmonitorSizeOf(T map, java.lang.String name)
void
receivedEvent(io.javaoperatorsdk.operator.processing.event.Event event, java.util.Map<java.lang.String,java.lang.Object> metadata)
void
reconcileCustomResource(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, io.javaoperatorsdk.operator.api.reconciler.RetryInfo retryInfoNullable, java.util.Map<java.lang.String,java.lang.Object> metadata)
<T> T
timeControllerExecution(io.javaoperatorsdk.operator.api.monitoring.Metrics.ControllerExecution<T> execution)
-
-
-
Constructor Detail
-
OperatorJosdkMetrics
public OperatorJosdkMetrics(KubernetesOperatorMetricGroup operatorMetricGroup, FlinkConfigManager configManager)
-
-
Method Detail
-
timeControllerExecution
public <T> T timeControllerExecution(io.javaoperatorsdk.operator.api.monitoring.Metrics.ControllerExecution<T> execution) throws java.lang.Exception
- Specified by:
timeControllerExecution
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
- Throws:
java.lang.Exception
-
receivedEvent
public void receivedEvent(io.javaoperatorsdk.operator.processing.event.Event event, java.util.Map<java.lang.String,java.lang.Object> metadata)
- Specified by:
receivedEvent
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
-
cleanupDoneFor
public void cleanupDoneFor(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, java.util.Map<java.lang.String,java.lang.Object> metadata)
- Specified by:
cleanupDoneFor
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
-
reconcileCustomResource
public void reconcileCustomResource(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, io.javaoperatorsdk.operator.api.reconciler.RetryInfo retryInfoNullable, java.util.Map<java.lang.String,java.lang.Object> metadata)
- Specified by:
reconcileCustomResource
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
-
finishedReconciliation
public void finishedReconciliation(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, java.util.Map<java.lang.String,java.lang.Object> metadata)
- Specified by:
finishedReconciliation
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
-
failedReconciliation
public void failedReconciliation(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID, java.lang.Exception exception, java.util.Map<java.lang.String,java.lang.Object> metadata)
- Specified by:
failedReconciliation
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
-
monitorSizeOf
public <T extends java.util.Map<?,?>> T monitorSizeOf(T map, java.lang.String name)
- Specified by:
monitorSizeOf
in interfaceio.javaoperatorsdk.operator.api.monitoring.Metrics
-
-