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
|
package tunnel
import (
"context"
"encoding/json"
"fmt"
"strings"
"github.com/containers/libpod/libpod/image"
"github.com/containers/libpod/pkg/bindings/manifests"
"github.com/containers/libpod/pkg/domain/entities"
"github.com/pkg/errors"
)
// ManifestCreate implements manifest create via ImageEngine
func (ir *ImageEngine) ManifestCreate(ctx context.Context, names, images []string, opts entities.ManifestCreateOptions) (string, error) {
imageID, err := manifests.Create(ir.ClientCxt, names, images, &opts.All)
if err != nil {
return imageID, errors.Wrapf(err, "error creating manifest")
}
return imageID, err
}
// ManifestInspect returns contents of manifest list with given name
func (ir *ImageEngine) ManifestInspect(ctx context.Context, name string) ([]byte, error) {
list, err := manifests.Inspect(ir.ClientCxt, name)
if err != nil {
return nil, errors.Wrapf(err, "error getting content of manifest list or image %s", name)
}
buf, err := json.MarshalIndent(list, "", " ")
if err != nil {
return buf, errors.Wrapf(err, "error rendering manifest for display")
}
return buf, err
}
// ManifestAdd adds images to the manifest list
func (ir *ImageEngine) ManifestAdd(ctx context.Context, opts entities.ManifestAddOptions) (string, error) {
manifestAddOpts := image.ManifestAddOpts{
All: opts.All,
Arch: opts.Arch,
Features: opts.Features,
Images: opts.Images,
OS: opts.OS,
OSVersion: opts.OSVersion,
Variant: opts.Variant,
}
if len(opts.Annotation) != 0 {
annotations := make(map[string]string)
for _, annotationSpec := range opts.Annotation {
spec := strings.SplitN(annotationSpec, "=", 2)
if len(spec) != 2 {
return "", errors.Errorf("no value given for annotation %q", spec[0])
}
annotations[spec[0]] = spec[1]
}
manifestAddOpts.Annotation = annotations
}
listID, err := manifests.Add(ctx, opts.Images[1], manifestAddOpts)
if err != nil {
return listID, errors.Wrapf(err, "error adding to manifest list %s", opts.Images[1])
}
return listID, nil
}
// FIXME There is no endpoint for annotate and therefor this code is currently invalid
// ManifestAnnotate updates an entry of the manifest list
func (ir *ImageEngine) ManifestAnnotate(ctx context.Context, names []string, opts entities.ManifestAnnotateOptions) (string, error) {
return "", errors.New("not implemented")
// manifestAnnotateOpts := image.ManifestAnnotateOpts{
// Arch: opts.Arch,
// Features: opts.Features,
// OS: opts.OS,
// OSFeatures: opts.OSFeatures,
// OSVersion: opts.OSVersion,
// Variant: opts.Variant,
// }
// if len(opts.Annotation) > 0 {
// annotations := make(map[string]string)
// for _, annotationSpec := range opts.Annotation {
// spec := strings.SplitN(annotationSpec, "=", 2)
// if len(spec) != 2 {
// return "", errors.Errorf("no value given for annotation %q", spec[0])
// }
// annotations[spec[0]] = spec[1]
// }
// manifestAnnotateOpts.Annotation = annotations
// }
// updatedListID, err := manifests.Annotate(ctx, names[0], names[1], manifestAnnotateOpts)
// if err != nil {
// return updatedListID, errors.Wrapf(err, "error annotating %s of manifest list %s", names[1], names[0])
// }
// return fmt.Sprintf("%s :%s", updatedListID, names[1]), nil
}
// ManifestRemove removes the digest from manifest list
func (ir *ImageEngine) ManifestRemove(ctx context.Context, names []string) (string, error) {
updatedListID, err := manifests.Remove(ctx, names[0], names[1])
if err != nil {
return updatedListID, errors.Wrapf(err, "error removing from manifest %s", names[0])
}
return fmt.Sprintf("%s :%s\n", updatedListID, names[1]), nil
}
// ManifestPush pushes a manifest list or image index to the destination
func (ir *ImageEngine) ManifestPush(ctx context.Context, names []string, opts entities.ManifestPushOptions) error {
_, err := manifests.Push(ctx, names[0], &names[1], &opts.All)
return err
}
|
