mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-28 05:57:25 +00:00
Merge pull request #31528 from mwielgus/loglevelrs
Automatic merge from submit-queue Increase log level for debug infos in Federated ReplicaSet controller cc: @quinton-hoole @wojtek-t
This commit is contained in:
commit
65c31dde62
@ -332,7 +332,7 @@ func (frsc *ReplicaSetController) schedule(frs *extensionsv1.ReplicaSet, cluster
|
|||||||
for clusterName, replicas := range overflow {
|
for clusterName, replicas := range overflow {
|
||||||
result[clusterName] += replicas
|
result[clusterName] += replicas
|
||||||
}
|
}
|
||||||
if glog.V(2) {
|
if glog.V(4) {
|
||||||
buf := bytes.NewBufferString(fmt.Sprintf("Schedule - ReplicaSet: %s/%s\n", frs.Namespace, frs.Name))
|
buf := bytes.NewBufferString(fmt.Sprintf("Schedule - ReplicaSet: %s/%s\n", frs.Namespace, frs.Name))
|
||||||
sort.Strings(clusterNames)
|
sort.Strings(clusterNames)
|
||||||
for _, clusterName := range clusterNames {
|
for _, clusterName := range clusterNames {
|
||||||
@ -347,7 +347,7 @@ func (frsc *ReplicaSetController) schedule(frs *extensionsv1.ReplicaSet, cluster
|
|||||||
}
|
}
|
||||||
fmt.Fprintf(buf, "\n")
|
fmt.Fprintf(buf, "\n")
|
||||||
}
|
}
|
||||||
glog.V(2).Infof(buf.String())
|
glog.V(4).Infof(buf.String())
|
||||||
}
|
}
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
@ -358,9 +358,9 @@ func (frsc *ReplicaSetController) reconcileReplicaSet(key string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
glog.V(1).Infof("Start reconcile replicaset %q", key)
|
glog.V(4).Infof("Start reconcile replicaset %q", key)
|
||||||
startTime := time.Now()
|
startTime := time.Now()
|
||||||
defer glog.V(1).Infof("Finished reconcile replicaset %q (%v)", key, time.Now().Sub(startTime))
|
defer glog.V(4).Infof("Finished reconcile replicaset %q (%v)", key, time.Now().Sub(startTime))
|
||||||
|
|
||||||
obj, exists, err := frsc.replicaSetStore.Store.GetByKey(key)
|
obj, exists, err := frsc.replicaSetStore.Store.GetByKey(key)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -402,7 +402,7 @@ func (frsc *ReplicaSetController) reconcileReplicaSet(key string) error {
|
|||||||
|
|
||||||
scheduleResult := frsc.schedule(frs, clusters, current, estimatedCapacity)
|
scheduleResult := frsc.schedule(frs, clusters, current, estimatedCapacity)
|
||||||
|
|
||||||
glog.V(1).Infof("Start syncing local replicaset %s: %v", key, scheduleResult)
|
glog.V(4).Infof("Start syncing local replicaset %s: %v", key, scheduleResult)
|
||||||
|
|
||||||
fedStatus := extensionsv1.ReplicaSetStatus{ObservedGeneration: frs.Generation}
|
fedStatus := extensionsv1.ReplicaSetStatus{ObservedGeneration: frs.Generation}
|
||||||
for clusterName, replicas := range scheduleResult {
|
for clusterName, replicas := range scheduleResult {
|
||||||
|
Loading…
Reference in New Issue
Block a user