mirror of
https://github.com/mudler/luet.git
synced 2025-09-04 08:45:40 +00:00
Compare commits
7 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
5c84e5b0a7 | ||
|
06fa8b1c87 | ||
|
ff153f367f | ||
|
459676397c | ||
|
93057fbf6d | ||
|
5e1a7c50df | ||
|
0ceaf09615 |
@@ -40,7 +40,7 @@ var Verbose bool
|
|||||||
var LockedCommands = []string{"install", "uninstall", "upgrade"}
|
var LockedCommands = []string{"install", "uninstall", "upgrade"}
|
||||||
|
|
||||||
const (
|
const (
|
||||||
LuetCLIVersion = "0.16.2"
|
LuetCLIVersion = "0.16.3"
|
||||||
LuetEnvPrefix = "LUET"
|
LuetEnvPrefix = "LUET"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@@ -774,8 +774,10 @@ func (cs *LuetCompiler) getSpecHash(pkgs pkg.DefaultPackages, salt string) (stri
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool, p *compilerspec.LuetCompilationSpec) error {
|
func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool, p *compilerspec.LuetCompilationSpec) error {
|
||||||
|
|
||||||
|
joinTag := ">:loop: join<"
|
||||||
if len(p.Join) != 0 {
|
if len(p.Join) != 0 {
|
||||||
Info("Generating a joint parent image from final packages")
|
Info(joinTag, "Generating a joint parent image from final packages")
|
||||||
} else {
|
} else {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@@ -785,13 +787,16 @@ func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool,
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "could not generate image hash")
|
return errors.Wrap(err, "could not generate image hash")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Info(joinTag, "Searching existing image with hash ", overallFp)
|
||||||
|
|
||||||
image := cs.findImageHash(overallFp, p)
|
image := cs.findImageHash(overallFp, p)
|
||||||
if image != "" {
|
if image != "" {
|
||||||
Info("Image already found", image)
|
Info("Image already found", image)
|
||||||
p.SetImage(image)
|
p.SetImage(image)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
Info("Generating image with hash ", image)
|
Info(joinTag, "Image not found. Generating image join with hash ", overallFp)
|
||||||
|
|
||||||
// Make sure there is an output path
|
// Make sure there is an output path
|
||||||
if err := os.MkdirAll(p.GetOutputPath(), os.ModePerm); err != nil {
|
if err := os.MkdirAll(p.GetOutputPath(), os.ModePerm); err != nil {
|
||||||
@@ -805,14 +810,24 @@ func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool,
|
|||||||
}
|
}
|
||||||
defer os.RemoveAll(joinDir) // clean up
|
defer os.RemoveAll(joinDir) // clean up
|
||||||
|
|
||||||
|
for _, p := range p.Join { //highly dependent on the order
|
||||||
|
Info(joinTag, ":arrow_right_hook:", p.HumanReadableString(), ":leaves:")
|
||||||
|
}
|
||||||
|
|
||||||
|
current := 0
|
||||||
for _, c := range p.Join {
|
for _, c := range p.Join {
|
||||||
|
current++
|
||||||
if c != nil && c.Name != "" && c.Version != "" {
|
if c != nil && c.Name != "" && c.Version != "" {
|
||||||
Info(" :droplet: generating", c.HumanReadableString())
|
joinTag2 := fmt.Sprintf("%s %d/%d ⤑ :hammer: build %s", joinTag, current, len(p.Join), c.HumanReadableString())
|
||||||
|
|
||||||
|
Info(joinTag2, "compilation starts")
|
||||||
spec, err := cs.FromPackage(c)
|
spec, err := cs.FromPackage(c)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "while generating images to join from")
|
return errors.Wrap(err, "while generating images to join from")
|
||||||
}
|
}
|
||||||
wantsArtifact := true
|
wantsArtifact := true
|
||||||
|
spec.SetOutputPath(p.GetOutputPath())
|
||||||
|
|
||||||
artifact, err := cs.compile(concurrency, keepPermissions, &wantsArtifact, spec)
|
artifact, err := cs.compile(concurrency, keepPermissions, &wantsArtifact, spec)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "failed building join image")
|
return errors.Wrap(err, "failed building join image")
|
||||||
@@ -822,6 +837,7 @@ func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool,
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "failed building join image")
|
return errors.Wrap(err, "failed building join image")
|
||||||
}
|
}
|
||||||
|
Info(joinTag2, ":white_check_mark: Done")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -831,6 +847,8 @@ func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool,
|
|||||||
}
|
}
|
||||||
defer os.RemoveAll(joinDir) // clean up
|
defer os.RemoveAll(joinDir) // clean up
|
||||||
|
|
||||||
|
Info(joinTag, ":droplet: generating artifact for source image of", p.GetPackage().HumanReadableString())
|
||||||
|
|
||||||
// After unpack, create a new artifact and a new final image from it.
|
// After unpack, create a new artifact and a new final image from it.
|
||||||
// no need to compress, as we are going to toss it away.
|
// no need to compress, as we are going to toss it away.
|
||||||
a := artifact.NewPackageArtifact(filepath.Join(artifactDir, p.GetPackage().GetFingerPrint()+".join.tar"))
|
a := artifact.NewPackageArtifact(filepath.Join(artifactDir, p.GetPackage().GetFingerPrint()+".join.tar"))
|
||||||
@@ -839,35 +857,47 @@ func (cs *LuetCompiler) resolveJoinImages(concurrency int, keepPermissions bool,
|
|||||||
}
|
}
|
||||||
|
|
||||||
joinImageName := fmt.Sprintf("%s:%s", cs.Options.PushImageRepository, overallFp)
|
joinImageName := fmt.Sprintf("%s:%s", cs.Options.PushImageRepository, overallFp)
|
||||||
|
Info(joinTag, ":droplet: generating image from artifact", joinImageName)
|
||||||
opts, err := a.GenerateFinalImage(joinImageName, cs.Backend, keepPermissions)
|
opts, err := a.GenerateFinalImage(joinImageName, cs.Backend, keepPermissions)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "could not create final image")
|
return errors.Wrap(err, "could not create final image")
|
||||||
}
|
}
|
||||||
if cs.Options.Push {
|
if cs.Options.Push {
|
||||||
|
Info(joinTag, ":droplet: pushing image from artifact", joinImageName)
|
||||||
if err = cs.Backend.Push(opts); err != nil {
|
if err = cs.Backend.Push(opts); err != nil {
|
||||||
return errors.Wrapf(err, "Could not push image: %s %s", image, opts.DockerFileName)
|
return errors.Wrapf(err, "Could not push image: %s %s", image, opts.DockerFileName)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Info("Using image ", joinImageName)
|
Info(joinTag, ":droplet: Consuming image", joinImageName)
|
||||||
p.SetImage(joinImageName)
|
p.SetImage(joinImageName)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cs *LuetCompiler) resolveMultiStageImages(concurrency int, keepPermissions bool, p *compilerspec.LuetCompilationSpec) error {
|
func (cs *LuetCompiler) resolveMultiStageImages(concurrency int, keepPermissions bool, p *compilerspec.LuetCompilationSpec) error {
|
||||||
resolvedCopyFields := []compilerspec.CopyField{}
|
resolvedCopyFields := []compilerspec.CopyField{}
|
||||||
|
copyTag := ">:droplet: copy<"
|
||||||
|
|
||||||
if len(p.Copy) != 0 {
|
if len(p.Copy) != 0 {
|
||||||
Info("Package has multi-stage copy, generating required images")
|
Info(copyTag, "Package has multi-stage copy, generating required images")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
current := 0
|
||||||
|
// TODO: we should run this only if we are going to build the image
|
||||||
for _, c := range p.Copy {
|
for _, c := range p.Copy {
|
||||||
|
current++
|
||||||
if c.Package != nil && c.Package.Name != "" && c.Package.Version != "" {
|
if c.Package != nil && c.Package.Name != "" && c.Package.Version != "" {
|
||||||
Info(" :droplet: generating multi-stage images for", c.Package.HumanReadableString())
|
copyTag2 := fmt.Sprintf("%s %d/%d ⤑ :hammer: build %s", copyTag, current, len(p.Copy), c.Package.HumanReadableString())
|
||||||
|
|
||||||
|
Info(copyTag2, "generating multi-stage images for", c.Package.HumanReadableString())
|
||||||
spec, err := cs.FromPackage(c.Package)
|
spec, err := cs.FromPackage(c.Package)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "while generating images to copy from")
|
return errors.Wrap(err, "while generating images to copy from")
|
||||||
}
|
}
|
||||||
noArtifact := false
|
|
||||||
artifact, err := cs.compile(concurrency, keepPermissions, &noArtifact, spec)
|
|
||||||
|
|
||||||
|
// If we specify --only-target package, we don't want any artifact, otherwise we do
|
||||||
|
genArtifact := !cs.Options.PackageTargetOnly
|
||||||
|
spec.SetOutputPath(p.GetOutputPath())
|
||||||
|
artifact, err := cs.compile(concurrency, keepPermissions, &genArtifact, spec)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.Wrap(err, "failed building multi-stage image")
|
return errors.Wrap(err, "failed building multi-stage image")
|
||||||
}
|
}
|
||||||
@@ -877,6 +907,7 @@ func (cs *LuetCompiler) resolveMultiStageImages(concurrency int, keepPermissions
|
|||||||
Source: c.Source,
|
Source: c.Source,
|
||||||
Destination: c.Destination,
|
Destination: c.Destination,
|
||||||
})
|
})
|
||||||
|
Info(copyTag2, ":white_check_mark: Done")
|
||||||
} else {
|
} else {
|
||||||
resolvedCopyFields = append(resolvedCopyFields, c)
|
resolvedCopyFields = append(resolvedCopyFields, c)
|
||||||
}
|
}
|
||||||
@@ -938,11 +969,13 @@ func (cs *LuetCompiler) compile(concurrency int, keepPermissions bool, generateA
|
|||||||
if generateArtifact != nil {
|
if generateArtifact != nil {
|
||||||
localGenerateArtifact = *generateArtifact
|
localGenerateArtifact = *generateArtifact
|
||||||
}
|
}
|
||||||
|
|
||||||
a, err := cs.compileWithImage(p.GetImage(), packageHashTree.BuilderImageHash, targetAssertion.Hash.PackageHash, concurrency, keepPermissions, cs.Options.KeepImg, p, localGenerateArtifact)
|
a, err := cs.compileWithImage(p.GetImage(), packageHashTree.BuilderImageHash, targetAssertion.Hash.PackageHash, concurrency, keepPermissions, cs.Options.KeepImg, p, localGenerateArtifact)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, "building direct image")
|
return nil, errors.Wrap(err, "building direct image")
|
||||||
}
|
}
|
||||||
a.SourceAssertion = p.GetSourceAssertion()
|
a.SourceAssertion = p.GetSourceAssertion()
|
||||||
|
|
||||||
a.PackageCacheImage = targetAssertion.Hash.PackageHash
|
a.PackageCacheImage = targetAssertion.Hash.PackageHash
|
||||||
return a, nil
|
return a, nil
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user