(ctx context.Context, vp Provider)
| 88 | } |
| 89 | |
| 90 | func (vs *Set) copyToHostFromProvider(ctx context.Context, vp Provider) error { |
| 91 | dir, err := os.MkdirTemp(vs.tempDir, "copyToHostFromProvider") |
| 92 | if err != nil { |
| 93 | return err |
| 94 | } |
| 95 | volumes, err := vp.CreateVolumesUnder(ctx, dir) |
| 96 | if err != nil { |
| 97 | return err |
| 98 | } |
| 99 | |
| 100 | mounts := make([]Mount, 0, len(volumes)) |
| 101 | for _, v := range volumes { |
| 102 | if v.name == "" { |
| 103 | index := len(vs.volumes) |
| 104 | v.name = fmt.Sprintf("anon_%d", index) |
| 105 | } |
| 106 | vs.volumes[v.name] = v |
| 107 | |
| 108 | mounts = append(mounts, Mount{key: v.name, Destination: v.containerPath, ReadOnly: false}) |
| 109 | } |
| 110 | vs.mounts[vp.Name()] = mounts |
| 111 | return nil |
| 112 | } |
| 113 | |
| 114 | func (vs *Set) createDiskImage(ctx context.Context, size int64) (path string, retErr error) { |
| 115 | f, err := os.CreateTemp(vs.tempDir, "createDiskImage") |
no test coverage detected