- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,290 for Warningf (0.48 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
if err2 != nil { utilruntime.HandleError(err2) } return } else if oldMeta.GetResourceVersion() == newMeta.GetResourceVersion() { if len(oldMeta.GetResourceVersion()) == 0 { klog.Warningf("%v throwing out update with empty RV. this is likely to happen if a test did not supply a resource version on an updated object", c.options.Name) } return } enqueue(newObj, false) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/volume/volume_linux.go
if fsGroup == nil { return nil } timer := time.AfterFunc(30*time.Second, func() { klog.Warningf("Setting volume ownership for %s and fsGroup set. If the volume has a lot of files then setting volume ownership could be slow, see https://github.com/kubernetes/kubernetes/issues/69699", dir) }) defer timer.Stop()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/context.go
ae := &ac.Event if ae.Annotations == nil { ae.Annotations = make(map[string]string) } if v, ok := ae.Annotations[key]; ok && v != value { klog.Warningf("Failed to set annotations[%q] to %q for audit:%q, it has already been set to %q", key, value, ae.AuditID, ae.Annotations[key]) return } ae.Annotations[key] = value }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/volume/flexvolume/probe.go
return nil } // Creates the plugin directory, if it doesn't already exist. func (prober *flexVolumeProber) createPluginDir() error { if _, err := prober.fs.Stat(prober.pluginDir); os.IsNotExist(err) { klog.Warningf("Flexvolume plugin directory at %s does not exist. Recreating.", prober.pluginDir) err := prober.fs.MkdirAll(prober.pluginDir, 0755) if err != nil { return fmt.Errorf("error (re-)creating driver directory: %s", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 9K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/configset.go
configMap, err := apiclient.GetConfigMapWithShortRetry(client, metav1.NamespaceSystem, cmName) if err != nil { if !mustExist && (apierrors.IsNotFound(err) || apierrors.IsForbidden(err)) { klog.Warningf("Warning: No %s config is loaded. Continuing without it: %v", h.GroupVersion, err) return nil, nil } return nil, err } configData, ok := configMap.Data[cmKey] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go
} matcher := h.GetCompiledMatcher(a.filterCompiler) matchResult := matcher.Match(ctx, versionedAttr, nil, a.authorizer) if matchResult.Error != nil { klog.Warningf("Failed evaluating match conditions, failing closed %v: %v", h.GetName(), matchResult.Error) return nil, apierrors.NewForbidden(attr.GetResource().GroupResource(), attr.GetName(), matchResult.Error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux_impl.go
} func isFilesystemOfType(mountpoint string, backingDev string, typeMagic int64) bool { var buf syscall.Statfs_t err := syscall.Statfs(mountpoint, &buf) if err != nil { klog.Warningf("Warning: Unable to statfs %s: %v", mountpoint, err) return false } if int64(buf.Type) != typeMagic { return false } if answer, _ := SupportsQuotas(mountpoint, FSQuotaAccounting); answer { return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 9.1K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
// This path is no executed since 1.17 2a9a9fa, keeping it in case it needs to be revisited if reconcile { if svc, updated := getMasterServiceUpdateIfNeeded(s, servicePorts, serviceType); updated { klog.Warningf("Resetting master service %q to %#v", serviceName, svc) _, err := c.client.CoreV1().Services(metav1.NamespaceDefault).Update(context.TODO(), svc, metav1.UpdateOptions{}) return err } } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/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 - 9.6K bytes - Viewed (0) -
plugin/pkg/admission/imagepolicy/admission.go
a.responseCache.Add(string(cacheKey), review.Status, a.statusTTL(review.Status)) } for k, v := range review.Status.AuditAnnotations { if err := attributes.AddAnnotation(AuditKeyPrefix+k, v); err != nil { klog.Warningf("failed to set admission audit annotation %s to %s: %v", AuditKeyPrefix+k, v, err) } } if !review.Status.Allowed { if len(review.Status.Reason) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 06:05:06 UTC 2023 - 9.8K bytes - Viewed (0)