- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for Consistently (0.17 sec)
-
tests/integration/pilot/common/routing.go
func consistentHashCases(t TrafficContext) { if len(t.Clusters().ByNetwork()) != 1 { // Consistent hashing does not work for multinetwork. The first request will consistently go to a // gateway, but that gateway will tcp_proxy it to a random pod. t.Skipf("multi-network is not supported") } for _, app := range []echo.Instances{t.Apps.A, t.Apps.B} { app := app
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
} }) } } type requestTracker struct { sync.Mutex requests int err error after int // this block should be updated consistently parallelLock sync.Mutex shouldTrackParallelRequests bool parallelRequests int maxParallelRequests int parallelRequestDelay time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
src/net/http/server.go
// But for now any three digits. // // We used to send "HTTP/1.1 000 0" on the wire in responses but there's // no equivalent bogus thing we can realistically send in HTTP/2, // so we'll consistently panic instead and help people find their bugs // early. (We can't return an error from WriteHeader even if we wanted to.) if code < 100 || code > 999 { panic(fmt.Sprintf("invalid WriteHeader code %v", code)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/cmd/go/internal/load/pkg.go
ctxt.UseAllFiles = true // Synthesize fake "directory" that only shows the named files, // to make it look like this is a standard package or // command directory. So that local imports resolve // consistently, the files must all be in the same directory. var dirent []fs.FileInfo var dir string for _, file := range gofiles { fi, err := fsys.Stat(file) if err != nil { base.Fatalf("%s", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 28 17:00:51 UTC 2024 - 120K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
// should have its own vector clock increased independently. Golang race detector uses pure happens-before // detection, so would catch a race condition consistently, despite only spawning 2 goroutines for i := 0; i < 2; i++ { go func() { kl.convertToAPIContainerStatuses(pod, criStatus, []v1.ContainerStatus{}, []v1.Container{}, false, false) }() } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
src/runtime/proc.go
// The need for this was made obvious by changing the // (deterministic) scheduling order in Go 1.5 and breaking // many poorly-written tests. // With the randomness here, as long as the tests pass // consistently with -race, they shouldn't have latent scheduling // assumptions. const randomizeScheduler = raceenabled // runqput tries to put g on the local runnable queue.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)