Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 649 for Warningf (0.11 sec)

  1. pkg/registry/core/service/portallocator/allocator.go

    // unallocated port or a port out of the range is a no-op and
    // returns no error.
    func (r *PortAllocator) Release(port int) error {
    	ok, offset := r.contains(port)
    	if !ok {
    		klog.Warningf("port is not in the range when release it. port: %v", port)
    		return nil
    	}
    
    	err := r.alloc.Release(offset)
    	if err == nil {
    		// update metrics
    		r.metrics.setAllocated(r.Used())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. pkg/volume/local/local.go

    	mountOptions := util.MountOptionFromSpec(spec, options...)
    	err = dm.mounter.FormatAndMount(devicePath, deviceMountPath, fstype, mountOptions)
    	if err != nil {
    		if rmErr := os.Remove(deviceMountPath); rmErr != nil {
    			klog.Warningf("local: failed to remove %s: %v", deviceMountPath, rmErr)
    		}
    		return fmt.Errorf("local: failed to mount device %s at %s (fstype: %s), error %w", devicePath, deviceMountPath, fstype, err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

    	switch {
    	case errors.IsNotFound(err):
    		// ignore, authConfigMap is nil now
    		return nil
    	case errors.IsForbidden(err):
    		klog.Warningf("Unable to get configmap/%s in %s.  Usually fixed by "+
    			"'kubectl create rolebinding -n %s ROLEBINDING_NAME --role=%s --serviceaccount=YOUR_NS:YOUR_SA'",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go

    	}
    	// If the current API Server location on disk doesn't match the expected API server, show a warning
    	if currentConfig.Clusters[currentCluster].Server != config.Clusters[expectedCluster].Server {
    		klog.Warningf("a kubeconfig file %q exists already but has an unexpected API Server URL: expected: %s, got: %s",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:04:18 UTC 2024
    - 27K bytes
    - Viewed (0)
  5. pkg/volume/util/operationexecutor/operation_generator.go

    			}
    			// If the mount path could not be found, don't fail the unmount, but instead log a warning and proceed,
    			// using the value from deviceToDetach.DeviceMountPath, so that the device can be marked as unmounted
    			deviceMountPath = deviceToDetach.DeviceMountPath
    			klog.Warningf(deviceToDetach.GenerateMsgDetailed(fmt.Sprintf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/apis/kubeadm/validation/validation.go

    	allErrs = append(allErrs, componentconfigs.Validate(c)...)
    	for _, certError := range ValidateCertValidity(c) {
    		klog.Warningf("WARNING: %s", certError.Error())
    	}
    	return allErrs
    }
    
    // ValidateAPIServer validates a APIServer object and collects all encountered errors
    func ValidateAPIServer(a *kubeadm.APIServer, fldPath *field.Path) field.ErrorList {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 16:01:49 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/preflight/checks.go

    	if addr == nil {
    		warnings = append(warnings, errors.Errorf("hostname \"%s\" could not be reached", hc.nodeName))
    	}
    	if err != nil {
    		warnings = append(warnings, errors.Wrapf(err, "hostname \"%s\"", hc.nodeName))
    	}
    	return warnings, errorList
    }
    
    // HTTPProxyCheck checks if https connection to specific host is going
    // to be done directly or over proxy. If proxy detected, it will return warning.
    type HTTPProxyCheck struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:20:55 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/phases/addons/dns/dns.go

    			// Errors in Corefile Migration is verified during preflight checks. This part will be executed when a user has chosen
    			// to ignore preflight check errors.
    			canMigrateCorefile = false
    			klog.Warningf("the CoreDNS Configuration was not migrated: %v. The existing CoreDNS Corefile configuration has been retained.", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 10:21:20 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/server/options/etcd.go

    		sizes, err := ParseWatchCacheSizes(f.Options.WatchCacheSizes)
    		if err != nil {
    			return generic.RESTOptions{}, err
    		}
    		size, ok := sizes[resource]
    		if ok && size > 0 {
    			klog.Warningf("Dropping watch-cache-size for %v - watchCache size is now dynamic", resource)
    		}
    		if ok && size <= 0 {
    			klog.V(3).InfoS("Not using watch cache", "resource", resource)
    			ret.Decorator = generic.UndecoratedStorage
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 15:02:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  10. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    		Name:         driverName,
    		NodeID:       driverNodeID,
    		TopologyKeys: sets.List[string](topologyKeys),
    	}
    
    	if maxAttachLimit > 0 {
    		if maxAttachLimit > math.MaxInt32 {
    			klog.Warningf("Exceeded max supported attach limit value, truncating it to %d", math.MaxInt32)
    			maxAttachLimit = math.MaxInt32
    		}
    		m := int32(maxAttachLimit)
    		driverSpec.Allocatable = &storagev1.VolumeNodeResources{Count: &m}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
Back to top