1
0
Fork 0
mirror of https://github.com/moby/moby.git synced 2022-11-09 12:21:53 -05:00
moby--moby/builder.go

119 lines
3.1 KiB
Go
Raw Normal View History

2013-04-24 14:03:01 -04:00
package docker
import (
"fmt"
"os"
"path"
"time"
2013-04-24 14:03:01 -04:00
)
type Builder struct {
runtime *Runtime
repositories *TagStore
2013-05-06 19:58:09 -04:00
graph *Graph
2013-05-19 13:46:24 -04:00
config *Config
image *Image
2013-04-24 14:03:01 -04:00
}
func NewBuilder(runtime *Runtime) *Builder {
return &Builder{
runtime: runtime,
2013-05-06 19:58:09 -04:00
graph: runtime.graph,
repositories: runtime.repositories,
2013-04-24 14:03:01 -04:00
}
}
func (builder *Builder) Create(config *Config) (*Container, error) {
// Lookup image
img, err := builder.repositories.LookupImage(config.Image)
if err != nil {
return nil, err
2013-05-01 17:36:45 -04:00
}
2013-05-01 17:36:45 -04:00
if img.Config != nil {
2013-05-19 13:46:24 -04:00
MergeConfig(config, img.Config)
2013-05-01 17:36:45 -04:00
}
if config.Cmd == nil || len(config.Cmd) == 0 {
2013-05-01 17:36:45 -04:00
return nil, fmt.Errorf("No command specified")
}
// Generate id
id := GenerateId()
// Generate default hostname
// FIXME: the lxc template no longer needs to set a default hostname
if config.Hostname == "" {
config.Hostname = id[:12]
2013-05-01 17:36:45 -04:00
}
container := &Container{
// FIXME: we should generate the ID here instead of receiving it as an argument
Id: id,
Created: time.Now(),
Path: config.Cmd[0],
Args: config.Cmd[1:], //FIXME: de-duplicate from config
Config: config,
Image: img.Id, // Always use the resolved image id
NetworkSettings: &NetworkSettings{},
// FIXME: do we need to store this in the container?
SysInitPath: sysInitPath,
}
container.root = builder.runtime.containerRoot(container.Id)
// Step 1: create the container directory.
// This doubles as a barrier to avoid race conditions.
if err := os.Mkdir(container.root, 0700); err != nil {
return nil, err
2013-05-01 17:36:45 -04:00
}
// If custom dns exists, then create a resolv.conf for the container
if len(config.Dns) > 0 {
container.ResolvConfPath = path.Join(container.root, "resolv.conf")
f, err := os.Create(container.ResolvConfPath)
if err != nil {
return nil, err
}
defer f.Close()
for _, dns := range config.Dns {
if _, err := f.Write([]byte("nameserver " + dns + "\n")); err != nil {
return nil, err
}
}
} else {
container.ResolvConfPath = "/etc/resolv.conf"
}
// Step 2: save the container json
if err := container.ToDisk(); err != nil {
return nil, err
2013-04-24 14:03:01 -04:00
}
// Step 3: register the container
if err := builder.runtime.Register(container); err != nil {
2013-04-24 14:03:01 -04:00
return nil, err
}
return container, nil
}
2013-05-01 17:36:45 -04:00
// Commit creates a new filesystem image from the current state of a container.
// The image can optionally be tagged into a repository
func (builder *Builder) Commit(container *Container, repository, tag, comment, author string, config *Config) (*Image, error) {
// FIXME: freeze the container before copying it to avoid data corruption?
// FIXME: this shouldn't be in commands.
rwTar, err := container.ExportRw()
2013-04-24 18:24:14 -04:00
if err != nil {
return nil, err
}
2013-05-01 17:36:45 -04:00
// Create a new image from the container's base layers + a new layer from container changes
img, err := builder.graph.Create(rwTar, container, comment, author, config)
2013-04-24 18:24:14 -04:00
if err != nil {
return nil, err
}
2013-05-06 19:58:09 -04:00
// Register the image if needed
if repository != "" {
if err := builder.repositories.Set(repository, tag, img.Id, true); err != nil {
return img, err
}
}
2013-04-24 18:24:14 -04:00
return img, nil
2013-04-24 16:35:57 -04:00
}