- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 154 for Port (0.11 sec)
-
pkg/config/validation/validation.go
errs = AppendValidation(errs, agent.ValidatePort(int(port.Number))) } // nolint: staticcheck if port.TargetPort > 0 { errs = AppendValidation(errs, fmt.Errorf("targetPort has no impact on Gateways")) } if port.Name == "" { errs = AppendValidation(errs, fmt.Errorf("port name must be set: %v", port)) } return } func validateServerBind(port *networking.Port, bind string) (errs error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
var portTrafficPolicy *networking.TrafficPolicy_PortTrafficPolicy // Check if port level overrides exist, if yes override with them. for _, p := range policy.PortLevelSettings { if p.Port != nil && uint32(port.Port) == p.Port.Number { // per the docs, port level policies do not inherit and instead to defaults if not provided portTrafficPolicy = p break } } if portTrafficPolicy == nil { return policy, false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
// For service instances with the same port, // we still need to capture all the instances on this port, as its required to populate telemetry metadata // The first instance will be used as the "primary" instance; this means if we have an conflicts between // Services the first one wins port := int(instance.Port.TargetPort) clustersToBuild[port] = append(clustersToBuild[port], instance) } bind := actualLocalHosts[0]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
t.Fatalf("expected %d listeners, found %d", len(tc.expectedListener), len(listeners)) } for _, port := range tc.expectedListener { l := findListenerByPort(listeners, uint32(port)) if l == nil { t.Fatalf("found no listener with port %d", port) } } }) } } func TestOutboundListenerDualStackWildcard(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/options.go
// The listening address for HTTP (debug). If the port in the address is empty or "0" (as in "127.0.0.1:" or "[::1]:0") // a port number is automatically chosen. HTTPAddr string // The listening address for HTTPS (webhooks). If the port in the address is empty or "0" (as in "127.0.0.1:" or "[::1]:0") // a port number is automatically chosen. // If the address is empty, the secure port is disabled, and the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
for _, port := range svc.Ports { if port.Protocol == protocol.UDP { continue } portString := strconv.Itoa(port.Port) cc := inboundChainConfig{ clusterName: model.BuildSubsetKey(model.TrafficDirectionInboundVIP, "tcp", svc.Hostname, port.Port), policyService: svc, port: model.ServiceInstancePort{ ServicePort: port, TargetPort: uint32(port.Port), },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/networking/core/listenertest/match.go
} if want.Type != "" { assert.Equal(t, want.Type, haveType, context(fmt.Sprintf("type should be equal (%+v)", have.FilterChainMatch))) } if want.Port != 0 { assert.Equal(t, want.Port, have.GetFilterChainMatch().GetDestinationPort().GetValue(), context("port should be equal")) } haveNetwork, haveHTTP := xdstest.ExtractFilterNames(t, have) if want.TotalMatch { if want.NetworkFilters != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/config/security/security.go
} info := JwksInfo{} switch u.Scheme { case "http": info.UseSSL = false info.Port = 80 case "https": info.UseSSL = true info.Port = 443 default: return JwksInfo{}, fmt.Errorf("URI scheme %q is not supported", u.Scheme) } if u.Port() != "" { info.Port, err = strconv.Atoi(u.Port()) if err != nil { return JwksInfo{}, err } } info.Hostname = host.Name(u.Hostname())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 04:43:34 UTC 2024 - 9.4K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
} } } else { // First, check section and port apply. This must come first if parentRef.Port != 0 && parentRef.Port != parent.Port { return &ParentError{ Reason: ParentErrorNotAccepted, Message: fmt.Sprintf("port %v not found", parentRef.Port), } } if len(parentRef.SectionName) > 0 && parentRef.SectionName != parent.SectionName {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
} func buildTestClusters(c clusterTest) []*cluster.Cluster { c = c.fillDefaults() servicePort := model.PortList{ &model.Port{ Name: "default", Port: 8080, Protocol: protocol.HTTP, }, &model.Port{ Name: "auto", Port: 9090, Protocol: protocol.Unsupported, }, } service := &model.Service{ Hostname: host.Name(c.serviceHostname),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0)