- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for portNames (0.34 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) -
pkg/apis/discovery/validation/validation.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 18 08:49:15 UTC 2021 - 7.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
if svc == nil { t.Fatal("failed to get service") } // Create an endpoint that indicates it's an MCS endpoint for the service. svc1Ips := []string{"128.0.0.1"} portNames := []string{"tcp-port"} createEndpoints(t, controller, svcName, ns, portNames, svc1Ips, nil, map[string]string{ mcs.LabelServiceName: svcName, }) fx.AssertEmpty(t, time.Millisecond*50) // Ensure that no endpoint is create
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K 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) -
pkg/config/analysis/analyzers/service/portname.go
Xiaopeng Han <******@****.***> 1694789158 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 15 14:45:58 UTC 2023 - 2.6K bytes - Viewed (0) -
tests/integration/telemetry/policy/traffic_allow_any_test.go
"net/http" "testing" "istio.io/istio/pkg/test/framework/components/prometheus" ) func TestOutboundTrafficPolicy_AllowAny(t *testing.T) { cases := []*TestCase{ { Name: "HTTP Traffic", PortName: "http", Expected: Expected{ Query: prometheus.Query{ Metric: "istio_requests_total", Aggregation: "sum", Labels: map[string]string{ "reporter": "source",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 18 18:03:23 UTC 2022 - 5.4K bytes - Viewed (0)