- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 106 for InfoS (0.09 sec)
-
pkg/kubelet/cm/container_manager_linux.go
} klog.InfoS("Container manager verified user specified cgroup-root exists", "cgroupRoot", cgroupRoot) // Include the top level cgroup for enforcing node allocatable into cgroup-root. // This way, all sub modules can avoid having to understand the concept of node allocatable. cgroupRoot = NewCgroupName(cgroupRoot, defaultNodeAllocatableCgroupName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
klog.InfoS("Starting CPU manager", "policy", m.policy.Name()) klog.InfoS("Reconciling", "reconcilePeriod", m.reconcilePeriod) m.sourcesReady = sourcesReady m.activePods = activePods m.podStatusProvider = podStatusProvider m.containerRuntime = containerRuntime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (2) -
cmd/erasure.go
infos[i] = di if err != nil { // - Do not consume disks which are not reachable // unformatted or simply not accessible for some reason. infos[i].Error = err.Error() } }() } wg.Wait() var scanningDisks, healingDisks []StorageAPI var scanningInfos, healingInfos []DiskInfo for i, info := range infos {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16K bytes - Viewed (0) -
pkg/proxy/winkernel/hns.go
ready: true, serving: true, terminating: false, } endpointInfos[ep.IpConfigurations[1].IpAddress] = endpointDualstack } klog.V(3).InfoS("Queried endpoints from network", "network", networkName) klog.V(5).InfoS("Queried endpoints details", "network", networkName, "endpointInfos", endpointInfos) return endpointInfos, nil } func (hns hns) getEndpointByID(id string) (*endpointInfo, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 21:21:12 UTC 2023 - 15K bytes - Viewed (0) -
src/cmd/go/internal/fsys/fsys_test.go
dir, want := tc.dir, tc.want infos, err := ReadDir(dir) if err != nil { t.Errorf("ReadDir(%q): %v", dir, err) continue } // Sorted diff of want and infos. for len(infos) > 0 || len(want) > 0 { switch { case len(want) == 0 || len(infos) > 0 && infos[0].Name() < want[0].name: t.Errorf("ReadDir(%q): unexpected entry: %s IsDir=%v Size=%v", dir, infos[0].Name(), infos[0].IsDir(), infos[0].Size())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 18:52:11 UTC 2023 - 29.1K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
} } else { if klogV := klog.V(6); klogV.Enabled() { klogV.InfoS("Evented PLEG: Generated pod status from the received event", "podUID", podID, "podStatus", status) } else { klog.V(4).InfoS("Evented PLEG: Generated pod status from the received event", "podUID", podID) } // Preserve the pod IP across cache updates if the new IP is empty.
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/kubelet/config/config.go
if update.Op == kubetypes.ADD { klog.V(4).InfoS("Adding new pods from source", "source", source, "pods", klog.KObjSlice(update.Pods)) } else if update.Op == kubetypes.DELETE { klog.V(4).InfoS("Gracefully deleting pods from source", "source", source, "pods", klog.KObjSlice(update.Pods)) } else { klog.V(4).InfoS("Updating pods from source", "source", source, "pods", klog.KObjSlice(update.Pods)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
// once https://github.com/kubernetes/kubernetes/issues/63336 is resolved klog.InfoS("Error getting ContainerStatus for containerID", "containerID", containerID, "err", err) } else { status := resp.GetStatus() if status == nil { klog.V(4).InfoS("Container status is nil") continue } if status.State != runtimeapi.ContainerState_CONTAINER_EXITED {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
klog.InfoS("Desired state populator starts to run") wait.PollUntil(dswp.loopSleepDuration, func() (bool, error) { done := sourcesReady.AllReady() dswp.populatorLoop() return done, nil }, stopCh) dswp.hasAddedPodsLock.Lock() if !dswp.hasAddedPods { klog.InfoS("Finished populating initial desired state of world") dswp.hasAddedPods = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/kubelet/prober/worker.go
if !ok { // Either the pod has not been created yet, or it was already deleted. klog.V(3).InfoS("No status for pod", "pod", klog.KObj(w.pod)) return true } // Worker should terminate if pod is terminated. if status.Phase == v1.PodFailed || status.Phase == v1.PodSucceeded { klog.V(3).InfoS("Pod is terminated, exiting probe worker", "pod", klog.KObj(w.pod), "phase", status.Phase) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K bytes - Viewed (0)