- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 79 for adsupdate (0.2 sec)
-
pilot/pkg/model/context.go
a := make(Resources, 0, len(r)) for _, rr := range r { a = append(a, &discovery.Resource{Resource: rr}) } return a } // XdsUpdates include information about the subset of updated resources. // See for example EDS incremental updates. type XdsUpdates = sets.Set[ConfigKey] // XdsLogDetails contains additional metadata that is captured by Generators and used by xds processors
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
pilot/pkg/model/push_context.go
// It is possible to split the endpoint tracking in future. type XDSUpdater interface { // EDSUpdate is called when the list of endpoints or labels in a Service is changed. // For each cluster and hostname, the full list of active endpoints (including empty list) // must be sent. The shard name is used as a key - current implementation is using the // registry name. EDSUpdate(shard ShardKey, hostname string, namespace string, entry []*IstioEndpoint)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
src/cmd/go/internal/modload/list.go
if mode != 0 { for _, m := range mods { if m.Reuse { continue } add := func(m *modinfo.ModulePublic) { sem <- token{} go func() { if mode&ListU != 0 { addUpdate(ctx, m) } if mode&ListVersions != 0 { addVersions(ctx, m, mode&ListRetractedVersions != 0) } if mode&ListRetracted != 0 { addRetraction(ctx, m) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 22:43:50 UTC 2023 - 8.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go
// Wait for the XDS event. ec.waitForXDS(t, false) } func (ec *serviceExportCacheImpl) waitForXDS(t *testing.T, exported bool) { t.Helper() retry.UntilSuccessOrFail(t, func() error { event := ec.opts.XDSUpdater.(*xdsfake.Updater).WaitOrFail(t, "eds") if len(event.Endpoints) != 1 { return fmt.Errorf("waitForXDS failed: expected 1 endpoint, found %d", len(event.Endpoints)) } hostName := host.Name(event.ID)
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/xds/pushqueue_test.go
Kind: kind.ServiceEntry, Name: "bar", Namespace: "ns1", }, ) if !reflect.DeepEqual(model.ConfigsOfKind(info.ConfigsUpdated, kind.ServiceEntry), expectedEds) { t.Errorf("Expected EdsUpdates to be %v, got %v", expectedEds, model.ConfigsOfKind(info.ConfigsUpdated, kind.ServiceEntry)) } if info.Full { t.Errorf("Expected full to be false, got true") } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
Full: true, ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: mcsHost.String(), Namespace: ns}), Reason: model.NewReasonStats(model.ServiceUpdate), } ic.opts.XDSUpdater.ConfigUpdate(pushReq) } // GetServiceImportIPs returns the list of ClusterSet IPs for the ServiceImport. // Exported for testing only. func GetServiceImportIPs(si *unstructured.Unstructured) []string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
clusterID := cluster.ID(fmt.Sprintf("cluster%d", networkNum)) networkID := network.ID(fmt.Sprintf("network%d", networkNum)) memRegistry := memory.NewServiceDiscovery() memRegistry.XdsUpdater = server.Discovery memRegistry.ClusterID = clusterID reg := serviceregistry.Simple{ ClusterID: clusterID, ProviderID: provider.Mock, DiscoveryController: memRegistry, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java
prevToken = null; readBufferIndex = BUFFER_SIZE; readBufferLen = 0; ch = 0; blkStart = 0; nextBlkStart = 0; if (synonymLoader != null && synonymLoader.isUpdate(lastModified)) { lastModified = synonymLoader.getLastModified(); final SynonymMap map = synonymLoader.getSynonymMap(); if (map != null) { synonymMap = map;
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 17K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
xdsUpdater := xdsfake.NewWithDelegate(delegate) meshcfg := mesh.NewFixedWatcher(mesh.DefaultMeshConfig()) istioStore := configController var controller *Controller if !workloadOnly { controller = NewController(configController, xdsUpdater, meshcfg, opts...) } else { controller = NewWorkloadEntryController(configController, xdsUpdater, meshcfg, opts...) } go controller.Run(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
return ic.serviceImports.Get(name.Name, name.Namespace) != nil } func (ic *serviceImportCacheImpl) checkXDS(t test.Failer) { t.Helper() ic.opts.XDSUpdater.(*xdsfake.Updater).MatchOrFail(t, xdsfake.Event{Type: "service", ID: serviceImportClusterSetHost.String()}) } func (ic *serviceImportCacheImpl) clusterLocalHost() host.Name {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 15.2K bytes - Viewed (0)