ProblemEnvironmentをリソースを元にschedulerする #46
Conversation
motacapla
changed the title
| MemoryUsedPercent: strconv.FormatFloat(virtualMemory.UsedPercent, 'f', -1, 64), | ||
| CPUUsedPercent: strconv.FormatFloat(cpuUsedPercents[0], 'f', -1, 64), |
There was a problem hiding this comment.
|
まだバグってて動いてないのでWIP戻します |
motacapla
changed the title
| MemoryUsedPercent string `json:"memoryUsedPercent"` | ||
| CPUUsedPercent string `json:"cpuUsedPercent"` |
There was a problem hiding this comment.
stringじゃなくてfloatでもつのがいいかなと思います！
There was a problem hiding this comment.
ここfloatだとコンパイルが通らなかったので、なくなくstringにしてました
後でもう一度試してみます！
warningですね
/home/motacapla/netcon-problem-management-subsystem/api/v1alpha1/worker_types.go:31:20: found float, the usage of which is highly discouraged, as support for them varies across languages. Please consider serializing your float as string instead. If you are really sure you want to use them, re-run with crd:allowDangerousTypes=true
There was a problem hiding this comment.
調べてたら似たような議論が出てきましたね。
kubernetes-sigs/controller-tools#245
ななめ読みする感じだと、floatは環境によって精度が変わったりするからintの方がいいよって感じですかね
方針はお任せするので、stringでもintでもめう氏が良さそうな方でお願いします！
|
|
||
| workerLength := len(workers.Items) | ||
| if workerLength < 2 { | ||
| // at least 1 worker must exist |
There was a problem hiding this comment.
基本的にはこの仮定が成り立つと思いますが、nil pointer dereferenceでクラッシュされるのは困るので、electWorkerから(string, error)を返すようにするか、workerLength == 0の時は空文字列を返すようにして、electWorkerの呼び出し元で適切にエラーハンドリングしてくれる方が嬉しいです！
| type WorkerResource struct { | ||
| Name string | ||
| CPUUsedPercent float64 | ||
| MemoryUsedPercent float64 | ||
| SumOfResourcesUsedPercent float64 | ||
| } | ||
| arr := make([]WorkerResource, 0, workerLength) | ||
| for i := 0; i < workerLength; i++ { | ||
| cpuUsedPct, err := strconv.ParseFloat(workers.Items[i].Status.WorkerInfo.CPUUsedPercent, 64) | ||
| if err != nil { | ||
| log.Error(err, "failed to parse CPUUsedPercent for worker election") | ||
| cpuUsedPct = MAX_USED_PERCENT | ||
| } | ||
| memoryUsedPercent, err := strconv.ParseFloat(workers.Items[i].Status.WorkerInfo.MemoryUsedPercent, 64) | ||
| if err != nil { | ||
| log.Error(err, "failed to parse CPUUsedPercent for worker election") | ||
| memoryUsedPercent = MAX_USED_PERCENT | ||
| } | ||
| sumOfResourcesUsedPercent := cpuUsedPct + memoryUsedPercent | ||
|
|
||
| arr = append(arr, WorkerResource{workers.Items[i].Name, cpuUsedPct, memoryUsedPercent, sumOfResourcesUsedPercent}) | ||
| } | ||
| sort.Slice(workers, func(i, j int) bool { | ||
| return arr[i].SumOfResourcesUsedPercent < arr[j].SumOfResourcesUsedPercent | ||
| }) | ||
| return arr[0].Name | ||
| } |
motacapla
changed the title
| message := "failed to elect worker for scheduling" | ||
| log.Info(message) |
There was a problem hiding this comment.
エラー時は特に何も更新せずに終えようと思ってましたが、この方針で良いですか?
There was a problem hiding this comment.
Scheduledっていうstatusがあったような気がする？ので、それをFalseに更新して、reasonに「workerが無かったよ」的なコメントを入れておけばいい気がします！（そのまま更新しないで抜けてもしばらくするとresync期間後に再Reconcileが走るはずなのでそれで問題ないと思います！）
There was a problem hiding this comment.
Issue切って別のPRで回収して全然大丈夫です！
There was a problem hiding this comment.
そのまま更新しないで抜けてもしばらくするとresync期間後に再Reconcileが走るはずなのでそれで問題ないと思います！
こっちを想定してました、下記対応のほうが丁寧なので、あとで直してみますね
Scheduledっていうstatusがあったような気がする？ので、それをFalseに更新して、reasonに「workerが無かったよ」的なコメントを入れておけばいい気がします！
| message := "failed to elect worker for scheduling" | ||
| log.Info(message) |
There was a problem hiding this comment.
Scheduledっていうstatusがあったような気がする？ので、それをFalseに更新して、reasonに「workerが無かったよ」的なコメントを入れておけばいい気がします！（そのまま更新しないで抜けてもしばらくするとresync期間後に再Reconcileが走るはずなのでそれで問題ないと思います！）
| // TODO: statusの Scheduled = Falseに更新する | ||
| // 更新せずとも、再reconcileが走るので問題はないはず |
#42
互いの値には相関があるので、CPU/メモリ使用率の合計値の昇順に選ぶようにした