Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for svcPorts (1.11 sec)

  1. pilot/pkg/config/kube/gateway/deploymentcontroller.go

    	GatewayNameLabel          string
    }
    
    func extractServicePorts(gw gateway.Gateway) []corev1.ServicePort {
    	tcp := strings.ToLower(string(protocol.TCP))
    	svcPorts := make([]corev1.ServicePort, 0, len(gw.Spec.Listeners)+1)
    	svcPorts = append(svcPorts, corev1.ServicePort{
    		Name:        "status-port",
    		Port:        int32(15021),
    		AppProtocol: &tcp,
    	})
    	portNums := sets.New[int32]()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 21:43:20 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/conversion.go

    		resolution = model.DNSRoundRobinLB
    	case networking.ServiceEntry_STATIC:
    		resolution = model.ClientSideLB
    	}
    
    	svcPorts := make(model.PortList, 0, len(serviceEntry.Ports))
    	var portOverrides map[uint32]uint32
    	for _, port := range serviceEntry.Ports {
    		svcPorts = append(svcPorts, convertPort(port))
    		if resolution == model.Passthrough && port.TargetPort != 0 {
    			if portOverrides == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    }
    
    func generateService(name, namespace string, labels, annotations map[string]string,
    	ports []int32, selector map[string]string, ip string,
    ) *corev1.Service {
    	svcPorts := make([]corev1.ServicePort, 0)
    	for _, p := range ports {
    		svcPorts = append(svcPorts, corev1.ServicePort{
    			Name:     "tcp-port",
    			Port:     p,
    			Protocol: "http",
    		})
    	}
    
    	return &corev1.Service{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    	}
    
    	svcPorts := make(model.PortList, 0, len(ports))
    	for name, port := range ports {
    		svcPort := &model.Port{
    			Name:     name,
    			Port:     port,
    			Protocol: convertPortNameToProtocol(name),
    		}
    		svcPorts = append(svcPorts, svcPort)
    	}
    
    	sortPorts(svcPorts)
    	svc.Ports = svcPorts
    	return svc
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    }
    
    func generateService(name, namespace string, labels, annotations map[string]string,
    	ports []int32, selector map[string]string, ip string,
    ) *corev1.Service {
    	svcPorts := make([]corev1.ServicePort, 0)
    	for _, p := range ports {
    		svcPorts = append(svcPorts, corev1.ServicePort{
    			Name:     "tcp-port",
    			Port:     p,
    			Protocol: "http",
    		})
    	}
    
    	return &corev1.Service{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  6. pkg/printers/internalversion/printers.go

    		internalIP = obj.Spec.ClusterIPs[0]
    	}
    
    	externalIP := getServiceExternalIP(obj, options.Wide)
    	svcPorts := makePortString(obj.Spec.Ports)
    	if len(svcPorts) == 0 {
    		svcPorts = "<none>"
    	}
    
    	row.Cells = append(row.Cells, obj.Name, string(svcType), internalIP, externalIP, svcPorts, translateTimestampSince(obj.CreationTimestamp))
    	if options.Wide {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  7. pkg/proxy/winkernel/proxier_test.go

    	if proxier == nil {
    		t.Error()
    	}
    
    	svcIP1 := "10.20.30.41"
    	svcPort1 := 80
    	svcNodePort1 := 3001
    	svcPortName1 := proxy.ServicePortName{
    		NamespacedName: makeNSN("ns1", "svc1"),
    		Port:           "p80",
    		Protocol:       v1.ProtocolTCP,
    	}
    
    	svcIP2 := "10.20.30.42"
    	svcPort2 := 80
    	svcNodePort2 := 3002
    	svcPortName2 := proxy.ServicePortName{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. pilot/pkg/xds/endpoints/mtls_checker.go

    type mtlsChecker struct {
    	push            *model.PushContext
    	svcPort         int
    	destinationRule *networkingapi.ClientTLSSettings_TLSmode
    }
    
    func newMtlsChecker(push *model.PushContext, svcPort int, dr *config.Config, subset string) *mtlsChecker {
    	return &mtlsChecker{
    		push:            push,
    		svcPort:         svcPort,
    		destinationRule: tlsModeForDestinationRule(dr, subset, svcPort),
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Dec 01 07:32:22 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go

    )
    
    // findServicePort finds the service port by name or numerically.
    func findServicePort(svc *v1.Service, port int32) (*v1.ServicePort, error) {
    	for _, svcPort := range svc.Spec.Ports {
    		if svcPort.Port == port {
    			return &svcPort, nil
    		}
    	}
    	return nil, errors.NewServiceUnavailable(fmt.Sprintf("no service port %d found for service %q", port, svc.Name))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/util.go

    // match is found, fail.
    func FindPort(pod *v1.Pod, svcPort *v1.ServicePort) (int, error) {
    	portName := svcPort.TargetPort
    	switch portName.Type {
    	case intstr.String:
    		name := portName.StrVal
    		for _, container := range pod.Spec.Containers {
    			for _, port := range container.Ports {
    				if port.Name == name && port.Protocol == svcPort.Protocol {
    					return int(port.ContainerPort), nil
    				}
    			}
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jul 28 02:01:47 UTC 2023
    - 6.1K bytes
    - Viewed (0)
Back to top