k8s滚动更新算法

Question

我们已经创建了自己的自定义资源，也就是 CRD，我们需要添加对滚动更新的支持，因为 K8s 支持它用于部署等我们想重用这样的逻辑，是否有任何我们可以使用（可能部分）的库支持吗？或者也许学习并遵循逻辑，因为我们不想重新发明轮子？任何参考/lib 都会有所帮助。我在这里很难找到这个。

Answer 1

发布社区 wiki 答案以总结问题。

Clark McCauley很好地建议：

您可能正在寻找此处包含的逻辑。

这是对 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)

}