6e28d11d |
package graph
import (
"encoding/json"
"io"
"io/ioutil"
"os" |
377ed712 |
"path/filepath" |
6e28d11d |
|
6f4d8470 |
"github.com/Sirupsen/logrus" |
30d5a42c |
"github.com/docker/docker/pkg/archive" |
6e28d11d |
"github.com/docker/docker/pkg/parsers" |
568f86eb |
"github.com/docker/docker/registry" |
6e28d11d |
)
// CmdImageExport exports all images with the given tag. All versions
// containing the same tag are exported. The resulting output is an
// uncompressed tar ball.
// name is the set of tags to export.
// out is the writer where the images are written to. |
2a14b7dd |
type ImageExportConfig struct {
Names []string
Outstream io.Writer
}
func (s *TagStore) ImageExport(imageExportConfig *ImageExportConfig) error {
|
6e28d11d |
// get image json
tempdir, err := ioutil.TempDir("", "docker-export-")
if err != nil { |
c79b9bab |
return err |
6e28d11d |
}
defer os.RemoveAll(tempdir)
rootRepoMap := map[string]Repository{} |
b37fdc5d |
addKey := func(name string, tag string, id string) { |
6f4d8470 |
logrus.Debugf("add key [%s:%s]", name, tag) |
b37fdc5d |
if repo, ok := rootRepoMap[name]; !ok {
rootRepoMap[name] = Repository{tag: id}
} else {
repo[tag] = id
}
} |
2a14b7dd |
for _, name := range imageExportConfig.Names { |
568f86eb |
name = registry.NormalizeLocalName(name) |
6f4d8470 |
logrus.Debugf("Serializing %s", name) |
e64131d1 |
rootRepo := s.Repositories[name]
if rootRepo != nil {
// this is a base repo name, like 'busybox' |
b37fdc5d |
for tag, id := range rootRepo {
addKey(name, tag, id) |
fa2c68a8 |
if err := s.exportImage(id, tempdir); err != nil { |
c79b9bab |
return err |
e64131d1 |
} |
6e28d11d |
}
} else { |
e64131d1 |
img, err := s.LookupImage(name)
if err != nil { |
c79b9bab |
return err |
6e28d11d |
} |
e64131d1 |
if img != nil {
// This is a named image like 'busybox:latest'
repoName, repoTag := parsers.ParseRepositoryTag(name)
// check this length, because a lookup of a truncated has will not have a tag
// and will not need to be added to this map
if len(repoTag) > 0 { |
b37fdc5d |
addKey(repoName, repoTag, img.ID) |
e64131d1 |
} |
fa2c68a8 |
if err := s.exportImage(img.ID, tempdir); err != nil { |
c79b9bab |
return err |
e64131d1 |
}
} else {
// this must be an ID that didn't get looked up just right? |
fa2c68a8 |
if err := s.exportImage(name, tempdir); err != nil { |
c79b9bab |
return err |
e64131d1 |
}
} |
6e28d11d |
} |
6f4d8470 |
logrus.Debugf("End Serializing %s", name) |
6e28d11d |
}
// write repositories, if there is something to write
if len(rootRepoMap) > 0 { |
377ed712 |
f, err := os.OpenFile(filepath.Join(tempdir, "repositories"), os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0644) |
29a3bbf2 |
if err != nil {
f.Close()
return err
}
if err := json.NewEncoder(f).Encode(rootRepoMap); err != nil {
return err
}
if err := f.Close(); err != nil { |
c79b9bab |
return err |
6e28d11d |
}
} else { |
6f4d8470 |
logrus.Debugf("There were no repositories to write") |
6e28d11d |
}
fs, err := archive.Tar(tempdir, archive.Uncompressed)
if err != nil { |
c79b9bab |
return err |
6e28d11d |
}
defer fs.Close()
|
2a14b7dd |
if _, err := io.Copy(imageExportConfig.Outstream, fs); err != nil { |
c79b9bab |
return err |
6e28d11d |
} |
2a14b7dd |
logrus.Debugf("End export image") |
c79b9bab |
return nil |
6e28d11d |
}
// FIXME: this should be a top-level function, not a class method |
fa2c68a8 |
func (s *TagStore) exportImage(name, tempdir string) error { |
6e28d11d |
for n := name; n != ""; {
// temporary directory |
377ed712 |
tmpImageDir := filepath.Join(tempdir, n) |
6e28d11d |
if err := os.Mkdir(tmpImageDir, os.FileMode(0755)); err != nil {
if os.IsExist(err) {
return nil
}
return err
}
var version = "1.0"
var versionBuf = []byte(version)
|
377ed712 |
if err := ioutil.WriteFile(filepath.Join(tmpImageDir, "VERSION"), versionBuf, os.FileMode(0644)); err != nil { |
6e28d11d |
return err
}
// serialize json |
377ed712 |
json, err := os.Create(filepath.Join(tmpImageDir, "json")) |
6e28d11d |
if err != nil {
return err
} |
fa2c68a8 |
imageInspectRaw, err := s.LookupRaw(n)
if err != nil { |
6e28d11d |
return err
} |
fa2c68a8 |
written, err := json.Write(imageInspectRaw)
if err != nil {
return err
}
if written != len(imageInspectRaw) {
logrus.Warnf("%d byes should have been written instead %d have been written", written, len(imageInspectRaw))
} |
6e28d11d |
// serialize filesystem |
377ed712 |
fsTar, err := os.Create(filepath.Join(tmpImageDir, "layer.tar")) |
6e28d11d |
if err != nil {
return err
} |
ba001759 |
if err := s.ImageTarLayer(n, fsTar); err != nil { |
6e28d11d |
return err
}
// find parent |
d07fe183 |
img, err := s.LookupImage(n)
if err != nil { |
6e28d11d |
return err
} |
d07fe183 |
n = img.Parent |
6e28d11d |
}
return nil
} |