Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ConvertService (0.23 sec)

  1. pilot/pkg/serviceregistry/kube/conversion_test.go

    					Port:     8080,
    					Protocol: corev1.ProtocolTCP,
    				},
    				{
    					Name:     "https",
    					Protocol: corev1.ProtocolTCP,
    					Port:     443,
    				},
    			},
    		},
    	}
    
    	service := ConvertService(localSvc, domainSuffix, clusterID, &meshconfig.MeshConfig{TrustDomain: domainSuffix})
    	if service == nil {
    		t.Fatalf("could not convert service")
    	}
    
    	if service.CreationTime != tnow {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/conversion.go

    	return &model.Port{
    		Name:     port.Name,
    		Port:     int(port.Port),
    		Protocol: kube.ConvertProtocol(port.Port, port.Name, port.Protocol, port.AppProtocol),
    	}
    }
    
    func ConvertService(svc corev1.Service, domainSuffix string, clusterID cluster.ID, mesh *meshconfig.MeshConfig) *model.Service {
    	addrs := []string{constants.UnspecifiedIP}
    	resolution := model.ClientSideLB
    	externalName := ""
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/conversion.go

    // This does not include endpoints - they'll be represented as EndpointSlice or EDS.
    //
    // See convertServices() for the reverse conversion, used by Istio to handle ServiceEntry configs.
    // See kube.ConvertService for the conversion from K8S to internal Service.
    func ServiceToServiceEntry(svc *model.Service, proxy *model.Proxy) *config.Config {
    	gvk := gvk.ServiceEntry
    	se := &networking.ServiceEntry{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/controller.go

    	namespaceDiscoveryHandlers []func(ns string, event model.Event)
    
    	// This is only used for test
    	stop chan struct{}
    
    	sync.RWMutex
    	// servicesMap stores hostname ==> service, it is used to reduce convertService calls.
    	servicesMap map[host.Name]*model.Service
    	// nodeSelectorsForServices stores hostname => label selectors that can be used to
    	// refine the set of node port IPs for a service.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			curr:     &updatedSvc,
    			prevConv: kube.ConvertService(svc, constants.DefaultClusterLocalDomain, "", nil),
    			currConv: kube.ConvertService(updatedSvc, constants.DefaultClusterLocalDomain, "", nil),
    			expect:   true,
    		},
    		testcase{
    			name:     "target ports unchanged",
    			prev:     &svc,
    			curr:     &svc,
    			prevConv: kube.ConvertService(svc, constants.DefaultClusterLocalDomain, "", nil),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
Back to top