Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 754 for port1 (0.21 sec)

  1. pkg/proxy/servicechangetracker_test.go

    			svc.Spec.Ports = addTestPort(svc.Spec.Ports, "port2", "UDP", 1235, 5321, 0)
    		}),
    		makeTestService("ns2", "node-port", func(svc *v1.Service) {
    			svc.Spec.Type = v1.ServiceTypeNodePort
    			svc.Spec.ClusterIP = "172.16.55.10"
    			svc.Spec.Ports = addTestPort(svc.Spec.Ports, "port1", "UDP", 345, 678, 0)
    			svc.Spec.Ports = addTestPort(svc.Spec.Ports, "port2", "TCP", 344, 677, 0)
    		}),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. security/pkg/k8s/chiron/utils_test.go

    	host := "127.0.0.1"
    	port1, err := getServerPort(server1.httpServer)
    	if err != nil {
    		t.Fatalf("error to get the server 1 port: %v", err)
    	}
    	port2, err := getServerPort(server2.httpServer)
    	if err != nil {
    		t.Fatalf("error to get the server 2 port: %v", err)
    	}
    
    	// Server 1 should be reachable, since it is not closed.
    	if !isTCPReachable(host, port1) {
    		t.Fatal("server 1 is unreachable")
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 03:58:11 UTC 2024
    - 13K bytes
    - Viewed (0)
  3. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go

    				}
    			}
    		})
    	}
    }
    
    func generateAddresses(num int) []v1.EndpointAddress {
    	addresses := make([]v1.EndpointAddress, num)
    	for i := 0; i < num; i++ {
    		part1 := i / 255
    		part2 := i % 255
    		ip := fmt.Sprintf("10.0.%d.%d", part1, part2)
    		addresses[i] = v1.EndpointAddress{IP: ip}
    	}
    	return addresses
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 12:57:29 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  4. pilot/pkg/model/service.go

    	// nolint: govet
    	out := *s
    	out.Attributes = s.Attributes.DeepCopy()
    	if s.Ports != nil {
    		out.Ports = make(PortList, len(s.Ports))
    		for i, port := range s.Ports {
    			if port != nil {
    				out.Ports[i] = &Port{
    					Name:     port.Name,
    					Port:     port.Port,
    					Protocol: port.Protocol,
    				}
    			} else {
    				out.Ports[i] = nil
    			}
    		}
    	}
    
    	if s.ServiceAccounts != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener_inbound.go

    			port := model.ServiceInstancePort{
    				ServicePort: &model.Port{
    					Name:     i.Port.Name,
    					Port:     int(i.Port.Number),
    					Protocol: protocol.Parse(i.Port.Protocol),
    				},
    				TargetPort: i.Port.Number, // No targetPort support in the API
    			}
    			bindtoPort := getBindToPort(i.CaptureMode, lb.node)
    			// Skip ports we cannot bind to
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  6. pkg/api/pod/warnings_test.go

    			}},
    			expected: []string{
    				`spec.containers[0].ports[2]: duplicate port definition with spec.containers[0].ports[0]`,
    				`spec.containers[1].ports[0]: duplicate port definition with spec.containers[0].ports[0]`,
    				`spec.containers[1].ports[0]: duplicate port definition with spec.containers[0].ports[2]`,
    				`spec.containers[1].ports[1]: duplicate port definition with spec.containers[0].ports[0]`,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 42.1K bytes
    - Viewed (0)
  7. 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)
  8. pilot/pkg/serviceregistry/serviceentry/conversion.go

    			// note: this is same as workloadentry handler
    			// endpoint port will first use the port defined in wle with same port name,
    			// if not port name not match, use the targetPort specified in ServiceEntry
    			// if both not matched, fallback to ServiceEntry port number.
    			var targetPort uint32
    			if port, ok := workloadInstance.PortMap[serviceEntryPort.Name]; ok && port > 0 {
    				targetPort = port
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  9. pkg/proxy/winkernel/proxier_test.go

    			svc.Spec.ClusterIP = svcIP1
    			svc.Spec.Ports = []v1.ServicePort{{
    				Name:     svcPortName1.Port,
    				Port:     int32(svcPort1),
    				Protocol: v1.ProtocolTCP,
    				NodePort: int32(svcNodePort1),
    			}}
    		}),
    		makeTestService(svcPortName2.Namespace, svcPortName2.Name, func(svc *v1.Service) {
    			svc.Spec.Type = "NodePort"
    			svc.Spec.ClusterIP = svcIP2
    			svc.Spec.Ports = []v1.ServicePort{{
    				Name:     svcPortName2.Port,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  10. pkg/proxy/endpointslicecache_test.go

    		},
    		Ports:       []discovery.EndpointPort{},
    		AddressType: discovery.AddressTypeIPv4,
    		Endpoints:   []discovery.Endpoint{},
    	}
    
    	for i, portNum := range portNums {
    		endpointSlice.Ports = append(endpointSlice.Ports, discovery.EndpointPort{
    			Name:     ptr.To(fmt.Sprintf("port-%d", i)),
    			Port:     portNum,
    			Protocol: ptr.To(v1.ProtocolTCP),
    		})
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
Back to top