- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,117 for Warningf (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/create.go
addStrictDecodingWarnings(req.Context(), strictError.Errors()) case isStrictError && validationDirective == metav1.FieldValidationIgnore: klog.Warningf("unexpected strict error when field validation is set to ignore") fallthrough default: err = transformDecodeError(scope.Typer, err, original, gvk, body) scope.err(err, w, req) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 10.1K bytes - Viewed (0) -
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) -
pkg/controlplane/reconcilers/lease.go
e.Subsets = endpointsv1.RepackSubsets(e.Subsets) } if len(e.Subsets) != 0 && !portsCorrect { // Reset ports. e.Subsets[0].Ports = endpointPorts } klog.Warningf("Resetting endpoints for master service %q to %v", serviceName, masterIPs) if shouldCreate { if _, err = r.epAdapter.Create(corev1.NamespaceDefault, e); errors.IsAlreadyExists(err) { err = nil } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
fcIfc utilflowcontrol.Interface, workEstimator flowcontrolrequest.WorkEstimatorFunc, defaultRequestWaitLimit time.Duration, ) http.Handler { if fcIfc == nil { klog.Warningf("priority and fairness support not found, skipping") return handler } initAPFOnce.Do(func() { initMaxInFlight(0, 0) // Fetching these gauges is delayed until after their underlying metric has been registered
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
pkg/volume/portworx/portworx_util.go
locator.VolumeLabels[pvcNamespaceLabel] = p.options.PVC.Namespace for k, v := range p.options.PVC.Annotations { if _, present := spec.VolumeLabels[k]; present { klog.Warningf("not saving annotation: %s=%s in spec labels due to an existing key", k, v) continue } spec.VolumeLabels[k] = v } volumeID, err := driver.Create(locator, source, spec) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object.go
// to log the stacktrace to allow debugging if that will happen. // OTOH, we don't want to spam logs with it. // So we try to log it at most once per second. if shouldLogCacheInvalidation(time.Now()) { klog.Warningf("Unexpected cache invalidation for %#v\n%s", o.object, string(debug.Stack())) } o.serializations.Store(make(serializationsCache)) } // The following functions implement metav1.Object interface:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 18:03:48 UTC 2023 - 12.6K bytes - Viewed (0) -
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) -
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) -
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) -
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)