func HandleReplicaStarting()

in internal/controller/checkpoint_stages.go [93:107]

• 15 lines of code
• 4 McCabe index (conditional complexity)

func HandleReplicaStarting(r *TeamcityReconciler, ctx context.Context, checkpoint *Checkpoint) (bool, error) {
	instance := checkpoint.Instance
	roStatefulSetName := resource.GetROStatefulSetNamespacedName(&instance)
	var roStatefulSet v1.StatefulSet
	if err := r.Get(ctx, roStatefulSetName, &roStatefulSet); err != nil {
		return false, err
	}
	if roStatefulSet.Status.AvailableReplicas > 0 {
		err := checkpoint.DoCheckpointWithDesiredStage(ctx, ReplicaReady)
		if err != nil {
			return false, err
		}
	}
	return true, nil
}