- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 544 for Dlog (0.05 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_manager.go
} else { klog.V(4).InfoS("SyncPod received new pod, will create a sandbox for it", "pod", klog.KObj(pod)) } } // Step 2: Kill the pod if the sandbox has changed. if podContainerChanges.KillPod { if podContainerChanges.CreateSandbox { klog.V(4).InfoS("Stopping PodSandbox for pod, will start new one", "pod", klog.KObj(pod)) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K 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/volume/downwardapi/downwardapi.go
klog.V(3).Infof("Setting up a downwardAPI volume %v for pod %v/%v at %v", b.volName, b.pod.Namespace, b.pod.Name, dir) // Wrap EmptyDir. Here we rely on the idempotency of the wrapped plugin to avoid repeatedly mounting wrapped, err := b.plugin.host.NewWrapperMounter(b.volName, wrappedVolumeSpec(), b.pod, *b.opts) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
} node, err := kl.initialNode(context.TODO()) if err != nil { klog.ErrorS(err, "Unable to construct v1.Node object for kubelet") continue } klog.InfoS("Attempting to register node", "node", klog.KObj(node)) registered := kl.tryRegisterWithAPIServer(node) if registered { klog.InfoS("Successfully registered node", "node", klog.KObj(node)) kl.registrationCompleted = true return } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
cmd/kube-controller-manager/app/plugins_providers.go
import ( "k8s.io/component-base/featuregate" "k8s.io/csi-translation-lib/plugins" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csimigration" "k8s.io/kubernetes/pkg/volume/portworx" ) type probeFn func() []volume.VolumePlugin
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
return false, true, nil } logger.V(5).Info("PersistentVolume and node matches for pod", "PV", klog.KRef("", pvName), "node", klog.KObj(node), "pod", klog.KObj(pod)) } logger.V(4).Info("All bound volumes for pod match with node", "pod", klog.KObj(pod), "node", klog.KObj(node)) return true, true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { klog.Errorf("Couldn't get object from tombstone %#v", obj) return } castObj, ok = tombstone.Obj.(*apiextensionsv1.CustomResourceDefinition) if !ok { klog.Errorf("Tombstone contained object that is not expected %#v", obj) return } } klog.V(4).Infof("Deleting customresourcedefinition %q", castObj.Name) c.enqueue(castObj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
} <-ctx.Done() } func (tc *Controller) addJob(logger klog.Logger, obj interface{}) { job := obj.(*batch.Job) logger.V(4).Info("Adding job", "job", klog.KObj(job)) if job.DeletionTimestamp == nil && needsCleanup(job) { tc.enqueue(logger, job) } } func (tc *Controller) updateJob(logger klog.Logger, old, cur interface{}) { job := cur.(*batch.Job)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
logger.V(3).Info("Could not sync claim", "PVC", klog.KObj(claim), "err", err) } else { logger.Error(err, "Could not sync volume", "PVC", klog.KObj(claim)) } } } // Unit test [5-5] [5-6] [5-7] // deleteClaim runs in worker thread and handles "claim deleted" event. func (ctrl *PersistentVolumeController) deleteClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) { logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
cmd/import-boss/main.go
"github.com/spf13/pflag" "golang.org/x/tools/go/packages" "k8s.io/klog/v2" "sigs.k8s.io/yaml" ) const ( rulesFileName = ".import-restrictions" goModFile = "go.mod" ) func main() { klog.InitFlags(nil) pflag.CommandLine.AddGoFlagSet(flag.CommandLine) pflag.Parse() pkgs, err := loadPkgs(pflag.Args()...) if err != nil { klog.Errorf("failed to load packages: %v", err) } pkgs = massage(pkgs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 12:36:49 UTC 2024 - 14.7K bytes - Viewed (0)