- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 217 for weighted (0.13 sec)
-
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
} lbEndpoints := eps[0].LbEndpoints if len(lbEndpoints) != len(expected.weights) { t.Fatalf("unexpected number of endpoints.\nWant:\n%v\nGot:\n%v", expected.getAddrs(), getLbEndpointAddrs(lbEndpoints)) } for addr, weight := range expected.weights { var match *endpoint.LbEndpoint for _, ep := range lbEndpoints {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
// 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. for _, localityWeightSetting := range distribute { if localityWeightSetting != nil && util.LocalityMatch(locality, localityWeightSetting.From) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.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) -
android/guava-tests/test/com/google/common/cache/CacheEvictionTest.java
} public void testEviction_weightedLru() { // test weighted lru within a single segment IdentityLoader<Integer> loader = identityLoader(); LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder() .concurrencyLevel(1) .maximumWeight(45) .weigher(intKeyWeigher()) .build(loader); CacheTesting.warmUp(cache, 0, 10);
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/networking/core/networkfilter.go
if route.Weight > 0 { clusterName := istioroute.GetDestinationCluster(route.Destination, service, port.Port) clusterSpecifier.WeightedClusters.Clusters = append(clusterSpecifier.WeightedClusters.Clusters, &tcp.TcpProxy_WeightedCluster_ClusterWeight{ Name: clusterName, Weight: uint32(route.Weight), }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheEvictionTest.java
} public void testEviction_weightedLru() { // test weighted lru within a single segment IdentityLoader<Integer> loader = identityLoader(); LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder() .concurrencyLevel(1) .maximumWeight(45) .weigher(intKeyWeigher()) .build(loader); CacheTesting.warmUp(cache, 0, 10);
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
// (if any) and will cause a nonzero final exit code. func (s *sequencer) Add(weight int64, f func(*reporter) error) { if weight < 0 || weight > s.maxWeight { weight = s.maxWeight } if err := s.sem.Acquire(context.TODO(), weight); err != nil { // Change the task from "execute f" to "report err". weight = 0 f = func(*reporter) error { return err } } r := &reporter{prev: s.prev}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go
apiserverSeatDemandAverages = compbasemetrics.NewGaugeVec( &compbasemetrics.GaugeOpts{ Namespace: namespace, Subsystem: subsystem, Name: "demand_seats_average", Help: "Time-weighted average, over last adjustment period, of demand_seats", StabilityLevel: compbasemetrics.ALPHA, }, []string{priorityLevel}, ) apiserverSeatDemandStandardDeviations = compbasemetrics.NewGaugeVec(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 19:40:05 UTC 2023 - 25.6K bytes - Viewed (0)