-
Notifications
You must be signed in to change notification settings - Fork 77
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
Add backoff metrics for grpc #1684
Conversation
Signed-off-by: hlts2 <[email protected]>
Signed-off-by: hlts2 <[email protected]>
Signed-off-by: hlts2 <[email protected]>
[CHATOPS:HELP] ChatOps commands.
|
@@ -31,7 +31,7 @@ import ( | |||
"github.com/vdaas/vald/internal/test/goleak" | |||
) | |||
|
|||
func TestDo(t *testing.T) { | |||
func TestDo_for_race(t *testing.T) { |
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.
I have fixed function name because of CI fails.
The reason why CI fails was because there was a same function in to the same package.
https://github.com/vdaas/vald/blob/master/internal/runner/runner_test.go#L284
Codecov Report
@@ Coverage Diff @@
## master #1684 +/- ##
==========================================
- Coverage 31.30% 31.26% -0.04%
==========================================
Files 374 377 +3
Lines 32591 32679 +88
==========================================
+ Hits 10202 10218 +16
- Misses 22002 22078 +76
+ Partials 387 383 -4
Continue to review full report at Codecov.
|
Signed-off-by: hlts2 <[email protected]>
Signed-off-by: hlts2 <[email protected]>
Signed-off-by: hlts2 <[email protected]>
@@ -2004,7 +2004,7 @@ | |||
} | |||
|
|||
func (s *server) Remove(ctx context.Context, req *payload.Remove_Request) (res *payload.Object_Location, err error) { | |||
ctx, span := trace.StartSpan(ctx, apiName+".Remove") | |||
ctx, span := trace.StartSpan(ctx, apiName+"/"+vald.RemoveRPCName) |
Check warning
Code scanning / CodeQL
Useless assignment to local variable
@@ -2140,7 +2140,7 @@ | |||
} | |||
|
|||
func (s *server) MultiRemove(ctx context.Context, reqs *payload.Remove_MultiRequest) (res *payload.Object_Locations, err error) { | |||
ctx, span := trace.StartSpan(ctx, apiName+".MultiRemove") | |||
ctx, span := trace.StartSpan(ctx, apiName+"/"+vald.MultiRemoveRPCName) |
Check warning
Code scanning / CodeQL
Useless assignment to local variable
Signed-off-by: hlts2 <[email protected]>
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.
LGTM
Description:
NOTE : This PR is mirror of #1666
WHAT
I have added the logic to be able to get backoff metrics.
This allows collection of backoff metrics (retry count) within each RPC request when observability and backoff are enabled
WHY
We are in the process of implementing CircuitBreaker, but first we need to get proper metrics on the backoffs that occur inside RPC requests.
Related Issue:
How Has This Been Tested?:
Environment:
Types of changes:
Changes to Core Features:
Checklist: