我們已經(jīng)創(chuàng)建了自己的自定義資源，也就是 CRD，我們需要添加對(duì)滾動(dòng)更新的支持，因?yàn)?K8s 支持它用于部署等我們想重用這樣的邏輯，是否有任何我們可以使用（可能部分）的庫支持嗎？或者也許學(xué)習(xí)并遵循邏輯，因?yàn)槲覀儾幌胫匦掳l(fā)明輪子？任何參考/lib 都會(huì)有所幫助。我在這里很難找到這個(gè)。
1 回答
慕萊塢森
TA貢獻(xiàn)1810條經(jīng)驗(yàn) 獲得超4個(gè)贊
發(fā)布社區(qū) wiki 答案以總結(jié)問題。
Clark McCauley很好地建議：
您可能正在尋找此處包含的邏輯。
這是對(duì) k8s 源代碼的引用，因此您可能找不到更好的想法來源:)
// rolloutRolling implements the logic for rolling a new replica set.
func (dc *DeploymentController) rolloutRolling(ctx context.Context, d *apps.Deployment, rsList []*apps.ReplicaSet) error {
newRS, oldRSs, err := dc.getAllReplicaSetsAndSyncRevision(ctx, d, rsList, true)
if err != nil {
return err
}
allRSs := append(oldRSs, newRS)
// Scale up, if we can.
scaledUp, err := dc.reconcileNewReplicaSet(ctx, allRSs, newRS, d)
if err != nil {
return err
}
if scaledUp {
// Update DeploymentStatus
return dc.syncRolloutStatus(ctx, allRSs, newRS, d)
}
// Scale down, if we can.
scaledDown, err := dc.reconcileOldReplicaSets(ctx, allRSs, controller.FilterActiveReplicaSets(oldRSs), newRS, d)
if err != nil {
return err
}
if scaledDown {
// Update DeploymentStatus
return dc.syncRolloutStatus(ctx, allRSs, newRS, d)
}
if deploymentutil.DeploymentComplete(d, &d.Status) {
if err := dc.cleanupDeployment(ctx, oldRSs, d); err != nil {
return err
}
}
// Sync deployment status
return dc.syncRolloutStatus(ctx, allRSs, newRS, d)
}
- 1 回答
- 0 關(guān)注
- 116 瀏覽
添加回答
舉報(bào)
0/150
提交
取消