Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for istioEndpoints (0.25 sec)

  1. 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)
  2. pilot/pkg/model/proxy_view_test.go

    			g := NewWithT(t)
    
    			view := (&model.Proxy{
    				Metadata: &model.NodeMetadata{
    					RequestedNetworkView: c.networkView,
    				},
    			}).GetView()
    
    			actual := view.IsVisible(&model.IstioEndpoint{
    				Network: network.ID(c.network),
    			})
    
    			g.Expect(actual).To(Equal(c.visible))
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/apigen/apigen_test.go

    	ds := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{})
    	sd := ds.MemRegistry
    	sd.AddHTTPService("fortio1.fortio.svc.cluster.local", "10.10.10.1", 8081)
    	sd.SetEndpoints("fortio1.fortio.svc.cluster.local", "", []*model.IstioEndpoint{
    		{
    			Address:         "127.0.0.1",
    			EndpointPort:    uint32(14056),
    			ServicePortName: "http-main",
    		},
    	})
    	return ds
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. pilot/pkg/xds/endpoints/mtls_checker.go

    // on the DR, original endpoint TLSMode (based on injection of sidecar), and PeerAuthentication settings.
    func (c *mtlsChecker) checkMtlsEnabled(ep *model.IstioEndpoint, isWaypoint bool) bool {
    	if drMode := c.destinationRule; drMode != nil {
    		return *drMode == networkingapi.ClientTLSSettings_ISTIO_MUTUAL
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 01 07:32:22 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/mock/discovery.go

    		return nil
    	}
    
    	// we make port 80 same as endpoint port, otherwise, it's distinct
    	target := port.Port
    	if target != 80 {
    		target += 1000
    	}
    
    	return &model.ServiceInstance{
    		Endpoint: &model.IstioEndpoint{
    			Address:         MakeIP(service, version),
    			EndpointPort:    uint32(target),
    			ServicePortName: port.Name,
    			Labels:          map[string]string{"version": fmt.Sprintf("v%d", version)},
    			Locality:        locality,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 07 18:40:05 UTC 2023
    - 3.7K 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