Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for istioEndpoints (0.26 sec)

  1. pilot/pkg/xds/endpoints/ep_filters.go

    		// Process all the endpoints.
    		for i, lbEp := range ep.llbEndpoints.LbEndpoints {
    			istioEndpoint := ep.istioEndpoints[i]
    
    			// If the proxy can't view the network for this endpoint, exclude it entirely.
    			if !b.proxyView.IsVisible(istioEndpoint) {
    				continue
    			}
    
    			// Copy the endpoint in order to expand the load balancing weight.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/util/workloadinstances/index_test.go

    		Name:      selector.Name,
    		Namespace: selector.Namespace,
    		Endpoint: &model.IstioEndpoint{
    			Address: "2.2.2.2",
    			Labels:  map[string]string{"app": "wle"}, // should match
    		},
    	}
    
    	wi2 := &model.WorkloadInstance{
    		Name:      "same-ip",
    		Namespace: selector.Namespace,
    		Endpoint: &model.IstioEndpoint{
    			Address: "2.2.2.2",
    			Labels:  map[string]string{"app": "wle"}, // should match
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go

    	"istio.io/istio/pkg/config/labels"
    	kubeUtil "istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/network"
    )
    
    // EndpointBuilder is a stateful IstioEndpoint builder with metadata used to build IstioEndpoint
    type EndpointBuilder struct {
    	controller controllerInterface
    
    	labels         labels.Instance
    	metaNetwork    network.ID
    	serviceAccount string
    	locality       model.Locality
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/conversion.go

    	}
    
    	return istioService
    }
    
    func ExternalNameEndpoints(svc *model.Service) []*model.IstioEndpoint {
    	if svc.Attributes.ExternalName == "" {
    		return nil
    	}
    	out := make([]*model.IstioEndpoint, 0, len(svc.Ports))
    
    	discoverabilityPolicy := model.AlwaysDiscoverable
    	if features.EnableMCSServiceDiscovery {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top