- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,290 for Warningf (0.16 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
func (c *connection) newSpdyStream(stream *spdystream.Stream) { replySent := make(chan struct{}) err := c.newStreamHandler(stream, replySent) rejectStream := (err != nil) if rejectStream { klog.Warningf("Stream rejected: %v", err) stream.Reset() return } c.registerStream(stream) stream.SendReply(http.Header{}, rejectStream) close(replySent) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K 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/volume/flexvolume/driver-call.go
return nil, execErr } if isCmdNotSupportedErr(err) { dc.plugin.unsupported(dc.Command) } else { klog.Warningf("FlexVolume: driver call failed: executable: %s, args: %s, error: %s, output: %q", execPath, dc.args, execErr.Error(), output) } return nil, err } status, err := handleCmdResponse(dc.Command, output)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 25 02:39:55 UTC 2021 - 7.5K 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) -
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) -
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) -
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) -
staging/src/k8s.io/apiserver/pkg/server/options/authorization.go
// use this path. If it is optional, ignore errors. clientConfig, err = rest.InClusterConfig() if err != nil && s.RemoteKubeConfigFileOptional { if err != rest.ErrNotInCluster { klog.Warningf("failed to read in-cluster kubeconfig for delegated authorization: %v", err) } return nil, nil } } if err != nil { return nil, fmt.Errorf("failed to get delegated authorization kubeconfig: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 9.3K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication.go
if o.TokenSuccessCacheTTL > 0 && o.WebHook.CacheTTL < o.TokenSuccessCacheTTL { klog.Warningf("the webhook cache ttl of %s is shorter than the overall cache ttl of %s for successful token authentication attempts.", o.WebHook.CacheTTL, o.TokenSuccessCacheTTL) } if o.TokenFailureCacheTTL > 0 && o.WebHook.CacheTTL < o.TokenFailureCacheTTL {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 22:40:22 UTC 2024 - 32.4K bytes - Viewed (0)