Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 154 for Port (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top