- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 2,118 for Warningf (0.17 sec)
-
cmd/kubeadm/app/features/features.go
featureSpec, ok := (*f)[k] if !ok { return nil, errors.Errorf("unrecognized feature-gate key: %s", k) } if featureSpec.PreRelease == featuregate.Deprecated { klog.Warningf("Setting deprecated feature gate %s=%s. It will be removed in a future release.", k, v) } boolValue, err := strconv.ParseBool(v) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 13:55:11 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/config/initconfiguration.go
return nil, err } continue } // If the group is neither a kubeadm core type or of a supported component config group, we dump a warning about it being ignored if !componentconfigs.Scheme.IsGroupRegistered(gvk.Group) { klog.Warningf("[config] WARNING: Ignored YAML document with GroupVersionKind %v\n", gvk) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 12:41:16 UTC 2024 - 17.3K bytes - Viewed (0) -
pkg/config/validation/agent/validation.go
v.Err = appendError(v.Err, t.Err) v.Warning = appendError(v.Warning, t.Warning) default: v.Err = appendError(v.Err, t) } } return v } // AppendWarningf appends a formatted warning string // nolint: unparam func AppendWarningf(v Validation, format string, a ...any) Validation { return AppendValidation(v, Warningf(format, a...)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 30.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/controlplane/manifests.go
if isValidAuthzMode(requested) { mode = append(mode, requested) } else { klog.Warningf("ignoring unknown kube-apiserver authorization-mode %q", requested) } } // only return the user provided mode if at least one was valid if len(mode) > 0 { if !compareAuthzModes(defaultMode, mode) { klog.Warningf("the default kube-apiserver authorization-mode is %q; using %q", strings.Join(defaultMode, ","),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 14:43:47 UTC 2024 - 17.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
return } if r.svcQueue.NumRequeues(key) < maxRetries { klog.V(2).InfoS("Error syncing Service, retrying", "service", key, "err", err) r.svcQueue.AddRateLimited(key) return } klog.Warningf("Dropping Service %q out of the queue: %v", key, err) r.svcQueue.Forget(key) runtime.HandleError(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/auth/authorizer/abac/abac.go
if !ok { return nil, policyLoadError{path, i, b, fmt.Errorf("unrecognized object: %#v", decodedObj)} } pl = append(pl, decodedPolicy) } if unversionedLines > 0 { klog.Warningf("Policy file %s contained unversioned rules. See docs/admin/authorization.md#abac-mode for ABAC file format details.", path) } if err := scanner.Err(); err != nil { return nil, policyLoadError{path, -1, nil, err}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 11 03:11:30 UTC 2021 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
if quit { return false } defer c.queue.Done(key) // log slow aggregations start := time.Now() defer func() { elapsed := time.Since(start) if elapsed > time.Second { klog.Warningf("slow openapi aggregation of %q: %s", key, elapsed) } }() err := c.syncFn(key) if err == nil { c.queue.Forget(key) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/certs.go
// and validates that the cert is a CA. Failure to load the key produces a warning. func validateCACertAndKey(l certKeyLocation) error { if err := validateCACert(l); err != nil { return err } _, err := pkiutil.TryLoadKeyFromDisk(l.pkiDir, l.caBaseName) if err != nil { klog.Warningf("assuming external key for %s: %v", l.uxName, err) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 05 10:17:14 UTC 2023 - 19.4K bytes - Viewed (0) -
pkg/volume/util/volumepathhandler/volume_path_handler_linux.go
// detach it from block device. func (v VolumePathHandler) DetachFileDevice(path string) error { loopPath, err := v.GetLoopDevice(path) if err != nil { if err.Error() == ErrDeviceNotFound { klog.Warningf("couldn't find loopback device which takes file descriptor lock. Skip detaching device. device path: %q", path) } else { return fmt.Errorf("GetLoopDevice failed for path %s: %v", path, err) } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/watch_tracker.go
func getIndexValue(r *http.Request, field string) string { opts := metainternalversion.ListOptions{} if err := scheme.ParameterCodec.DecodeParameters(r.URL.Query(), metav1.SchemeGroupVersion, &opts); err != nil { klog.Warningf("Couldn't parse list options for %v: %v", r.URL.Query(), err) return unsetValue } if opts.FieldSelector == nil { return unsetValue } if value, ok := opts.FieldSelector.RequiresExactMatch(field); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 7.4K bytes - Viewed (0)