Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for istioEndpoints (0.16 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/util/xdsfake/updater.go

    	Reason model.ReasonStats
    
    	Namespace string
    
    	// The endpoints associated with an EDS push if any
    	Endpoints []*model.IstioEndpoint
    
    	// EndpointCount, used in matches only
    	EndpointCount int
    }
    
    func (fx *Updater) EDSUpdate(c model.ShardKey, hostname string, ns string, entry []*model.IstioEndpoint) {
    	select {
    	case fx.Events <- Event{Type: "eds", ID: hostname, Endpoints: entry, Namespace: ns}:
    	default:
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 29 18:40:34 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  5. 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)
  6. pilot/pkg/config/kube/gateway/context.go

    }
    
    func (gc GatewayContext) GetService(hostname, namespace string) *model.Service {
    	return gc.ps.ServiceIndex.HostnameAndNamespace[host.Name(hostname)][namespace]
    }
    
    func instancesEmpty(m map[int][]*model.IstioEndpoint) bool {
    	for _, instances := range m {
    		if len(instances) > 0 {
    			return false
    		}
    	}
    	return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 18:33:02 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top