Function ResetPodsRecursive

cmd/reset/pods.go:123–143

(ctx devspacecontext.Context, dependencies, force bool)

}

func ResetPodsRecursive(ctx devspacecontext.Context, dependencies, force bool) int {
	resetted := 0
	if dependencies {
		for _, d := range ctx.Dependencies() {
			resetted += ResetPodsRecursive(ctx.AsDependency(d), dependencies, force)
		}
	}

	// create pod replacer
	podReplacer := podreplace.NewPodReplacer()
	for _, replacePodCache := range ctx.Config().RemoteCache().ListDevPods() {
		deleted, err := podReplacer.RevertReplacePod(ctx, &replacePodCache, &deploy.PurgeOptions{ForcePurge: force})
		if err != nil {
			ctx.Log().Warnf("Error resetting replaced pod: %v", err)
		} else if deleted {
			resetted++
		}
	}

	return resetted
}