-
Notifications
You must be signed in to change notification settings - Fork 737
migrate MessagingMetrics to micrometer #27848
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
npepinpe
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Found some issues already, I'll review Monday when it's ready
| REQUEST_RESPONSE_LATENCY { | ||
| @Override | ||
| public String getName() { | ||
| return "zeebe.messaging_request.response.latency"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
❓ Kept a _ there on purpose, or?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| return "zeebe.messaging_request.response.latency"; | |
| return "zeebe.messaging.request.response.latency"; |
| IN_FLIGHT_REQUESTS { | ||
| @Override | ||
| public String getName() { | ||
| return "messaging_inflight_requests"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| return "messaging_inflight_requests"; | |
| return "zeebe.messaging.inflight.requests"; |
| } | ||
| }; | ||
|
|
||
| enum MessagingKeyNames implements KeyName { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🔧 Please add some documentation for the key names
| return Counter.builder(RESPONSE_COUNT.getName()) | ||
| .description(RESPONSE_COUNT.getDescription()) | ||
| .tags( | ||
| MessagingKeyNames.TYPE.asString(), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
❌ Should be "outcome", not "type".
| private static final String MESSAGE = "MESSAGE"; | ||
| private static final String REQ_RESP = "REQ_RESP"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🔧 If I understood correctly, these are the two possible values for the type label? We should make it an enum.
16cce10 to
6ce28c5
Compare
a1a149f to
507508b
Compare
dc96efc to
7986087
Compare
npepinpe
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚀 Did you test it? As this is quite a substantial PR.
| }, | ||
| "editorMode": "code", | ||
| "expr": "histogram_quantile(0.50, sum(rate(zeebe_messaging_request_response_latency_bucket{cluster=~\"$cluster\", namespace=~\"$namespace\",pod=~\"$pod\", partition=~\"$partition\"}[$__rate_interval])) by (topic, le))", | ||
| "expr": "histogram_quantile(0.50, sum(rate(zeebe_messaging_request_response_latency_bucket{cluster=~\"$cluster\", namespace=~\"$namespace\",pod=~\"$pod\", partition=~\"$partition\"}[$__rate_interval]) or rate(zeebe_messaging_request_response_latency_seconds_bucket{cluster=~\"$cluster\", namespace=~\"$namespace\",pod=~\"$pod\", partition=~\"$partition\"}[$__rate_interval])) by (topic, le))", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🔧 Does this show things properly? I ran into an issue with the union of series and heatmap data earlier, though I was not using histogram_quantile, so maybe that works better.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| "uid": "$DS_PROMETHEUS" | ||
| }, | ||
| "editorMode": "code", | ||
| "expr": "sum(increase(zeebe_messaging_request_response_latency_bucket{cluster=~\"$cluster\", namespace=~\"$namespace\",partition=~\"$partition\",pod=~\"$pod\", topic=~\"atomix-membership-probe-request\"}[$__rate_interval])) by (le)", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🔧 Same as above, for the others in general. Did you double check?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
|
Yes I did check the dashboard it looks fine to me, I hope I didn't miss anything |
e3538f3 to
c91e636
Compare
f4c5036 to
2bff71b
Compare
|
Created backport PR for
Please cherry-pick the changes locally and resolve any conflicts. git fetch origin backport-27848-to-stable/8.5
git worktree add --checkout .worktree/backport-27848-to-stable/8.5 backport-27848-to-stable/8.5
cd .worktree/backport-27848-to-stable/8.5
git reset --hard HEAD^
git cherry-pick -x 4a4a767762119b45828ef5449b1d6302b4861846 f4324309af5d04d61cef9eef07267314cc0efb55 bdb959f4b9a2527d89b4fb3dde953529313e578d 89ec8f33e6fa63c3d80beba6ea5d2b21485809c4 b7fd8ceb3dbf2040315d9819a49d9eaaacac1298 1cf487dfa4a8559e579c0be2400a43a066a77fb5 a88665609955707e6346e5e1ad4a79c35336aec3 6c7df9d081f0c3ca65d6c05059005e905b7e5284 8774e00c3d64928ed220ce5a51d07e64b129039c 8261d97293dbb5c6234db03a147dbcc4d4062cfa 28ddf16cc98d2a79ee1981fa89b53459e6355611 bcc389615bec1af9faac9ef3ae130f9b18ba6b22 9bd85d6bf41dc26227a7a1228b34d93e4b20e699 e99390ec0296c1cf277cd52ee902ec53f24099a3 5034256a8a0bad915cf76c5d0f2efffa595cbea3 688f49286655b7da789c85a7034a895d6b7f2a01 74153bb784864cecbfc3760947019a35fee9ca2d 16108868b4fe9c0de9b83dbdbb555460285a9b90 2bff71b3ece40c34d2fe39c7c6c91ef32c3da1ad
git push --force-with-lease |
|
Created backport PR for
Please cherry-pick the changes locally and resolve any conflicts. git fetch origin backport-27848-to-stable/8.6
git worktree add --checkout .worktree/backport-27848-to-stable/8.6 backport-27848-to-stable/8.6
cd .worktree/backport-27848-to-stable/8.6
git reset --hard HEAD^
git cherry-pick -x 4a4a767762119b45828ef5449b1d6302b4861846 f4324309af5d04d61cef9eef07267314cc0efb55 bdb959f4b9a2527d89b4fb3dde953529313e578d 89ec8f33e6fa63c3d80beba6ea5d2b21485809c4 b7fd8ceb3dbf2040315d9819a49d9eaaacac1298 1cf487dfa4a8559e579c0be2400a43a066a77fb5 a88665609955707e6346e5e1ad4a79c35336aec3 6c7df9d081f0c3ca65d6c05059005e905b7e5284 8774e00c3d64928ed220ce5a51d07e64b129039c 8261d97293dbb5c6234db03a147dbcc4d4062cfa 28ddf16cc98d2a79ee1981fa89b53459e6355611 bcc389615bec1af9faac9ef3ae130f9b18ba6b22 9bd85d6bf41dc26227a7a1228b34d93e4b20e699 e99390ec0296c1cf277cd52ee902ec53f24099a3 5034256a8a0bad915cf76c5d0f2efffa595cbea3 688f49286655b7da789c85a7034a895d6b7f2a01 74153bb784864cecbfc3760947019a35fee9ca2d 16108868b4fe9c0de9b83dbdbb555460285a9b90 2bff71b3ece40c34d2fe39c7c6c91ef32c3da1ad
git push --force-with-lease |
|
Created backport PR for
Please cherry-pick the changes locally and resolve any conflicts. git fetch origin backport-27848-to-stable/8.7
git worktree add --checkout .worktree/backport-27848-to-stable/8.7 backport-27848-to-stable/8.7
cd .worktree/backport-27848-to-stable/8.7
git reset --hard HEAD^
git cherry-pick -x 4a4a767762119b45828ef5449b1d6302b4861846 f4324309af5d04d61cef9eef07267314cc0efb55 bdb959f4b9a2527d89b4fb3dde953529313e578d 89ec8f33e6fa63c3d80beba6ea5d2b21485809c4 b7fd8ceb3dbf2040315d9819a49d9eaaacac1298 1cf487dfa4a8559e579c0be2400a43a066a77fb5 a88665609955707e6346e5e1ad4a79c35336aec3 6c7df9d081f0c3ca65d6c05059005e905b7e5284 8774e00c3d64928ed220ce5a51d07e64b129039c 8261d97293dbb5c6234db03a147dbcc4d4062cfa 28ddf16cc98d2a79ee1981fa89b53459e6355611 bcc389615bec1af9faac9ef3ae130f9b18ba6b22 9bd85d6bf41dc26227a7a1228b34d93e4b20e699 e99390ec0296c1cf277cd52ee902ec53f24099a3 5034256a8a0bad915cf76c5d0f2efffa595cbea3 688f49286655b7da789c85a7034a895d6b7f2a01 74153bb784864cecbfc3760947019a35fee9ca2d 16108868b4fe9c0de9b83dbdbb555460285a9b90 2bff71b3ece40c34d2fe39c7c6c91ef32c3da1ad
git push --force-with-lease |
# Description Backport of #27848 to `stable/8.5`. relates to #27082 original author: @entangled90
…28192) ## Description Backport of #27848 to stable/8.7. original author: @entangled90 Backport of #27848 from stable/8.5 to stable/8.7. Original PR was made in main, but there are less conflicts from stable/8.5 Does not contain backport of #28108, it must be merged afterwards ## Related issues relates to #27082


Description
Migrates MessagingMetrics to micrometers.
There are a couple of timers, so dashboard changes are needed.
Related issues
closes #27082