Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for validatePorts (0.23 sec)

  1. pkg/apis/discovery/validation/validation.go

    	allErrs = append(allErrs, validateAddressType(endpointSlice.AddressType)...)
    	allErrs = append(allErrs, validateEndpoints(endpointSlice.Endpoints, endpointSlice.AddressType, field.NewPath("endpoints"))...)
    	allErrs = append(allErrs, validatePorts(endpointSlice.Ports, field.NewPath("ports"))...)
    
    	return allErrs
    }
    
    // ValidateEndpointSliceCreate validates an EndpointSlice when it is created.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 18 08:49:15 UTC 2021
    - 7.8K bytes
    - Viewed (0)
  2. pkg/config/security/security.go

    	case hasPrefix(key, attrRequestClaims):
    		return validateMapKey(key)
    	case isEqual(key, attrDestIP):
    		return ValidateIPs(values)
    	case isEqual(key, attrDestPort):
    		return ValidatePorts(values)
    	case isEqual(key, attrConnSNI):
    	case hasPrefix(key, attrExperimental):
    		return validateMapKey(key)
    	case isEqual(key, attrDestNamespace):
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 07 04:43:34 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. pkg/config/validation/validation.go

    						errs = appendErrors(errs, fmt.Errorf("`to.operation` must not be empty, found at rule %d", i))
    					}
    					errs = appendErrors(errs, security.ValidatePorts(to.Operation.GetPorts()))
    					errs = appendErrors(errs, security.ValidatePorts(to.Operation.GetNotPorts()))
    					errs = appendErrors(errs, security.CheckEmptyValues("Ports", op.Ports))
    					errs = appendErrors(errs, security.CheckEmptyValues("Methods", op.Methods))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
  4. pkg/config/validation/agent/extensionprovider.go

    	if config == nil {
    		return fmt.Errorf("nil EnvoyExternalAuthorizationHttpProvider")
    	}
    	if err := ValidatePort(int(config.Port)); err != nil {
    		errs = AppendErrors(errs, err)
    	}
    	if err := validateExtensionProviderService(config.Service); err != nil {
    		errs = AppendErrors(errs, err)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. pilot/pkg/model/validation.go

    			}
    		} else if !labels.IsDNS1123Label(port.Name) {
    			errs = multierror.Append(errs, fmt.Errorf("invalid name: %q", port.Name))
    		}
    		if err := agent.ValidatePort(port.Port); err != nil {
    			errs = multierror.Append(errs,
    				fmt.Errorf("invalid service port value %d for %q: %v", port.Port, port.Name, err))
    		}
    	}
    	return errs
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. pkg/webhooks/validation/server/server.go

    			return reasonInvalidConfig, fmt.Errorf("unknown field %q on %s resource %s/%s",
    				key, kind, namespace, name)
    		}
    	}
    
    	return "", nil
    }
    
    // validatePort checks that the network port is in range
    func validatePort(port int) error {
    	if 1 <= port && port <= 65535 {
    		return nil
    	}
    	return fmt.Errorf("port number %d must be in the range 1..65535", port)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat May 04 06:13:56 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  7. pkg/config/validation/agent/validation.go

    	if drainDuration%time.Second != 0 {
    		errs = multierror.Append(errs,
    			errors.New("drain time only supports durations to seconds precision"))
    	}
    	return
    }
    
    // ValidatePort checks that the network port is in range
    func ValidatePort(port int) error {
    	if 1 <= port && port <= 65535 {
    		return nil
    	}
    	return fmt.Errorf("port number %d must be in the range 1..65535", port)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  8. pkg/config/validation/virtualservice.go

    				errs = appendErrors(errs, validateStringMatch(qp, "queryParams"))
    			}
    		}
    	}
    
    	for _, match := range http.Match {
    		if match != nil {
    			if match.Port != 0 {
    				errs = appendErrors(errs, agent.ValidatePort(int(match.Port)))
    			}
    			errs = appendErrors(errs, labels.Instance(match.SourceLabels).Validate())
    			errs = appendErrors(errs, validateGatewayNames(match.Gateways, false))
    			if match.SourceNamespace != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:27 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/apis/kubeadm/validation/validation.go

    	allErrs := field.ErrorList{}
    	if netutils.ParseIPSloppy(ipaddr) == nil {
    		allErrs = append(allErrs, field.Invalid(fldPath, ipaddr, "ip address is not valid"))
    	}
    	return allErrs
    }
    
    // ValidatePort validates port numbers
    func ValidatePort(port int32, fldPath *field.Path) field.ErrorList {
    	allErrs := field.ErrorList{}
    	if _, err := kubeadmutil.ParsePort(strconv.Itoa(int(port))); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 16:01:49 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  10. pkg/config/validation/agent/validation_test.go

    func TestValidatePort(t *testing.T) {
    	ports := map[int]bool{
    		0:     false,
    		65536: false,
    		-1:    false,
    		100:   true,
    		1000:  true,
    		65535: true,
    	}
    	for port, valid := range ports {
    		if got := ValidatePort(port); (got == nil) != valid {
    			t.Errorf("Failed: got valid=%t but wanted valid=%t: %v for %d", got == nil, valid, got, port)
    		}
    	}
    }
    
    func TestValidateControlPlaneAuthPolicy(t *testing.T) {
    	cases := []struct {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 39.1K bytes
    - Viewed (0)
Back to top