/
perf_check_container_backend.go
132 lines (112 loc) · 4.81 KB
/
perf_check_container_backend.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
121
122
123
124
125
126
127
128
129
130
131
132
package container_backend
import (
"context"
"github.com/werf/logboek"
"github.com/werf/werf/pkg/image"
)
type PerfCheckContainerBackend struct {
ContainerBackend ContainerBackend
}
func NewPerfCheckContainerBackend(containerBackend ContainerBackend) *PerfCheckContainerBackend {
return &PerfCheckContainerBackend{ContainerBackend: containerBackend}
}
func (runtime *PerfCheckContainerBackend) HasStapelBuildSupport() bool {
return runtime.ContainerBackend.HasStapelBuildSupport()
}
func (runtime *PerfCheckContainerBackend) ShouldCleanupDockerfileImage() bool {
return runtime.ContainerBackend.ShouldCleanupDockerfileImage()
}
func (runtime *PerfCheckContainerBackend) GetImageInfo(ctx context.Context, ref string, opts GetImageInfoOpts) (resImg *image.Info, resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.GetImageInfo %q", ref).
Do(func() {
resImg, resErr = runtime.ContainerBackend.GetImageInfo(ctx, ref, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) Rmi(ctx context.Context, ref string, opts RmiOpts) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.Rmi %q", ref).
Do(func() {
resErr = runtime.ContainerBackend.Rmi(ctx, ref, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) Pull(ctx context.Context, ref string, opts PullOpts) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.Pull %q", ref).
Do(func() {
resErr = runtime.ContainerBackend.Pull(ctx, ref, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) Tag(ctx context.Context, ref, newRef string, opts TagOpts) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.Tag %q as %q", ref, newRef).
Do(func() {
resErr = runtime.ContainerBackend.Tag(ctx, ref, newRef, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) Push(ctx context.Context, ref string, opts PushOpts) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.Push %q", ref).
Do(func() {
resErr = runtime.ContainerBackend.Push(ctx, ref, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) BuildDockerfile(ctx context.Context, dockerfile []byte, opts BuildDockerfileOpts) (resID string, resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.BuildDockerfile").
Do(func() {
resID, resErr = runtime.ContainerBackend.BuildDockerfile(ctx, dockerfile, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) BuildStapelStage(ctx context.Context, opts BuildStapelStageOptions) (resID string, resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.BuildDockerfile").
Do(func() {
resID, resErr = runtime.ContainerBackend.BuildStapelStage(ctx, opts)
})
return
}
func (runtime *PerfCheckContainerBackend) CalculateDependencyImportChecksum(ctx context.Context, dependencyImport DependencyImportSpec) (resID string, resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.BuildDockerfile").
Do(func() {
resID, resErr = runtime.ContainerBackend.CalculateDependencyImportChecksum(ctx, dependencyImport)
})
return
}
func (runtime *PerfCheckContainerBackend) RefreshImageObject(ctx context.Context, img LegacyImageInterface) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.RefreshImageObject %q", img.Name()).
Do(func() {
resErr = runtime.ContainerBackend.RefreshImageObject(ctx, img)
})
return
}
func (runtime *PerfCheckContainerBackend) PullImageFromRegistry(ctx context.Context, img LegacyImageInterface) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.PullImageFromRegistry %q", img.Name()).
Do(func() {
resErr = runtime.ContainerBackend.PullImageFromRegistry(ctx, img)
})
return
}
func (runtime *PerfCheckContainerBackend) RenameImage(ctx context.Context, img LegacyImageInterface, newImageName string, removeOldName bool) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.RenameImage %q to %q", img.Name(), newImageName).
Do(func() {
resErr = runtime.ContainerBackend.RenameImage(ctx, img, newImageName, removeOldName)
})
return
}
func (runtime *PerfCheckContainerBackend) RemoveImage(ctx context.Context, img LegacyImageInterface) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.RemoveImage %q", img.Name()).
Do(func() {
resErr = runtime.ContainerBackend.RemoveImage(ctx, img)
})
return
}
func (runtime *PerfCheckContainerBackend) String() string {
return runtime.ContainerBackend.String()
}
func (runtime *PerfCheckContainerBackend) RemoveHostDirs(ctx context.Context, mountDir string, dirs []string) (resErr error) {
logboek.Context(ctx).Default().LogProcess("ContainerBackend.RemoveHostDirs %q %v", mountDir, dirs).
Do(func() {
resErr = runtime.ContainerBackend.RemoveHostDirs(ctx, mountDir, dirs)
})
return
}