graph

package
v1.7.0-rc3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2015 License: Apache-2.0 Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source
const DEFAULTTAG = "latest"

Variables

View Source
var ErrV2RegistryUnavailable = errors.New("error v2 registry unavailable")

Functions

func SetupInitLayer

func SetupInitLayer(initLayer string) error

setupInitLayer populates a directory with mountpoints suitable for bind-mounting dockerinit into the container. The mountpoint is simply an empty file at /.dockerinit

This extra layer is used by all containers as the top-most ro layer. It protects the container from unwanted side-effects on the rw layer.

func WriteStatus added in v1.3.0

func WriteStatus(requestedTag string, out io.Writer, sf *streamformatter.StreamFormatter, layersDownloaded bool)

Types

type ByCreated added in v1.7.0

type ByCreated []*types.Image

func (ByCreated) Len added in v1.7.0

func (r ByCreated) Len() int

func (ByCreated) Less added in v1.7.0

func (r ByCreated) Less(i, j int) bool

func (ByCreated) Swap added in v1.7.0

func (r ByCreated) Swap(i, j int)

type Graph

type Graph struct {
	Root string
	// contains filtered or unexported fields
}

A Graph is a store for versioned filesystem images and the relationship between them.

func NewGraph

func NewGraph(root string, driver graphdriver.Driver) (*Graph, error)

NewGraph instantiates a new graph at the given root path in the filesystem. `root` will be created if it doesn't exist.

func (*Graph) ByParent

func (graph *Graph) ByParent() (map[string][]*image.Image, error)

ByParent returns a lookup table of images by their parent. If an image of id ID has 3 children images, then the value for key ID will be a list of 3 images. If an image has no children, it will not have an entry in the table.

func (*Graph) Create

func (graph *Graph) Create(layerData archive.ArchiveReader, containerID, containerImage, comment, author string, containerConfig, config *runconfig.Config) (*image.Image, error)

Create creates a new image and registers it in the graph.

func (*Graph) Delete

func (graph *Graph) Delete(name string) error

Delete atomically removes an image from the graph.

func (*Graph) Driver

func (graph *Graph) Driver() graphdriver.Driver

func (*Graph) Exists

func (graph *Graph) Exists(id string) bool

Exists returns true if an image is registered at the given id. If the image doesn't exist or if an error is encountered, false is returned.

func (*Graph) Get

func (graph *Graph) Get(name string) (*image.Image, error)

Get returns the image with the given id, or an error if the image doesn't exist.

func (*Graph) Heads

func (graph *Graph) Heads() (map[string]*image.Image, error)

Heads returns all heads in the graph, keyed by id. A head is an image which is not the parent of another image in the graph.

func (*Graph) ImageRoot

func (graph *Graph) ImageRoot(id string) string

func (*Graph) IsNotExist

func (graph *Graph) IsNotExist(err error, id string) bool

FIXME: Implement error subclass instead of looking at the error text Note: This is the way golang implements os.IsNotExists on Plan9

func (*Graph) Map

func (graph *Graph) Map() (map[string]*image.Image, error)

Map returns a list of all images in the graph, addressable by ID.

func (*Graph) Mktemp

func (graph *Graph) Mktemp(id string) (string, error)

Mktemp creates a temporary sub-directory inside the graph's filesystem.

func (*Graph) Register

func (graph *Graph) Register(img *image.Image, layerData archive.ArchiveReader) (err error)

Register imports a pre-existing image into the graph.

func (*Graph) TempLayerArchive

func (graph *Graph) TempLayerArchive(id string, sf *streamformatter.StreamFormatter, output io.Writer) (*archive.TempArchive, error)

TempLayerArchive creates a temporary archive of the given image's filesystem layer.

The archive is stored on disk and will be automatically deleted as soon as has been read.
If output is not nil, a human-readable progress bar will be written to it.
FIXME: does this belong in Graph? How about MktempFile, let the caller use it for archives?

type ImageExportConfig added in v1.7.0

type ImageExportConfig struct {
	Names     []string
	Outstream io.Writer
}

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.

type ImageImportConfig added in v1.7.0

type ImageImportConfig struct {
	Changes         []string
	InConfig        io.ReadCloser
	OutStream       io.Writer
	ContainerConfig *runconfig.Config
}

type ImagePullConfig added in v1.7.0

