- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for unweighted (0.58 sec)
-
pilot/pkg/xds/mesh_network_test.go
w.testUnweighted(t, s) w.testWeighted(t, s) }) } func (w *workload) testUnweighted(t *testing.T, s *xds.FakeDiscoveryServer) { if w.expectations == nil { return } t.Run("unweighted", func(t *testing.T) { // wait for eds cache update retry.UntilSuccessOrFail(t, func() error { eps := xdstest.ExtractLoadAssignments(s.Endpoints(w.proxy)) for c, want := range w.expectations {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
HostRewriteLiteral: operations.Authority, } } } weighted = append(weighted, clusterWeight) } // rewrite to a single cluster if there is only weighted cluster if len(weighted) == 1 { action.ClusterSpecifier = &route.RouteAction_Cluster{Cluster: weighted[0].Name} out.RequestHeadersToAdd = append(out.RequestHeadersToAdd, weighted[0].RequestHeadersToAdd...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
tests := []struct { network string sidecarID string want expectedResults }{ { // Verify that EDS from network1 will return 1 local endpoint with local VIP + 2 remote // endpoints weighted accordingly with the IP of the ingress gateway. network: "network1", sidecarID: sidecarID("10.1.0.1", "app3"), want: expectedResults{ weights: map[string]uint32{ // 1 local endpoint
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/test/loadbalancersim/lb_test.go
// Create the new test output. tm := &testMetrics{ hasNetworkLatency: networkLatencyCase.enable, hasQueueLatency: enableQueueLatency, weighted: weightCase.enableWeighting, algorithm: algorithmCase.name, topology: topologyCase.name, } sm = append(sm, tm)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 19 23:29:30 UTC 2022 - 11K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
return } // Support Locality weighted load balancing // (https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/upstream/load_balancing/locality_weight#locality-weighted-load-balancing) // by providing weights in LocalityLbEndpoints via load_balancing_weight. // By setting weights across different localities, it can allow // Envoy to do weighted load balancing across different zones and geographical locations.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter.go
Name: clusterName, Weight: uint32(route.Weight), }) } } // For weighted clusters set hash policy if any of the upstream destinations have sourceIP. maybeSetHashPolicy(destinationRule, tcpProxy, "") // In case of weighted clusters, tunneling config for a subset is ignored, // because it is set on listener, not on a cluster.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheEvictionTest.java
CacheTesting.drainRecencyQueues(cache); assertThat(keySet).containsExactly(2, 10, 11, 12, 6, 7, 8, 13, 14, 15); } public void testEviction_weightedLru() { // test weighted lru within a single segment IdentityLoader<Integer> loader = identityLoader(); LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder() .concurrencyLevel(1)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 14.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheEvictionTest.java
CacheTesting.drainRecencyQueues(cache); assertThat(keySet).containsExactly(2, 10, 11, 12, 6, 7, 8, 13, 14, 15); } public void testEviction_weightedLru() { // test weighted lru within a single segment IdentityLoader<Integer> loader = identityLoader(); LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder() .concurrencyLevel(1)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 14.9K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
adscConn := s.Connect(nil, nil, watchEds) endpoints := adscConn.GetEndpoints() lbe, f := endpoints["outbound|80||weighted.static.svc.cluster.local"] if !f || len(lbe.Endpoints) == 0 { t.Fatalf("No lb endpoints for %v, %v", "outbound|80||weighted.static.svc.cluster.local", adscConn.EndpointsJSON()) } expected := map[string]uint32{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
src/cmd/gofmt/gofmt.go
} // A sequencer performs concurrent tasks that may write output, but emits that // output in a deterministic order. type sequencer struct { maxWeight int64 sem *semaphore.Weighted // weighted by input bytes (an approximate proxy for memory overhead) prev <-chan *reporterState // 1-buffered } // newSequencer returns a sequencer that allows concurrent tasks up to maxWeight
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0)