- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,192 for slog (0.04 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
} if err == nil { if remountingLogStr == "" { klog.V(1).InfoS(volumeToMount.GenerateMsgDetailed("operationExecutor.MountVolume started", remountingLogStr), "pod", klog.KObj(volumeToMount.Pod)) } else { klog.V(5).InfoS(volumeToMount.GenerateMsgDetailed("operationExecutor.MountVolume started", remountingLogStr), "pod", klog.KObj(volumeToMount.Pod)) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/status/fake_status_manager.go
"k8s.io/apimachinery/pkg/types" "k8s.io/klog/v2" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" "k8s.io/kubernetes/pkg/kubelet/status/state" ) type fakeManager struct { state state.State } func (m *fakeManager) Start() { klog.InfoS("Start()") return } func (m *fakeManager) GetPodStatus(uid types.UID) (v1.PodStatus, bool) { klog.InfoS("GetPodStatus()") return v1.PodStatus{}, false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 05:59:34 UTC 2023 - 2.7K bytes - Viewed (0) -
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) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
"pod", klog.KObj(pod), "createdPod", klog.KObj(modifiedPod)) return framework.Queue, nil } logger.V(5).Info("a scheduled pod was created, but it doesn't matches with the pod's topology spread constraints", "pod", klog.KObj(pod), "createdPod", klog.KObj(modifiedPod)) return framework.QueueSkip, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate.go
) func main() { registerFlags(migrateCmd.Flags(), &opts) err := migrateCmd.Execute() if err != nil { klog.Errorf("Failed to execute migratecmd: %s", err) } } // runMigrate starts the migration. func runMigrate() { if err := opts.validateAndDefault(); err != nil { klog.Fatalf("%v", err) } copyBinaries() target := &EtcdVersionPair{ version: MustParseEtcdVersion(opts.targetVersion),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 16 23:10:54 UTC 2020 - 3.8K bytes - Viewed (0) -
pkg/volume/iscsi/disk_manager.go
if err != nil { klog.Errorf("Failed to bind mount: source:%s, target:%s, err:%v", globalPDPath, volPath, err) noMnt, mntErr := b.mounter.IsLikelyNotMountPoint(volPath) if mntErr != nil { klog.Errorf("IsLikelyNotMountPoint check failed: %v", mntErr) return err } if !noMnt { if mntErr = b.mounter.Unmount(volPath); mntErr != nil { klog.Errorf("Failed to unmount: %v", mntErr) return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
klog.V(4).Info(log("mounter created successfully")) return mounter, nil } func (p *csiPlugin) NewUnmounter(specName string, podUID types.UID) (volume.Unmounter, error) { klog.V(4).Infof(log("setting up unmounter for [name=%v, podUID=%v]", specName, podUID)) kvh, ok := p.host.(volume.KubeletVolumeHost) if !ok { return nil, errors.New(log("cast from VolumeHost to KubeletVolumeHost failed"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controlplane/controller/apiserverleasegc/gc_controller.go
gcCheckPeriod: gcCheckPeriod, } } // Run starts one worker. func (c *Controller) Run(stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer klog.Infof("Shutting down apiserver lease garbage collector") klog.Infof("Starting apiserver lease garbage collector") // we have a personal informer that is narrowly scoped, start it. go c.leaseInformer.Run(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 25 03:27:44 UTC 2021 - 4.6K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
//ok default: klog.V(2).Infof("NODE DENY: '%s' %#v", nodeName, attrs) return authorizer.DecisionNoOpinion, "can only read resources of this type", nil } if len(attrs.GetSubresource()) > 0 { klog.V(2).Infof("NODE DENY: '%s' %#v", nodeName, attrs) return authorizer.DecisionNoOpinion, "cannot read subresource", nil } if len(attrs.GetNamespace()) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0) -
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)