- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 108 for Shards (0.12 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) -
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) -
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) -
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) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
{ "aliases", "allocation", "count", "fielddata", "health", "indices", "master", "nodeattrs", "nodes", "pending_tasks", "plugins", "recovery", "repositories", "thread_pool", "shards", "segments", "snapshots", "templates" }; // =================================================================================== // Attribute
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java
public void onResponse(final SearchResponse searchResponse) { if (searchResponse.getFailedShards() > 0) { deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards())); } else { deferred.resolve(createResponse(searchResponse)); } } @Override
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 13.4K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
retval := discovery.DiscoveryResponse{} if len(responses) == 0 { return &retval, nil } for _, response := range responses { // Combine all the shards as one, even if that means losing information about // the control plane version from each shard. retval.ControlPlane = response.ControlPlane retval.Resources = append(retval.Resources, response.Resources...) } return &retval, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.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)