type ImagePullConfig struct {
	MetaHeaders map[string][]string
	AuthConfig  *cliconfig.AuthConfig
	OutStream   io.Writer
}

type ImagePushConfig added in v1.7.0

type ImagePushConfig struct {
	MetaHeaders map[string][]string
	AuthConfig  *cliconfig.AuthConfig
	Tag         string
	OutStream   io.Writer
}

type ImagesConfig added in v1.7.0

type ImagesConfig struct {
	Filters string
	Filter  string
	All     bool
}

type Repository

type Repository map[string]string

func (Repository) Contains added in v1.3.0

func (r Repository) Contains(u Repository) bool

return true if the contents of u Repository, are wholly contained in r Repository

func (Repository) Update added in v1.3.0

func (r Repository) Update(u Repository)

update Repository mapping with content of u

type TagStore

type TagStore struct {
	Repositories map[string]Repository

	sync.Mutex
	// contains filtered or unexported fields
}

func NewTagStore

func NewTagStore(path string, cfg *TagStoreConfig) (*TagStore, error)

func (*TagStore) ByID

func (store *TagStore) ByID() map[string][]string

Return a reverse-lookup table of all the names which refer to each image Eg. {"43b5f19b10584": {"base:latest", "base:v1"}}

func (*TagStore) Delete

func (store *TagStore) Delete(repoName, ref string) (bool, error)

func (*TagStore) DeleteAll

func (store *TagStore) DeleteAll(id string) error

func (*TagStore) Get

func (store *TagStore) Get(repoName string) (Repository, error)

func (*TagStore) GetImage

func (store *TagStore) GetImage(repoName, refOrID string) (*image.Image, error)

func (*TagStore) GetRepoRefs added in v0.12.0

func (store *TagStore) GetRepoRefs() map[string][]string

func (*TagStore) History added in v1.7.0

func (s *TagStore) History(name string) ([]*types.ImageHistory, error)

func (*TagStore) ImageExport added in v1.7.0

func (s *TagStore) ImageExport(imageExportConfig *ImageExportConfig) error

func (*TagStore) ImageName

func (store *TagStore) ImageName(id string) string

func (*TagStore) ImageTarLayer added in v1.7.0

func (s *TagStore) ImageTarLayer(name string, dest io.Writer) error

ImageTarLayer return the tarLayer of the image

func (*TagStore) Images added in v1.7.0

func (s *TagStore) Images(config *ImagesConfig) ([]*types.Image, error)

func (*TagStore) Import added in v1.7.0

func (s *TagStore) Import(src string, repo string, tag string, imageImportConfig *ImageImportConfig) error

func (*TagStore) Load added in v1.7.0

func (s *TagStore) Load(inTar io.ReadCloser, outStream io.Writer) error

Loads a set of images into the repository. This is the complementary of ImageExport. The input stream is an uncompressed tar ball containing images and metadata.

func (*TagStore) Lookup added in v1.7.0

func (s *TagStore) Lookup(name string) (*types.ImageInspect, error)

Lookup return an image encoded in JSON

func (*TagStore) LookupImage

func (store *TagStore) LookupImage(name string) (*image.Image, error)

func (*TagStore) LookupRaw added in v1.7.0

func (s *TagStore) LookupRaw(name string) ([]byte, error)

func (*TagStore) Pull added in v1.7.0

func (s *TagStore) Pull(image string, tag string, imagePullConfig *ImagePullConfig) error

func (*TagStore) Push added in v1.7.0

func (s *TagStore) Push(localName string, imagePushConfig *ImagePushConfig) error

FIXME: Allow to interrupt current push when new push of same image is done.

func (*TagStore) SetDigest added in v1.6.0

func (store *TagStore) SetDigest(repoName, digest, imageName string) error

SetDigest creates a digest reference to an image ID.

func (*TagStore) SetLoad added in v1.7.0

func (store *TagStore) SetLoad(repoName, tag, imageName string, force bool, out io.Writer) error

func (*TagStore) Tag added in v1.7.0

func (store *TagStore) Tag(repoName, tag, imageName string, force bool) error

type TagStoreConfig added in v1.7.0

type TagStoreConfig struct {
	Graph    *Graph
	Key      libtrust.PrivateKey
	Registry *registry.Service
	Events   *events.Events
	Trust    *trust.TrustStore
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL