- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for grpcStatus (0.22 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) -
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) -
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) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
defer cleanupAction() } if err != nil { s, _ := grpcstatus.FromError(err) m.recordContainerEvent(pod, container, "", v1.EventTypeWarning, events.FailedToCreateContainer, "Error: %v", s.Message()) return s.Message(), ErrCreateContainerConfig } err = m.internalLifecycle.PreCreateContainer(pod, container, containerConfig) if err != nil { s, _ := grpcstatus.FromError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K 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)