- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for portNames (0.14 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
) krt.Collection[model.ServiceInfo] { ServicesInfo := krt.NewCollection(Services, func(ctx krt.HandlerContext, s *v1.Service) *model.ServiceInfo { portNames := map[int32]model.ServicePortName{} for _, p := range s.Spec.Ports { portNames[p.Port] = model.ServicePortName{ PortName: p.Name, TargetPortName: p.TargetPort.StrVal, } } waypointKey := ""
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go
}, }, }, PortNames: map[int32]model.ServicePortName{ // Not a named port 80: {PortName: "80"}, // Named port found in WE 81: {PortName: "81", TargetPortName: "81-target"}, // Named port target found in WE 82: {PortName: "82", TargetPortName: "82-target"}, // Named port not found in WE 83: {PortName: "83", TargetPortName: "83-target"}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
// Here we manually create them for mocking purpose. svc1Ips := []string{"128.0.0.1"} portNames := []string{"tcp-port"} // Create 1 endpoint that refers to a pod in the same namespace. createEndpoints(t, controller, "svc1", "nsA", portNames, svc1Ips, nil, nil) // Creates 100 endpoints that refers to a pod in a different namespace. fakeSvcCounts := 100
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/kube/controller/ambient/workloads.go
// ServiceEntry has no explicit named targetPorts; targetPort only allows a number // Instead, there is name matching between the port names if named, f := svc.PortNames[int32(port.ServicePort)]; f { // get port name or target port tv, ok := p.Ports[named.PortName] if ok { // if we match one, override it. Otherwise, use the service port targetPort = tv } else if targetPort == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pilot/pkg/model/service.go
} type ServicePortName struct { PortName string TargetPortName string } type ServiceInfo struct { *workloadapi.Service // LabelSelectors for the Service. Note these are only used internally, not sent over XDS LabelSelector // PortNames provides a mapping of ServicePort -> port names. Note these are only used internally, not sent over XDS PortNames map[int32]ServicePortName
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/config/validation/validation.go
} } // Ensure unique port names portNames := make(map[string]bool) for _, s := range value.Servers { if s == nil { v = AppendValidation(v, fmt.Errorf("server may not be nil")) continue } if s.Port != nil { if portNames[s.Port.Name] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
tests/integration/security/filebased_tls_origination/destination_rule_tls_test.go
sni: server `).ApplyOrFail(t) for _, portName := range []string{"grpc", "http", "tcp"} { portName := portName t.NewSubTest(portName).Run(func(t framework.TestContext) { opts := echo.CallOptions{ To: server, Count: 1, Port: echo.Port{ Name: portName, }, Check: check.OK(), } if portName == "tcp" { opts.Scheme = scheme.TCP }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/config/kube/conversion.go
) // ConvertProtocol from k8s protocol and port name func ConvertProtocol(port int32, portName string, proto corev1.Protocol, appProto *string) protocol.Instance { if proto == corev1.ProtocolUDP { return protocol.UDP } // If application protocol is set, we will use that // If not, use the port name name := portName if appProto != nil { name = *appProto
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/kubelet/lifecycle/handlers.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 11:40:52 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/proxy/types.go
Sync() // SyncLoop runs periodic work. // This is expected to run as a goroutine or as the main loop of the app. // It does not return. SyncLoop() } // ServicePortName carries a namespace + name + portname. This is the unique // identifier for a load-balanced service. type ServicePortName struct { types.NamespacedName Port string Protocol v1.Protocol } func (spn ServicePortName) String() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 1.7K bytes - Viewed (0)