- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 519 for Shards (0.13 sec)
-
pilot/pkg/model/endpointshards.go
es.RLock() defer es.RUnlock() res := &EndpointShards{ Shards: make(map[ShardKey][]*IstioEndpoint, len(es.Shards)), ServiceAccounts: es.ServiceAccounts.Copy(), } for k, v := range es.Shards { res.Shards[k] = make([]*IstioEndpoint, 0, len(v)) for _, ep := range v { res.Shards[k] = append(res.Shards[k], ep.DeepCopy()) } } return res }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
valid := 0 for shardIdx, shard := range splitFilled[:k] { shardConfig[shardIdx] = shard[offset] valid += int(shard[offset]) if shard[offset] == 0 { shards[shardIdx] = shards[shardIdx][:0] } else { shards[shardIdx] = append(shards[shardIdx][:0], splitData[shardIdx][offset]) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 31 14:49:23 UTC 2024 - 38.5K bytes - Viewed (0) -
docs/debugging/hash-set/main.go
flag.StringVar(&deploymentID, "deployment-id", "", "MinIO deployment ID, obtained from 'format.json'") flag.IntVar(&setCount, "set-count", 0, "Total set count") flag.IntVar(&shards, "shards", 0, "Total shards count") flag.BoolVar(&verbose, "v", false, "Display all objects") flag.Parse() if deploymentID == "" { log.Fatalln("deployment ID is mandatory") } if setCount == 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go
shards, ok := endpoints.ShardsForService(string(s.Hostname), s.Attributes.Namespace) if !ok { return nil } var pn string for _, p := range s.Ports { if p.Port == port { pn = p.Name break } } if pn == "" && port != 0 { return nil } shards.RLock() defer shards.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.1K bytes - Viewed (0) -
pilot/pkg/model/endpointshards_test.go
originalEndpointsShard := &EndpointShards{ Shards: map[ShardKey][]*IstioEndpoint{ c1Key: cluster1Endppoints, c2Key: {{Address: "10.244.0.1", ServiceAccount: "sa1"}, {Address: "10.244.0.2", ServiceAccount: "sa-vm2"}}, }, ServiceAccounts: map[string]struct{}{ "sa1": {}, "sa-vm1": {}, "sa-vm2": {}, }, } originalEndpointsShard.Shards[tc.shardKey] = tc.endpoints
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 15:48:05 UTC 2023 - 2.7K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters_test.go
} ep.Labels["app"] = "example" ep.Locality.ClusterID = sk.Cluster shards.Shards[sk][i] = ep } } // convert to EndpointIndex index := model.NewEndpointIndex(model.NewXdsCache()) for shardKey, testEps := range shards.Shards { svc, _ := index.GetOrCreateEndpointShard("example.ns.svc.cluster.local", "ns") svc.Lock() svc.Shards[shardKey] = testEps svc.Unlock() } return index
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
shards := b.findShards(endpointIndex) if shards == nil { return nil } // Determine whether or not the target service is considered local to the cluster // and should, therefore, not be accessed from outside the cluster. isClusterLocal := b.clusterLocal var eps []*model.IstioEndpoint shards.RLock() defer shards.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
docs/distributed/SIZING.md
This will allow normal write operations to take place on systems that exceed the write tolerance.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 15 23:04:20 UTC 2023 - 3.9K bytes - Viewed (0) -
pilot/pkg/xds/eds.go
func (s *DiscoveryServer) SvcUpdate(shard model.ShardKey, hostname string, namespace string, event model.Event) { // When a service deleted, we should cleanup the endpoint shards and also remove keys from EndpointIndex to // prevent memory leaks. if event == model.EventDelete { inboundServiceDeletes.Increment() s.Env.EndpointIndex.DeleteServiceShard(shard, hostname, namespace, false) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
src/run.bash
# Use of this source code is governed by a BSD-style # license that can be found in the LICENSE file. # Environment variables that control run.bash: # # GO_TEST_SHARDS: number of "dist test" test shards that the # $GOROOT/test directory will be sliced up into for parallel # execution. Defaults to 1, unless GO_BUILDER_NAME is also specified, # in which case it defaults to 10. #
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:02:23 UTC 2024 - 1.7K bytes - Viewed (0)