- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 348 for Shardz (0.14 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) -
pilot/pkg/xds/eds_test.go
} testEndpoints("10.10.1.1", "outbound|8080||flipflop.com", adscConn, t) if shard, ok := s.Discovery.Env.EndpointIndex.ShardsForService("flipflop.com", ""); !ok { t.Fatalf("Expected service key %s to be present in EndpointIndex. But missing %v", "flipflop.com", s.Discovery.Env.EndpointIndex.Shardz()) } else { assert.Equal(t, sets.SortedList(shard.ServiceAccounts), []string{tt.newSa}) } }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
writeJSON(w, all, req) } // Dumps info about the endpoint shards, tracked using the new direct interface. // Legacy registry provides are synced to the new data structure as well, during // the full push. func (s *DiscoveryServer) endpointShardz(w http.ResponseWriter, req *http.Request) { writeJSON(w, s.Env.EndpointIndex.Shardz(), req) } func (s *DiscoveryServer) cachez(w http.ResponseWriter, req *http.Request) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K 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) -
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) -
pilot/pkg/serviceregistry/serviceentry/controller.go
} } // doEdsCacheUpdate invokes XdsUpdater's EDSCacheUpdate to update endpoint shards. func (s *Controller) doEdsCacheUpdate(keys sets.Set[instancesKey]) { endpoints := s.buildEndpoints(keys) shard := model.ShardKeyFromRegistry(s) // This is delete. if len(endpoints) == 0 { for k := range keys { s.XdsUpdater.EDSCacheUpdate(shard, string(k.hostname), k.namespace, nil) } } else { for k, eps := range endpoints {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K 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) -
cmd/erasure-decode.go
// Reading first time on this disk, hence the buffer needs to be allocated. // Subsequent reads will reuse this buffer. p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes. // Hence the following statement ensures that the buffer size is reset to the right size. p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize] n, err := rr.ReadAt(p.buf[bufIdx], p.offset)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0)