mirror of https://github.com/k3s-io/k3s
Perfect some logs description
Signed-off-by: PingWang <wang.ping5@zte.com.cn>pull/564/head
parent
d257ee9bfd
commit
a9154b1a91
|
@ -302,10 +302,10 @@ func NewConfigFactory(args *ConfigFactoryArgs) Configurator {
|
|||
if pod, ok := t.Obj.(*v1.Pod); ok {
|
||||
return assignedPod(pod)
|
||||
}
|
||||
runtime.HandleError(fmt.Errorf("unable to convert object %T to *v1.Pod in %T", obj, c))
|
||||
runtime.HandleError(fmt.Errorf("unable to convert object %T to *v1.Pod for filtering scheduledPod in %T", obj, c))
|
||||
return false
|
||||
default:
|
||||
runtime.HandleError(fmt.Errorf("unable to handle object in %T: %T", c, obj))
|
||||
runtime.HandleError(fmt.Errorf("unable to handle object for filtering scheduledPod in %T: %T", c, obj))
|
||||
return false
|
||||
}
|
||||
},
|
||||
|
@ -327,10 +327,10 @@ func NewConfigFactory(args *ConfigFactoryArgs) Configurator {
|
|||
if pod, ok := t.Obj.(*v1.Pod); ok {
|
||||
return !assignedPod(pod) && responsibleForPod(pod, args.SchedulerName)
|
||||
}
|
||||
runtime.HandleError(fmt.Errorf("unable to convert object %T to *v1.Pod in %T", obj, c))
|
||||
runtime.HandleError(fmt.Errorf("unable to convert object %T to *v1.Pod for filtering unscheduledPod in %T", obj, c))
|
||||
return false
|
||||
default:
|
||||
runtime.HandleError(fmt.Errorf("unable to handle object in %T: %T", c, obj))
|
||||
runtime.HandleError(fmt.Errorf("unable to handle object for filtering unscheduledPod in %T: %T", c, obj))
|
||||
return false
|
||||
}
|
||||
},
|
||||
|
@ -467,7 +467,7 @@ func (c *configFactory) onPvAdd(obj interface{}) {
|
|||
// Pods created when there are no PVs available will be stuck in
|
||||
// unschedulable queue. But unbound PVs created for static provisioning and
|
||||
// delay binding storage class are skipped in PV controller dynamic
|
||||
// provisiong and binding process, will not trigger events to schedule pod
|
||||
// provisioning and binding process, will not trigger events to schedule pod
|
||||
// again. So we need to move pods to active queue on PV add for this
|
||||
// scenario.
|
||||
c.podQueue.MoveAllToActiveQueue()
|
||||
|
@ -500,7 +500,7 @@ func (c *configFactory) onPvcUpdate(old, new interface{}) {
|
|||
func (c *configFactory) onStorageClassAdd(obj interface{}) {
|
||||
sc, ok := obj.(*storagev1.StorageClass)
|
||||
if !ok {
|
||||
klog.Errorf("cannot convert to *storagev1.StorageClass: %v", obj)
|
||||
klog.Errorf("cannot convert to *storagev1.StorageClass for storageClassAdd: %v", obj)
|
||||
return
|
||||
}
|
||||
|
||||
|
@ -543,7 +543,7 @@ func (c *configFactory) GetClient() clientset.Interface {
|
|||
return c.client
|
||||
}
|
||||
|
||||
// GetScheduledPodListerIndexer provides a pod lister, mostly internal use, but may also be called by mock-tests.
|
||||
// GetScheduledPodLister provides a pod lister, mostly internal use, but may also be called by mock-tests.
|
||||
func (c *configFactory) GetScheduledPodLister() corelisters.PodLister {
|
||||
return c.scheduledPodLister
|
||||
}
|
||||
|
@ -631,7 +631,7 @@ func (c *configFactory) deletePodFromCache(obj interface{}) {
|
|||
var ok bool
|
||||
pod, ok = t.Obj.(*v1.Pod)
|
||||
if !ok {
|
||||
klog.Errorf("cannot convert to *v1.Pod: %v", t.Obj)
|
||||
klog.Errorf("cannot convert DeletedFinalStateUnknown obj to *v1.Pod: %v", t.Obj)
|
||||
return
|
||||
}
|
||||
default:
|
||||
|
@ -742,7 +742,7 @@ func (c *configFactory) deleteNodeFromCache(obj interface{}) {
|
|||
var ok bool
|
||||
node, ok = t.Obj.(*v1.Node)
|
||||
if !ok {
|
||||
klog.Errorf("cannot convert to *v1.Node: %v", t.Obj)
|
||||
klog.Errorf("cannot convert DeletedFinalStateUnknown obj to *v1.Node: %v", t.Obj)
|
||||
return
|
||||
}
|
||||
default:
|
||||
|
|
Loading…
Reference in New Issue