Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 166 for slog (0.04 sec)

  1. cmd/kubeadm/app/cmd/phases/reset/cleanupnode.go

    	}
    	certsDir := r.CertificatesDir()
    
    	// Try to stop the kubelet service
    	klog.V(1).Infoln("[reset] Getting init system")
    	initSystem, err := initsystem.GetInitSystem()
    	if err != nil {
    		klog.Warningln("[reset] The kubelet service could not be stopped by kubeadm. Unable to detect a supported init system!")
    		klog.Warningln("[reset] Please ensure kubelet is stopped manually")
    	} else {
    		if !r.DryRun() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. plugin/pkg/auth/authorizer/node/graph_populator.go

    	pod, ok := obj.(*corev1.Pod)
    	if !ok {
    		klog.Infof("unexpected type %T", obj)
    		return
    	}
    	if len(pod.Spec.NodeName) == 0 {
    		klog.V(5).Infof("deletePod %s/%s, no node", pod.Namespace, pod.Name)
    		return
    	}
    
    	klog.V(4).Infof("deletePod %s/%s for node %s", pod.Namespace, pod.Name, pod.Spec.NodeName)
    	startTime := time.Now()
    	g.graph.DeletePod(pod.Name, pod.Namespace)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. staging/publishing/import-restrictions.yaml

      - k8s.io/apimachinery
      - k8s.io/kube-openapi
      - k8s.io/utils/clock
      - k8s.io/utils/net
      - k8s.io/utils/strings
      - k8s.io/klog
      - k8s.io/utils/ptr
    
    - baseImportPath: "./staging/src/k8s.io/api"
      allowedImports:
      - k8s.io/api
      - k8s.io/apimachinery
      - k8s.io/klog
    
    - baseImportPath: "./staging/src/k8s.io/code-generator"
      ignoredSubTrees:
      - "./staging/src/k8s.io/code-generator/examples"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 13:13:22 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. src/sync/poolqueue.go

    		// reading the value to take back ownership of this
    		// slot.
    		head--
    		ptrs2 := d.pack(head, tail)
    		if d.headTail.CompareAndSwap(ptrs, ptrs2) {
    			// We successfully took back slot.
    			slot = &d.vals[head&uint32(len(d.vals)-1)]
    			break
    		}
    	}
    
    	val := *(*any)(unsafe.Pointer(slot))
    	if val == dequeueNil(nil) {
    		val = nil
    	}
    	// Zero the slot. Unlike popTail, this isn't racing with
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 18:12:29 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_stack_test.go

    		if err := fs.Set(flag, value); err != nil {
    			fmt.Printf("Unexpected error configuring klog: %v", err)
    			return
    		}
    	}
    	var buffer bytes.Buffer
    	klog.SetOutput(&buffer)
    
    	logger := klog.Background()
    	logger = klog.LoggerWithValues(logger, "request", 42)
    	ctx := klog.NewContext(context.Background(), logger)
    
    	// The line number of the next call must be at line 60. Here are some
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/util/util.go

    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    	if sandboxStatus.State != runtimeapi.PodSandboxState_SANDBOX_READY {
    		klog.V(2).InfoS("No ready sandbox for pod can be found. Need to start a new one", "pod", klog.KObj(pod))
    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    
    	// Needs to create a new sandbox when network namespace changed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. pkg/kubelet/lifecycle/handlers.go

    			klog.V(1).ErrorS(err, "Sleep lifecycle hook for Container in Pod failed", "sleepSeconds", handler.Sleep.Seconds, "containerName", container.Name, "pod", klog.KObj(pod))
    		}
    		return msg, err
    	default:
    		err := fmt.Errorf("invalid handler: %v", handler)
    		msg := fmt.Sprintf("Cannot run handler: %v", err)
    		klog.ErrorS(err, "Cannot run handler")
    		return msg, err
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 11:40:52 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. pkg/kubelet/volumemanager/reconciler/reconstruct.go

    			if err != nil {
    				klog.ErrorS(err, "Could not add pod to volume information to actual state of world", "pod", klog.KObj(volume.pod))
    				continue
    			}
    			seLinuxMountContext = volume.seLinuxMountContext
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. pkg/kubelet/util/swap/swap_util.go

    			// https://github.com/torvalds/linux/blob/v6.8/mm/shmem.c#L4004-L4011
    			// https://github.com/kubernetes/kubernetes/issues/125137
    			klog.InfoS("Running under a user namespace - tmpfs noswap is not supported")
    			return false
    		}
    
    		kernelVersion, err := utilkernel.GetVersion()
    		if err != nil {
    			klog.ErrorS(err, "cannot determine kernel version, unable to determine is tmpfs noswap is supported")
    			return false
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 10:07:06 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. pkg/kubelet/prober/prober.go

    		if err != nil {
    			klog.V(1).ErrorS(err, "Probe errored", "probeType", probeType, "pod", klog.KObj(pod), "podUID", pod.UID, "containerName", container.Name)
    			pb.recordContainerEvent(pod, &container, v1.EventTypeWarning, events.ContainerUnhealthy, "%s probe errored: %v", probeType, err)
    		} else { // result != probe.Success
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:50:13 UTC 2024
    - 8.7K bytes
    - Viewed (0)
Back to top