- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for grpcStatus (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/metrics.go
return time.Since(start).Seconds() } type gRPCError interface { GRPCStatus() *status.Status } func getErrorCode(err error) string { if err == nil { return codes.OK.String() } // handle errors wrapped with fmt.Errorf and similar var s gRPCError if errors.As(err, &s) { return s.GRPCStatus().Code().String() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 22:44:02 UTC 2023 - 5.5K bytes - Viewed (0) -
pilot/pkg/grpc/grpc.go
return true } if s.Code() == codes.Unavailable && containsExpectedMessage(s.Message()) { return true } } // If this is not a gRPCStatus we should just error message. if strings.Contains(err.Error(), "stream terminated by RST_STREAM with error code: NO_ERROR") { return true } if strings.Contains(err.Error(), "received prior goaway: code: NO_ERROR") {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 04:27:50 UTC 2024 - 4.2K bytes - Viewed (0) -
tests/integration/telemetry/api/testdata/attributegen.yaml
match: - value: getoperation condition: request.method == 'GET' - output_attribute: istio_grpcResponseStatus match: - value: OK
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 00:53:57 UTC 2024 - 639 bytes - Viewed (0)