Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 46 of 46 for adsupdate (0.34 sec)

  1. pkg/adsc/adsc_test.go

    				TypeUrl: request.TypeUrl,
    			}
    		}
    
    		tc := testCase{
    			desc: desc.desc,
    			inAdsc: &ADSC{
    				Received:   make(map[string]*discovery.DiscoveryResponse),
    				Updates:    make(chan string),
    				XDSUpdates: make(chan *discovery.DiscoveryResponse),
    				cfg: &ADSConfig{
    					Config:                   Config{},
    					InitialDiscoveryRequests: desc.initialRequests,
    				},
    				VersionInfo: map[string]string{},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 15.4K bytes
    - Viewed (0)
  2. 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)
  3. pilot/pkg/xds/sds.go

    		configs = append(configs, config.HashCode())
    	}
    	return configs
    }
    
    func (sr SecretResource) Cacheable() bool {
    	return true
    }
    
    func sdsNeedsPush(updates model.XdsUpdates) bool {
    	if len(updates) == 0 {
    		return true
    	}
    	for update := range updates {
    		switch update.Kind {
    		case kind.Secret:
    			return true
    		case kind.ReferenceGrant:
    			return true
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 15 23:04:36 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/network.go

    		if c.extractGatewaysInner(svc) {
    			gwsChanged = true
    			break
    		}
    	}
    	c.Unlock()
    	if gwsChanged {
    		c.NotifyGatewayHandlers()
    		// TODO ConfigUpdate via gateway handler
    		c.opts.XDSUpdater.ConfigUpdate(&model.PushRequest{Full: true, Reason: model.NewReasonStats(model.NetworksTrigger)})
    	}
    }
    
    // extractGatewaysInner performs the logic for extractGatewaysFromService without locking the controller.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. pilot/pkg/xds/eds_test.go

    	})
    	t.Run("UDSEndpoints", func(t *testing.T) {
    		testUdsEndpoints(adscConn, t)
    	})
    	t.Run("PushIncremental", func(t *testing.T) {
    		edsUpdateInc(s, adscConn, t)
    	})
    	t.Run("Push", func(t *testing.T) {
    		edsUpdates(s, adscConn, t)
    	})
    	t.Run("MultipleRequest", func(t *testing.T) {
    		multipleRequest(s, false, 20, 5, 25*time.Second, nil, t)
    	})
    	// 5 pushes for 100 clients, using EDS incremental only.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 20:58:47 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  6. okhttp/src/main/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.gz

    divtasvuodna.no divttasvuotna.no diy dj dk dk.eu.org dlugoleka.pl dm dn.ua dnepropetrovsk.ua dni.us dnipropetrovsk.ua dnp dnsalias.com dnsalias.net dnsalias.org dnsdojo.com dnsdojo.net dnsdojo.org dnsfor.me dnshome.de dnsiskinky.com dnsking.ch dnsup.net dnsupdate.info dnsupdater.de do docs doctor does-it.net doesntexist.com doesntexist.org dog dolls.museum domains donetsk.ua donna.no donostia.museum dontexist.com dontexist.net dontexist.org doomdns.com doomdns.org dopaas.com doshi.yamanashi.jp dot dovre.no...
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 40.4K bytes
    - Viewed (0)
Back to top