Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request moby#5 from rumpl/feat-pull
Create the containerd image service
- Loading branch information
Showing
4 changed files
with
291 additions
and
33 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,244 @@ | ||
| package containerd | ||
|
|
||
| import ( | ||
| "context" | ||
| "io" | ||
|
|
||
| "github.com/containerd/containerd" | ||
| "github.com/containerd/containerd/platforms" | ||
| "github.com/docker/distribution" | ||
| "github.com/docker/distribution/reference" | ||
| "github.com/docker/docker/api/types" | ||
| "github.com/docker/docker/api/types/backend" | ||
| "github.com/docker/docker/api/types/filters" | ||
| imagetype "github.com/docker/docker/api/types/image" | ||
| registrytypes "github.com/docker/docker/api/types/registry" | ||
| "github.com/docker/docker/builder" | ||
| "github.com/docker/docker/container" | ||
| "github.com/docker/docker/daemon/images" | ||
| "github.com/docker/docker/errdefs" | ||
| "github.com/docker/docker/image" | ||
| "github.com/docker/docker/layer" | ||
| "github.com/opencontainers/go-digest" | ||
| ocispec "github.com/opencontainers/image-spec/specs-go/v1" | ||
| ) | ||
|
|
||
| type containerdStore struct { | ||
| client *containerd.Client | ||
| } | ||
|
|
||
| func NewService(c *containerd.Client) *containerdStore { | ||
| return &containerdStore{ | ||
| client: c, | ||
| } | ||
| } | ||
|
|
||
| func (cs *containerdStore) PullImage(ctx context.Context, image, tag string, platform *ocispec.Platform, metaHeaders map[string][]string, authConfig *types.AuthConfig, outStream io.Writer) error { | ||
| var opts []containerd.RemoteOpt | ||
| if platform != nil { | ||
| opts = append(opts, containerd.WithPlatform(platforms.Format(*platform))) | ||
| } | ||
| ref, err := reference.ParseNormalizedNamed(image) | ||
| if err != nil { | ||
| return errdefs.InvalidParameter(err) | ||
| } | ||
|
|
||
| if tag != "" { | ||
| // The "tag" could actually be a digest. | ||
| var dgst digest.Digest | ||
| dgst, err = digest.Parse(tag) | ||
| if err == nil { | ||
| ref, err = reference.WithDigest(reference.TrimNamed(ref), dgst) | ||
| } else { | ||
| ref, err = reference.WithTag(ref, tag) | ||
| } | ||
| if err != nil { | ||
| return errdefs.InvalidParameter(err) | ||
| } | ||
| } | ||
|
|
||
| _, err = cs.client.Pull(ctx, ref.String(), opts...) | ||
| return err | ||
| } | ||
|
|
||
| func (cs *containerdStore) Images(ctx context.Context, opts types.ImageListOptions) ([]*types.ImageSummary, error) { | ||
| images, err := cs.client.ListImages(ctx) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| var ret []*types.ImageSummary | ||
| for _, image := range images { | ||
| size, err := image.Size(ctx) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| ret = append(ret, &types.ImageSummary{ | ||
| RepoDigests: []string{image.Name() + "@" + image.Target().Digest.String()}, // "hello-world@sha256:bfea6278a0a267fad2634554f4f0c6f31981eea41c553fdf5a83e95a41d40c38"}, | ||
| RepoTags: []string{image.Name()}, | ||
| Containers: -1, | ||
| ParentID: "", | ||
| SharedSize: -1, | ||
| VirtualSize: 10, | ||
| ID: image.Target().Digest.String(), | ||
| Created: image.Metadata().CreatedAt.Unix(), | ||
| Size: size, | ||
| }) | ||
| } | ||
|
|
||
| return ret, nil | ||
| } | ||
|
|
||
| func (cs *containerdStore) LogImageEvent(imageID, refName, action string) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) LogImageEventWithAttributes(imageID, refName, action string, attributes map[string]string) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetLayerFolders(img *image.Image, rwLayer layer.RWLayer) ([]string, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) Map() map[image.ID]*image.Image { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetLayerByID(string) (layer.RWLayer, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetLayerMountID(string) (string, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) Cleanup() error { | ||
| return nil | ||
| } | ||
|
|
||
| func (cs *containerdStore) GraphDriverName() string { | ||
| return "" | ||
| } | ||
|
|
||
| func (cs *containerdStore) CommitBuildStep(c backend.CommitConfig) (image.ID, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) CreateImage(config []byte, parent string) (builder.Image, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetImageAndReleasableLayer(ctx context.Context, refOrID string, opts backend.GetImageAndLayerOptions) (builder.Image, builder.ROLayer, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) MakeImageCache(sourceRefs []string) builder.ImageCache { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) TagImageWithReference(imageID image.ID, newTag reference.Named) error { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) SquashImage(id, parent string) (string, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ExportImage(names []string, outStream io.Writer) error { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ImageDelete(imageRef string, force, prune bool) ([]types.ImageDeleteResponseItem, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ImageHistory(name string) ([]*imagetype.HistoryResponseItem, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ImagesPrune(ctx context.Context, pruneFilters filters.Args) (*types.ImagesPruneReport, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ImportImage(src string, repository string, platform *ocispec.Platform, tag string, msg string, inConfig io.ReadCloser, outStream io.Writer, changes []string) error { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) LoadImage(inTar io.ReadCloser, outStream io.Writer, quiet bool) error { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) LookupImage(ctx context.Context, name string) (*types.ImageInspect, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) PushImage(ctx context.Context, image, tag string, metaHeaders map[string][]string, authConfig *types.AuthConfig, outStream io.Writer) error { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) SearchRegistryForImages(ctx context.Context, searchFilters filters.Args, term string, limit int, authConfig *types.AuthConfig, metaHeaders map[string][]string) (*registrytypes.SearchResults, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) TagImage(imageName, repository, tag string) (string, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetRepository(context.Context, reference.Named, *types.AuthConfig) (distribution.Repository, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ImageDiskUsage(ctx context.Context) ([]*types.ImageSummary, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) LayerDiskUsage(ctx context.Context) (int64, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) ReleaseLayer(rwlayer layer.RWLayer) error { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) CommitImage(c backend.CommitConfig) (image.ID, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetImage(refOrID string, platform *ocispec.Platform) (retImg *image.Image, retErr error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) CreateLayer(container *container.Container, initFunc layer.MountInit) (layer.RWLayer, error) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) DistributionServices() images.DistributionServices { | ||
| return images.DistributionServices{} | ||
| } | ||
|
|
||
| func (cs *containerdStore) CountImages() int { | ||
| imgs, err := cs.client.ListImages(context.TODO()) | ||
| if err != nil { | ||
| return 0 | ||
| } | ||
|
|
||
| return len(imgs) | ||
| } | ||
|
|
||
| func (cs *containerdStore) LayerStoreStatus() [][2]string { | ||
| return [][2]string{} | ||
| } | ||
|
|
||
| func (cs *containerdStore) GetContainerLayerSize(containerID string) (int64, int64) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) UpdateConfig(maxDownloads, maxUploads int) { | ||
| panic("not implemented") | ||
| } | ||
|
|
||
| func (cs *containerdStore) Children(id image.ID) []image.ID { | ||
| panic("not implemented") | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters