- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 555 for weighted (0.14 sec)
-
pkg/scheduler/framework/extender.go
// Prioritize based on extender-implemented priority functions. The returned scores & weight // are used to compute the weighted score for an extender. The weighted scores are added to // the scores computed by Kubernetes scheduler. The total scores are used to do the host selection. Prioritize(pod *v1.Pod, nodes []*NodeInfo) (hostPriorities *extenderv1.HostPriorityList, weight int64, err error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 3.3K bytes - Viewed (0) -
tests/testdata/config/rule-fault-injection.yaml
ports: http: 8081 labels: version: v2 --- apiVersion: networking.istio.io/v1alpha3 kind: DestinationRule metadata: name: fault namespace: testns spec: host: c-weighted.extsvc.com subsets: - name: v1 labels: version: v1 - name: v2 labels: version: v2 --- apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 28 21:38:06 UTC 2019 - 1.2K 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) -
releasenotes/notes/locality-lb-docs.yaml
**Added** The locality load balancing docs have been re-written into a formal traffic management task. The new docs describe in more detail how locality load balancing works as well as how to configure both failover and weighted distribution. In addition, the new docs are now
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 15 22:52:39 UTC 2020 - 420 bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/testdata/zero.yaml.golden
namespace: default spec: gateways: - istio-system/gateway-istio-autogenerated-k8s-gateway-default hosts: - first.domain.example http: - match: - uri: prefix: /weighted-100 name: default.http.1 route: - destination: host: foo-svc.default.svc.domain.suffix port: number: 8000 headers: request: add:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 18:54:10 UTC 2024 - 2.3K 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/config/kube/gateway/testdata/zero.yaml
- name: httpbin-zero port: 8080 weight: 0 - matches: - path: type: PathPrefix value: /weighted-100 backendRefs: - filters: - requestHeaderModifier: add: - name: foo value: bar type: RequestHeaderModifier port: 8000 name: foo-svc weight: 100 --- apiVersion: gateway.networking.k8s.io/v1alpha2
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 18 22:43:39 UTC 2023 - 1.5K 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) -
pkg/test/echo/server/forwarder/executor.go
return &execGroup{ e: e, sem: semaphore.NewWeighted(int64(maxConcurrencyPerForward)), } } type execGroup struct { e *executor g multierror.Group sem *semaphore.Weighted } // Go runs the given work function asynchronously. func (g *execGroup) Go(ctx context.Context, work func() error) { g.g.Go(func() error { g.e.totalRequests.Inc() g.e.activeRequests.Inc()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 2K bytes - Viewed (0)