- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for grpcstatus (0.16 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) -
src/internal/trace/testdata/tests/go122-annotations.test
ProcStatus dt=1 p=8 pstatus=2 ProcStatus dt=1 p=9 pstatus=2 ProcStatus dt=1 p=10 pstatus=2 ProcStatus dt=1 p=11 pstatus=2 ProcStatus dt=1 p=12 pstatus=2 ProcStatus dt=1 p=13 pstatus=2 ProcStatus dt=1 p=14 pstatus=2 ProcStatus dt=1 p=15 pstatus=2 ProcStatus dt=1 p=16 pstatus=2 ProcStatus dt=1 p=17 pstatus=2 ProcStatus dt=1 p=18 pstatus=2 ProcStatus dt=1 p=19 pstatus=2 ProcStatus dt=1 p=20 pstatus=2 ProcStatus dt=1 p=21 pstatus=2
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 8.7K bytes - Viewed (0) -
src/internal/trace/testdata/tests/go122-syscall-steal-proc-reacquire-new-proc.test
-- expect -- SUCCESS -- trace -- Trace Go1.22 EventBatch gen=1 m=0 time=0 size=23 ProcStatus dt=1 p=1 pstatus=2 ProcStatus dt=1 p=0 pstatus=1 GoStatus dt=1 g=1 m=0 gstatus=2 GoSyscallBegin dt=1 p_seq=1 stack=0 ProcStart dt=1 p=1 p_seq=1 GoSyscallEndBlocked dt=1 EventBatch gen=1 m=1 time=0 size=14 ProcStatus dt=1 p=2 pstatus=1 GoStatus dt=1 g=2 m=1 gstatus=2 ProcSteal dt=1 p=0 p_seq=2 m=0 EventBatch gen=1 m=18446744073709551615 time=0 size=5
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 592 bytes - Viewed (0) -
src/internal/trace/testdata/tests/go122-syscall-steal-proc-gen-boundary.test
-- expect -- SUCCESS -- trace -- Trace Go1.22 EventBatch gen=1 m=0 time=0 size=11 ProcStatus dt=1 p=1 pstatus=1 GoStatus dt=1 g=1 m=0 gstatus=3 GoSyscallEndBlocked dt=1 EventBatch gen=1 m=1 time=0 size=18 ProcStatus dt=1 p=2 pstatus=1 GoStatus dt=1 g=2 m=1 gstatus=2 ProcStatus dt=1 p=0 pstatus=4 ProcSteal dt=1 p=0 p_seq=1 m=0 EventBatch gen=1 m=18446744073709551615 time=0 size=5 Frequency freq=15625000
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 529 bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-reacquire-new-proc.go
} func gen(t *testgen.Trace) { g := t.Generation(1) // One goroutine enters a syscall, grabs a P, and starts running. b0 := g.Batch(trace.ThreadID(0), 0) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcIdle) b0.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning) b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.1K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary.go
// acquired a new P. b0 := g.Batch(trace.ThreadID(0), 0) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcRunning) b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall) b0.Event("GoSyscallEndBlocked") // A running goroutine stole P0 at the generation boundary. b1 := g.Batch(trace.ThreadID(1), 0) b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.1K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary-reacquire-new-proc.go
b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall) b0.Event("ProcStatus", trace.ProcID(1), go122.ProcIdle) b0.Event("ProcStart", trace.ProcID(1), testgen.Seq(1)) b0.Event("GoSyscallEndBlocked") // A running goroutine stole P0 at the generation boundary. b1 := g.Batch(trace.ThreadID(1), 0) b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.1K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-confuse-seq-across-generations.go
// A running goroutine blocks. b10 := g1.Batch(trace.ThreadID(0), 0) b10.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning) b10.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning) b10.Event("GoStop", "whatever", testgen.NoStack) // The running goroutine gets unblocked. b11 := g1.Batch(trace.ThreadID(1), 0) b11.Event("ProcStatus", trace.ProcID(1), go122.ProcRunning) b11.Event("GoStart", trace.GoID(1), testgen.Seq(1))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 2.1K bytes - Viewed (0) -
cmd/metrics-v3-system-network.go
connStats := globalConnStats.toServerConnStats() rpcStats := rest.GetRPCStats() if globalIsDistErasure { m.Set(internodeErrorsTotal, float64(rpcStats.Errs)) m.Set(internodeDialErrorsTotal, float64(rpcStats.DialErrs)) m.Set(internodeDialAvgTimeNanos, float64(rpcStats.DialAvgDuration)) m.Set(internodeSentBytesTotal, float64(connStats.internodeOutputBytes))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.4K bytes - Viewed (0)