Function StatusReplicasStatus

pkg/controller/component/replicas.go:139–176

(its *workloads.InstanceSet, replicas []string, hasMemberJoin, hasDataAction bool)

}

func StatusReplicasStatus(its *workloads.InstanceSet, replicas []string, hasMemberJoin, hasDataAction bool) error {
	loaded := func() *bool {
		if hasDataAction {
			return ptr.To(true)
		}
		return nil
	}()
	joined := func() *bool {
		if hasMemberJoin {
			return ptr.To(true)
		}
		return nil
	}()
	return UpdateReplicasStatusFunc(its, func(status *ReplicasStatus) error {
		status.Replicas = *its.Spec.Replicas
		if status.Status == nil {
			status.Status = make([]ReplicaStatus, 0)
		}
		for _, replica := range replicas {
			i := slices.IndexFunc(status.Status, func(s ReplicaStatus) bool {
				return s.Name == replica
			})
			if i >= 0 {
				status.Status[i].Provisioned = true
			} else {
				status.Status = append(status.Status, ReplicaStatus{
					Name:              replica,
					Generation:        compGenerationFromITS(its),
					CreationTimestamp: its.CreationTimestamp.Time,
					Provisioned:       true,
					DataLoaded:        loaded,
					MemberJoined:      joined,
				})
			}
		}
		return nil
	})
}

func UpdateReplicasStatusFunc(its *workloads.InstanceSet, f func(status *ReplicasStatus) error) error {
	if f == nil {