- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,315 for _obj (0.22 sec)
-
pkg/scheduler/schedule_one.go
// When contextualized logging hits GA // https://github.com/kubernetes/kubernetes/issues/111672 logger = klog.LoggerWithValues(logger, "pod", klog.KObj(pod)) ctx = klog.NewContext(ctx, logger) logger.V(4).Info("About to try and schedule pod", "pod", klog.KObj(pod)) fwk, err := sched.frameworkForPod(pod) if err != nil { // This shouldn't happen, because we only accept for scheduling the pods
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
AddFunc: func(obj interface{}) { pod := obj.(*v1.Pod) nc.podUpdated(nil, pod) }, UpdateFunc: func(prev, obj interface{}) { prevPod := prev.(*v1.Pod) newPod := obj.(*v1.Pod) nc.podUpdated(prevPod, newPod) }, DeleteFunc: func(obj interface{}) { pod, isPod := obj.(*v1.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
klog.V(3).InfoS("computePodActions got for pod", "podActions", podContainerChanges, "pod", klog.KObj(pod)) if podContainerChanges.CreateSandbox { ref, err := ref.GetReference(legacyscheme.Scheme, pod) if err != nil { klog.ErrorS(err, "Couldn't make a ref to pod", "pod", klog.KObj(pod)) } if podContainerChanges.SandboxID != "" {
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/kubelet/lifecycle/handlers.go
klog.V(1).ErrorS(err, "Exec lifecycle hook for Container in Pod failed", "execCommand", handler.Exec.Command, "containerName", container.Name, "pod", klog.KObj(pod), "message", string(output)) } return msg, err case handler.HTTPGet != nil: err := hr.runHTTPHandler(ctx, pod, container, handler, hr.eventRecorder) var msg string if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 11:40:52 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
} // pvAddedUpdated reacts to pv added/updated events func (c *Controller) pvAddedUpdated(logger klog.Logger, obj interface{}) { pv, ok := obj.(*v1.PersistentVolume) if !ok { utilruntime.HandleError(fmt.Errorf("PV informer returned non-PV object: %#v", obj)) return } logger.V(4).Info("Got event on PV", "PV", klog.KObj(pv))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
return false } core := minio.Core{Client: sclnt} sobj, _, _, err := core.GetObject(context.Background(), sourceBucket, srcCtnt.Key, opts) if err != nil { fmt.Printf("unreadable on source: %s (%s)\n", srcCtnt.Key, err) return false } tobj, _, _, err := core.GetObject(context.Background(), targetBucket, tgtCtnt.Key, opts) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 22 15:12:47 UTC 2022 - 8.4K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
if err != nil { utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err)) return } e.queue.Add(key) } // onServiceDelete removes the Service Selector from the cache and queues the Service for processing. func (e *Controller) onServiceDelete(obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
) return ec, nil } func (ec *Controller) enqueuePod(logger klog.Logger, obj interface{}, deleted bool) { if d, ok := obj.(cache.DeletedFinalStateUnknown); ok { obj = d.Obj } pod, ok := obj.(*v1.Pod) if !ok { // Not a pod?! logger.Error(nil, "enqueuePod called for unexpected object", "type", fmt.Sprintf("%T", obj)) return } if len(pod.Spec.ResourceClaims) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
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) logger.V(4).Info("Updating job", "job", klog.KObj(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.go
return newClaim, err } logger.V(4).Info("Updating PersistentVolumeClaim: bound to volume", "PVC", klog.KObj(claim), "volumeName", volume.Name) return newClaim, nil } logger.V(4).Info("Updating PersistentVolumeClaim: already bound to volume", "PVC", klog.KObj(claim), "volumeName", volume.Name) return claim, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0)