- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 655 for Dlog (0.05 sec)
-
src/log/slog/doc.go
a global LevelVar: var programLevel = new(slog.LevelVar) // Info by default Then use the LevelVar to construct a handler, and make it the default: h := slog.NewJSONHandler(os.Stderr, &slog.HandlerOptions{Level: programLevel}) slog.SetDefault(slog.New(h)) Now the program can change its logging level with a single statement: programLevel.Set(slog.LevelDebug) # Groups
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 15 14:35:48 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/volume/util/atomic_writer.go
klog.V(4).Infof("%s: write required for target directory %v", w.logContext, w.targetDir) } } if shouldWrite { // (5) tsDir, err := w.newTimestampDir() if err != nil { klog.V(4).Infof("%s: error creating new ts data directory: %v", w.logContext, err) return err } tsDirName := filepath.Base(tsDir) // (6) if err = w.writePayloadToDir(cleanPayload, tsDir); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
func removeMountDir(plug *csiPlugin, mountPath string) error { klog.V(4).Info(log("removing mount path [%s]", mountPath)) mnt, err := isDirMounted(plug, mountPath) if err != nil { return err } if !mnt { klog.V(4).Info(log("dir not mounted, deleting it [%s]", mountPath)) if err := os.Remove(mountPath); err != nil && !os.IsNotExist(err) { return errors.New(log("failed to remove dir [%s]: %v", mountPath, err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
pkg/volume/portworx/portworx_util.go
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 { klog.Errorf("Error creating Portworx Volume : %v", err) return "", 0, nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.2K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
return true } func (c *Controller) processPVC(ctx context.Context, pvcNamespace, pvcName string) error { logger := klog.FromContext(ctx) logger.V(4).Info("Processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName)) startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName), "duration", time.Since(startTime)) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
for i := 0; i < retries; i++ { if i > 0 { klog.V(1).Infof("[etcd] Waiting %v until next retry\n", retryInterval) time.Sleep(retryInterval) } klog.V(2).Infof("[etcd] attempting to see if all cluster endpoints (%s) are available %d/%d", c.Endpoints, i+1, retries) _, err := c.getClusterStatus() if err != nil { switch err { case context.DeadlineExceeded: klog.V(1).Infof("[etcd] Attempt timed out") default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
} func (gcc *PodGCController) gc(ctx context.Context) { pods, err := gcc.podLister.List(labels.Everything()) if err != nil { klog.FromContext(ctx).Error(err, "Error while listing all pods") return } nodes, err := gcc.nodeLister.List(labels.Everything()) if err != nil { klog.FromContext(ctx).Error(err, "Error while listing all nodes") return } if gcc.terminatedPodThreshold > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices.go
// Updates RunContainerOptions.Envs. for k, v := range resp.Envs { if e, ok := envsMap[k]; ok { klog.V(4).InfoS("Skip existing env", "envKey", k, "envValue", v) if e != v { klog.ErrorS(nil, "Environment variable has conflicting setting", "envKey", k, "expected", v, "got", e) } continue } klog.V(4).InfoS("Add env", "envKey", k, "envValue", v) envsMap[k] = v
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
if err != nil { // nolint:logcheck // Not using the result of klog.V inside the // if branch is okay, we just use it to determine whether the // additional "podStatus" key and its value should be added. if klog.V(6).Enabled() { klog.ErrorS(err, "Evented PLEG: error generating pod status from the received event", "podUID", podID, "podStatus", status) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
return err } switch { case result.Protected && result.Operation != reconciliation.ReconcileNone: klog.Warningf("skipped reconcile-protected clusterrole.%s/%s with missing permissions: %v", rbac.GroupName, clusterRole.Name, result.MissingRules) case result.Operation == reconciliation.ReconcileUpdate: klog.V(2).Infof("updated clusterrole.%s/%s with additional permissions: %v", rbac.GroupName, clusterRole.Name, result.MissingRules)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0)