Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for grpcStatus (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top