- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,118 for Warningf (0.23 sec)
-
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) -
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) -
staging/src/k8s.io/apiserver/pkg/authentication/serviceaccount/util.go
if _, err = coreClient.Namespaces().Create(context.TODO(), &v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: namespace}}, metav1.CreateOptions{}); err != nil && !apierrors.IsAlreadyExists(err) { klog.Warningf("create non-exist namespace %s failed:%v", namespace, err) } } // Create the service account
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 8.1K bytes - Viewed (0) -
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) -
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) -
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) -
cmd/kubeadm/app/cmd/reset.go
klog.V(1).Infof("[reset] Loaded client set from kubeconfig file: %s", opts.kubeconfigPath) initCfg, err = configutil.FetchInitConfigurationFromCluster(client, nil, "reset", false, false) if err != nil { klog.Warningf("[reset] Unable to fetch the kubeadm-config ConfigMap from cluster: %v", err) } } else { klog.V(1).Infof("[reset] Could not obtain a client set from the kubeconfig file: %s", opts.kubeconfigPath) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 12:26:58 UTC 2023 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.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 - 11.5K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/join.go
if len(args) == 0 { opt.externalcfg.Discovery.BootstrapToken = nil } else { if len(opt.cfgPath) == 0 && len(args) > 1 { klog.Warningf("[preflight] WARNING: More than one API server endpoint supplied on command line %v. Using the first one.", args) } opt.externalcfg.Discovery.BootstrapToken.APIServerEndpoint = args[0] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 25.2K bytes - Viewed (0)