- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for svcPorts (1.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)