graph

package
v1.4.2-0...-d12a2d8 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2015 License: Apache-2.0 Imports: 43 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 ValidateTagName 

func ValidateTagName(name string) error

ValidateTagName validates the name of a tag

func WriteStatus 

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

Types

type ByCreated 

type ByCreated []*types.Image

func (ByCreated) Len 

func (r ByCreated) Len() int

func (ByCreated) Less 

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

func (ByCreated) Swap 

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 ImagesConfig 

type ImagesConfig struct {
	Filters string
	Filter  string
	All     bool
}

type Repository 

type Repository map[string]string

func (Repository) Contains 

func (r Repository) Contains(u Repository) bool

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

func (Repository) Update 

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, graph *Graph, key libtrust.PrivateKey, registryService *registry.Service, eventsService *events.Events) (*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) CmdGet 

func (s *TagStore) CmdGet(job *engine.Job) error

CmdGet returns information about an image. If the image doesn't exist, an empty object is returned, to allow checking for an image's existence.

func (*TagStore) CmdImageExport 

func (s *TagStore) CmdImageExport(job *engine.Job) error

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.

func (*TagStore) CmdImport 

func (s *TagStore) CmdImport(job *engine.Job) error

func (*TagStore) CmdLoad 

func (s *TagStore) CmdLoad(job *engine.Job) 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) CmdLookup 

func (s *TagStore) CmdLookup(job *engine.Job) error

CmdLookup return an image encoded in JSON

func (*TagStore) CmdPull 

func (s *TagStore) CmdPull(job *engine.Job) error

func (*TagStore) CmdPush 

func (s *TagStore) CmdPush(job *engine.Job) error

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

func (*TagStore) CmdSet 

func (s *TagStore) CmdSet(job *engine.Job) error

CmdSet stores a new image in the graph. Images are stored in the graph using 4 elements:

  • A user-defined ID
  • A collection of metadata describing the image
  • A directory tree stored as a tar archive (also called the "layer")
  • A reference to a "parent" ID on top of which the layer should be applied

NOTE: even though the parent ID is only useful in relation to the layer and how to apply it (ie you could represent the full directory tree as 'parent_layer + layer', it is treated as a top-level property of the image. This is an artifact of early design and should probably be cleaned up in the future to simplify the design.

Syntax: image_set ID Input:

  • Layer content must be streamed in tar format on stdin. An empty input is valid and represents a nil layer.

  • Image metadata must be passed in the command environment. 'json': a json-encoded object with all image metadata. It will be stored as-is, without any encoding/decoding artifacts. That is a requirement of the current registry client implementation, because a re-encoded json might invalidate the image checksum at the next upload, even with functionaly identical content.

func (*TagStore) CmdTag 

func (s *TagStore) CmdTag(job *engine.Job) error

func (*TagStore) CmdTarLayer 

func (s *TagStore) CmdTarLayer(job *engine.Job) error

CmdTarLayer return the tarLayer of the image

func (*TagStore) CmdViz 

func (s *TagStore) CmdViz(job *engine.Job) error

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 

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

func (*TagStore) History 

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

func (*TagStore) ImageName 

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

func (*TagStore) Images 

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

func (*TagStore) Install 

func (s *TagStore) Install(eng *engine.Engine) error

func (*TagStore) LookupImage 

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

func (*TagStore) Set 

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

func (*TagStore) SetDigest 

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

SetDigest creates a digest reference to an image ID.

func (*TagStore) SetLoad 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.