- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,731 for Dlog (0.04 sec)
-
pkg/scheduler/internal/cache/node_tree.go
// is added to the array of nodes in that zone. func (nt *nodeTree) addNode(logger klog.Logger, n *v1.Node) { zone := utilnode.GetZoneKey(n) if na, ok := nt.tree[zone]; ok { for _, nodeName := range na { if nodeName == n.Name { logger.Info("Did not add to the NodeTree because it already exists", "node", klog.KObj(n)) return } } nt.tree[zone] = append(na, n.Name) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 4.5K bytes - Viewed (0) -
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) -
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) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
} if !suitable { return statusUnschedulable(logger, "resourceclaim cannot be allocated for the node (unsuitable)", "pod", klog.KObj(pod), "node", klog.KObj(node), "resourceclaim", klog.KObj(claim)) } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
} <-ctx.Done() } func (dc *DeploymentController) addDeployment(logger klog.Logger, obj interface{}) { d := obj.(*apps.Deployment) logger.V(4).Info("Adding deployment", "deployment", klog.KObj(d)) dc.enqueueDeployment(d) } func (dc *DeploymentController) updateDeployment(logger klog.Logger, old, cur interface{}) { oldD := old.(*apps.Deployment) curD := cur.(*apps.Deployment)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_checkpoint.go
err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err) } } // Delete deletes corresponding Blocks from ContainerMemoryAssignments func (sc *stateCheckpoint) Delete(podUID string, containerName string) { sc.Lock() defer sc.Unlock() sc.cache.Delete(podUID, containerName) err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 5.3K bytes - Viewed (0) -
pkg/scheduler/internal/cache/fake/fake_cache.go
} // AssumePod is a fake method for testing. func (c *Cache) AssumePod(logger klog.Logger, pod *v1.Pod) error { c.AssumeFunc(pod) return nil } // FinishBinding is a fake method for testing. func (c *Cache) FinishBinding(logger klog.Logger, pod *v1.Pod) error { return nil } // ForgetPod is a fake method for testing. func (c *Cache) ForgetPod(logger klog.Logger, pod *v1.Pod) error { c.ForgetFunc(pod) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 2.8K bytes - Viewed (0) -
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/kubelet/cm/devicemanager/plugin/v1beta1/server.go
} dir, name := filepath.Split(socketPath) klog.V(2).InfoS("Creating device plugin registration server", "version", api.Version, "socket", socketPath) s := &server{ socketName: name, socketDir: dir, rhandler: rh, chandler: ch, clients: make(map[string]Client), } return s, nil } func (s *server) Start() error { klog.V(2).InfoS("Starting device plugin registration server")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
return true } func (c *Controller) processPV(ctx context.Context, pvName string) error { logger := klog.FromContext(ctx) logger.V(4).Info("Processing PV", "PV", klog.KRef("", pvName)) startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PV", "PV", klog.KRef("", pvName), "cost", time.Since(startTime)) }() pv, err := c.pvLister.Get(pvName) if apierrors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0)