[TIL] Argo Rollouts có nút bấm restart trên giao diện ArgoCD

Argo CD là gì

Argo CD is a declarative, GitOps continuous delivery tool for Kubernetes. https://argoproj.github.io/cd/

Argo CD và FluxCD là 2 lựa chọn phổ biến để thực hiện "Continuous Delivery" (CD) trên Kubernetes. Argo CD có giao diện nên thường được ưa chuộng hơn.

Argo Rollouts là gì

Argo Rollouts is a Kubernetes controller and set of CRDs which provide advanced deployment capabilities such as blue-green, canary, canary analysis, experimentation, and progressive delivery features to Kubernetes. https://argoproj.github.io/argo-rollouts/

Kubernetes Deployment mặc định hỗ trợ strategy deploy RollingUpdate, nhưng chiến thuật này có nhiều hạn chế. Argo Rollouts hỗ trợ nhiều chiến thuật deploy như blue-green, canary với nhiều tính năng phức tạp hơn.

Restart rollout

Khi cần restart các pod trong 1 rollout, các cách làm:

xóa từng pod đi để replicaset sẽ tạo lại pod mới (không khả thi với số lượng pod lớn, bấm mỏi tay)
xóa replicaset đi để rollout tạo lại replicaset mới
restart rollout: đây là 1 tính năng của Argo Rollouts, nó thậm chí có cả 1 nút bấm trong menu của rollout object trên giao diện Argo UI. https://argoproj.github.io/argo-rollouts/features/restart/#how-it-works

How it works

During a restart, the controller iterates through each ReplicaSet to see if all the Pods have a creation timestamp which is newer than the restartAt time. For every pod older than the restartAt timestamp, the Pod will be evicted, allowing the ReplicaSet to replace the pod with a recreated one.

Code:

func (p *RolloutPodRestarter) Reconcile(roCtx *rolloutContext) error {
  ...
    restartedAt := roCtx.rollout.Spec.RestartAt
    needsRestart := 0
    restarted := 0
    for _, pod := range rolloutPods {
        if pod.CreationTimestamp.After(restartedAt.Time) || pod.CreationTimestamp.Equal(restartedAt) {
            continue
        }
        needsRestart += 1
        if canRestart <= 0 {
            continue
        }
        if pod.DeletionTimestamp != nil {
            continue
        }
        newLogCtx := logCtx.WithField("Pod", pod.Name).WithField("CreatedAt", pod.CreationTimestamp.Format(time.RFC3339)).WithField("RestartAt", restartedAt.Format(time.RFC3339))
        newLogCtx.Info("restarting Pod that's older than restartAt Time")
        evictTarget := policy.Eviction{
            ObjectMeta: metav1.ObjectMeta{
                Name:      pod.Name,
                Namespace: pod.Namespace,
            },
        }
        err := p.client.CoreV1().Pods(pod.Namespace).Evict(ctx, &evictTarget)
    ...