SamBarker commented on code in PR #863:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/863#discussion_r1716706322
##########
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesClientMetrics.java:
##########
@@ -118,32 +139,91 @@ public KubernetesClientMetrics(
createMeterViewForMetricsGroup(
responseMetricGroup.addGroup(HTTP_RESPONSE_5XX)));
}
+ this.requestStartTimes = new ConcurrentHashMap<>();
}
@Override
- public Response intercept(Chain chain) throws IOException {
- Request request = chain.request();
- updateRequestMetrics(request);
- Response response = null;
- final long startTime = System.nanoTime();
- try {
- response = chain.proceed(request);
- return response;
- } finally {
- updateResponseMetrics(response, startTime);
+ public AsyncBody.Consumer<List<ByteBuffer>> consumer(
Review Comment:
Argh. The problem with before is that I'm the request.id we see might not be
the actual one sent as another filter can modify it after the invocation of our
before callback.
I'll have to have another poke around the latency tracking.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
