Function Cleanup

service/node/task.go:130–142

(args *cluster.FolderCleanup, c *gin.Context)

)

func Cleanup(args *cluster.FolderCleanup, c *gin.Context) error {
	l := logging.FromContext(c)
	ae := serializer.NewAggregateError()
	for _, p := range args.Path {
		l.Info("Cleaning up folder %q", p)
		if err := os.RemoveAll(p); err != nil {
			l.Warning("Failed to clean up folder %q: %s", p, err)
			ae.Add(p, err)
		}
	}

	return ae.Aggregate()
}

type (
	CreateSlaveDownloadTaskParamCtx  struct{}