-
Notifications
You must be signed in to change notification settings - Fork 61
/
described_image.go
120 lines (101 loc) · 3.53 KB
/
described_image.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
// Copyright 2020 VMware, Inc.
// SPDX-License-Identifier: Apache-2.0
package imagedesc
import (
"encoding/json"
"fmt"
regv1 "github.com/google/go-containerregistry/pkg/v1"
"github.com/google/go-containerregistry/pkg/v1/types"
)
type DescribedImage struct {
desc ImageDescriptor
layerProvider LayerProvider
}
var _ regv1.Image = DescribedImage{}
func NewDescribedImage(desc ImageDescriptor, layerProvider LayerProvider) DescribedImage {
return DescribedImage{desc, layerProvider}
}
func (i DescribedImage) Ref() string { return i.desc.Refs[0] }
func (i DescribedImage) Tag() string { return i.desc.Tag }
// Layers returns the ordered collection of filesystem layers that comprise this image.
// The order of the list is oldest/base layer first, and most-recent/top layer last.
func (i DescribedImage) Layers() ([]regv1.Layer, error) {
var layers []regv1.Layer
for _, layerTD := range i.desc.Layers {
layerFile, err := i.layerProvider.FindLayer(layerTD)
if err != nil {
return nil, err
}
layers = append(layers, NewDescribedCompressedLayer(layerTD, layerFile))
}
return layers, nil
}
// MediaType of this image's manifest.
func (i DescribedImage) MediaType() (types.MediaType, error) {
return types.MediaType(i.desc.Manifest.MediaType), nil
}
// ConfigName returns the hash of the image's config file.
func (i DescribedImage) ConfigName() (regv1.Hash, error) {
return regv1.NewHash(i.desc.Config.Digest)
}
// ConfigFile returns this image's config file.
func (i DescribedImage) ConfigFile() (*regv1.ConfigFile, error) {
var config *regv1.ConfigFile
err := json.Unmarshal([]byte(i.desc.Config.Raw), &config)
if err != nil {
return nil, err
}
return config, nil
}
// RawConfigFile returns the serialized bytes of ConfigFile()
func (i DescribedImage) RawConfigFile() ([]byte, error) {
return []byte(i.desc.Config.Raw), nil
}
// Digest returns the sha256 of this image's manifest.
func (i DescribedImage) Digest() (regv1.Hash, error) {
return regv1.NewHash(i.desc.Manifest.Digest)
}
// Manifest returns this image's Manifest object.
func (i DescribedImage) Manifest() (*regv1.Manifest, error) {
var manifest *regv1.Manifest
err := json.Unmarshal([]byte(i.desc.Manifest.Raw), &manifest)
if err != nil {
return nil, err
}
return manifest, nil
}
// RawManifest returns the serialized bytes of Manifest()
func (i DescribedImage) RawManifest() ([]byte, error) {
return []byte(i.desc.Manifest.Raw), nil
}
func (i DescribedImage) Size() (int64, error) {
return int64(len(i.desc.Manifest.Raw)), nil
}
// LayerByDigest returns a Layer for interacting with a particular layer of
// the image, looking it up by "digest" (the compressed hash).
func (i DescribedImage) LayerByDigest(digest regv1.Hash) (regv1.Layer, error) {
for _, layerTD := range i.desc.Layers {
if layerTD.Digest == digest.String() {
layerFile, err := i.layerProvider.FindLayer(layerTD)
if err != nil {
return nil, err
}
return NewDescribedCompressedLayer(layerTD, layerFile), nil
}
}
return nil, fmt.Errorf("Expected to find layer '%s' by digest", digest)
}
// LayerByDiffID is an analog to LayerByDigest, looking up by "diff id"
// (the uncompressed hash).
func (i DescribedImage) LayerByDiffID(diffID regv1.Hash) (regv1.Layer, error) {
for _, layerTD := range i.desc.Layers {
if layerTD.DiffID == diffID.String() {
layerFile, err := i.layerProvider.FindLayer(layerTD)
if err != nil {
return nil, err
}
return NewDescribedCompressedLayer(layerTD, layerFile), nil
}
}
return nil, fmt.Errorf("Expected to find layer '%s' by diff id", diffID)
}