Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for buildIstioEndpointsWithService (0.19 sec)

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

    				endpoints = append(endpoints, istioEndpoint)
    			}
    		}
    	}
    	esc.endpointCache.Update(hostName, slice.Name, endpoints)
    }
    
    func (esc *endpointSliceController) buildIstioEndpointsWithService(name, namespace string, hostName host.Name, updateCache bool) []*model.IstioEndpoint {
    	esLabelSelector := endpointSliceSelectorForService(name)
    	slices := esc.slices.List(namespace, esLabelSelector)
    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/serviceregistry/kube/controller/controller.go

    	c.handlers.NotifyServiceHandlers(prevConv, currConv, event)
    }
    
    func (c *Controller) buildEndpointsForService(svc *model.Service, updateCache bool) []*model.IstioEndpoint {
    	endpoints := c.endpoints.buildIstioEndpointsWithService(svc.Attributes.Name, svc.Attributes.Namespace, svc.Hostname, updateCache)
    	if features.EnableK8SServiceSelectWorkloadEntries {
    		fep := c.collectWorkloadInstanceEndpoints(svc)
    		endpoints = append(endpoints, fep...)
    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