- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GRPCStatus (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go
} type grpcError interface { GRPCStatus() *grpcstatus.Status } func isTooLargeError(err error) bool { if err != nil { if etcdErr, ok := err.(etcdError); ok { if etcdErr.Code() == grpccodes.InvalidArgument && etcdErr.Error() == "etcdserver: request is too large" { return true } } if grpcErr, ok := err.(grpcError); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 17K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_internal_test.go
}, }, { name: "grpc abort", fault: &networking.HTTPFaultInjection{ Abort: &networking.HTTPFaultInjection_Abort{ ErrorType: &networking.HTTPFaultInjection_Abort_GrpcStatus{ GrpcStatus: "DEADLINE_EXCEEDED", }, Percentage: &networking.Percent{ Value: float64(50), }, }, }, want: &xdshttpfault.HTTPFault{ Abort: &xdshttpfault.FaultAbort{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 11 02:47:57 UTC 2024 - 18.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics.go
} 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: Sat Sep 09 22:31:32 UTC 2023 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
} type grpcError interface { GRPCStatus() *grpcstatus.Status } func isCancelError(err error) bool { if err == nil { return false } if err == context.Canceled { return true } if etcdErr, ok := err.(etcdError); ok && etcdErr.Code() == grpccodes.Canceled { return true } if grpcErr, ok := err.(grpcError); ok && grpcErr.GRPCStatus().Code() == grpccodes.Canceled { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/checkers.go
if r.Code == notExpectedStr { return fmt.Errorf("received unexpected response code `%s`. Response: %s", notExpectedStr, r) } return nil } } // GRPCStatus checks that the gRPC response status code matches the expected value. func GRPCStatus(expected codes.Code) echo.Checker { return func(result echo.CallResult, err error) error { if expected == codes.OK { if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 03 16:19:07 UTC 2023 - 17.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
// limitations under the License. package autoregistration import ( "context" "fmt" "math" "strings" "time" "golang.org/x/time/rate" "google.golang.org/grpc/codes" grpcstatus "google.golang.org/grpc/status" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" kubetypes "k8s.io/apimachinery/pkg/types" "istio.io/api/annotation"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
"golang.org/x/net/http2" "google.golang.org/grpc" "google.golang.org/grpc/codes" "google.golang.org/grpc/credentials/insecure" grpcHealth "google.golang.org/grpc/health/grpc_health_v1" grpcStatus "google.golang.org/grpc/status" "google.golang.org/protobuf/proto" k8sUtilIo "k8s.io/utils/io" "istio.io/istio/pilot/cmd/pilot-agent/metrics" "istio.io/istio/pilot/cmd/pilot-agent/status/grpcready"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1)