Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for pushEDS (0.1 sec)

  1. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    		v1beta1.LabelServiceName: name,
    	}).AsSelectorPreValidated().Add(*endpointSliceRequirement)
    }
    
    func (esc *endpointSliceController) pushEDS(hostnames []host.Name, namespace string) {
    	shard := model.ShardKeyFromRegistry(esc.c)
    	// Even though we just read from the cache, we need the full lock to ensure pushEDS
    	// runs sequentially when `EnableK8SServiceSelectWorkloadEntries` is enabled. Otherwise,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. pilot/pkg/xds/endpoints/endpoint_builder.go

    	// This can happen if a ServiceEntry's resolution is changed from STATIC to DNS which changes the Envoy cluster type from
    	// EDS to STRICT_DNS or LOGICAL_DNS. When pushEds is called before Envoy sends the updated cluster list via Endpoint request which in turn
    	// will update "Connection.Clusters", we might accidentally send EDS updates for STRICT_DNS cluster. This check guards
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 02:18:19 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/controller.go

    	matchedHostnames := slices.Map(matchedServices, func(e *v1.Service) host.Name {
    		return kube.ServiceHostname(e.Name, e.Namespace, c.opts.DomainSuffix)
    	})
    	c.endpoints.pushEDS(matchedHostnames, si.Namespace)
    }
    
    func (c *Controller) onSystemNamespaceEvent(_, ns *v1.Namespace, ev model.Event) error {
    	if ev == model.EventDelete {
    		return nil
    	}
    	if c.setNetworkFromNamespace(ns) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top