@@ -30,41 +30,42 @@ import (
3030func DispatchImages (ctx context.Context , targets []* target.Target ) error {
3131 errG := errgroup.Group {}
3232 for _ , obj := range targets {
33+ o := obj
3334 errG .Go (func () error {
34- switch obj .Proto {
35+ switch o .Proto {
3536 case target .DOCKERD :
3637 r , err := docker .New ()
3738 if err != nil {
3839 return err
3940 }
40- return HostImage (ctx , obj , r )
41+ return HostImage (ctx , o , r )
4142 case target .CONTAINERD :
4243 r , err := containerd .New ()
4344 if err != nil {
4445 return err
4546 }
46- return HostImage (ctx , obj , r )
47+ return HostImage (ctx , o , r )
4748 case target .REGISTRY_IMAGE :
48- path := filepath .Join (obj .Opts .TempPath , xid .NewWithTime (time .Now ()).String ())
49+ path := filepath .Join (o .Opts .TempPath , xid .NewWithTime (time .Now ()).String ())
4950 r , err := remote .New (path )
5051 if err != nil {
5152 return err
5253 }
53- return RegistryImage (ctx , obj , r )
54+ return RegistryImage (ctx , o , r )
5455 case target .REGISTRY :
55- path := filepath .Join (obj .Opts .TempPath , xid .NewWithTime (time .Now ()).String ())
56+ path := filepath .Join (o .Opts .TempPath , xid .NewWithTime (time .Now ()).String ())
5657 r , err := remote .New (path )
5758 if err != nil {
5859 return err
5960 }
60- return Registry (ctx , obj , r )
61+ return Registry (ctx , o , r )
6162 case target .TARBALL :
62- path := filepath .Join (obj .Opts .TempPath , xid .NewWithTime (time .Now ()).String ())
63+ path := filepath .Join (o .Opts .TempPath , xid .NewWithTime (time .Now ()).String ())
6364 t , err := tarball .New (tarball .WithRoot (path ))
6465 if err != nil {
6566 return err
6667 }
67- return TarballImage (ctx , obj , t )
68+ return TarballImage (ctx , o , t )
6869 default :
6970 return errors .New (fmt .Sprintf ("individual image protol: %s" , obj .Proto ))
7071 }
0 commit comments