k8s滚动更新算法

滚动更新是一种 Kubernetes 部署策略，它允许逐步替换旧版本 Pod，而不会导致应用程序中断。要为自定义资源（CRD）添加滚动更新支持，可以使用 Kubernetes 中的内置逻辑。具体而言，可以参考 Kubernetes 源代码中的 rolloutRolling 函数，该函数包含滚动更新的实现。这个函数管理扩展新副本集和缩减旧副本集的过程，以实现平滑的部署过渡。通过利用 Kubernetes 的滚动更新机制，可以简化 CRD 部署的管理，确保应用程序的高可用性和无缝升级。

我们已经创建了自己的自定义资源（也称为 CRD），我们需要添加对滚动更新的支持，因为 K8s 支持它进行部署等，我们希望重用此类逻辑，是否有任何我们可以使用（可能部分）的库我们可以用它来支持吗？或者也许学习并遵循逻辑，因为我们不想重新发明轮子？任何参考/库都会有帮助。

我费了好大劲才在这里找到这个。

正确答案

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

Clark McCauley 很好的建议：

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

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

终于介绍完啦！小伙伴们，这篇关于《k8s滚动更新算法》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！