- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for grpcstatus (0.12 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) -
pilot/pkg/xds/filters/filters.go
TypedConfig: protoconv.MessageToAny(&grpcweb.GrpcWeb{}), }, } GrpcStats = &hcm.HttpFilter{ Name: wellknown.HTTPGRPCStats, ConfigType: &hcm.HttpFilter_TypedConfig{ TypedConfig: protoconv.MessageToAny(&grpcstats.FilterConfig{ EmitFilterState: true, PerMethodStatSpecifier: &grpcstats.FilterConfig_StatsForAllMethods{ StatsForAllMethods: &wrapperspb.BoolValue{Value: false}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 09:24:25 UTC 2024 - 15.5K bytes - Viewed (0) -
src/internal/trace/event/go122/event.go
case GoSyscall: return "Syscall" case GoWaiting: return "Waiting" } return "Bad" } type ProcStatus uint8 const ( ProcBad ProcStatus = iota ProcRunning ProcIdle ProcSyscall ProcSyscallAbandoned ) func (s ProcStatus) String() string { switch s { case ProcRunning: return "Running" case ProcIdle: return "Idle" case ProcSyscall:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 14.8K bytes - Viewed (0) -
src/runtime/traceruntime.go
ev := traceEvGoSyscallEnd procStatus := traceProcSyscall // Procs implicitly enter traceProcSyscall on GoSyscallBegin. if lostP { ev = traceEvGoSyscallEndBlocked procStatus = traceProcRunning // If a G has a P when emitting this event, it reacquired a P and is indeed running. } else { tl.mp.p.ptr().trace.mSyscallID = -1 } tl.eventWriter(traceGoSyscall, procStatus).commit(ev) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0)