alt-orchestra/talos
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: add unit-test for containerd image import (#553)

Browse Source 
Just because we can easily do that, this also covers prior work
on converting panics to errors: #518

Signed-off-by: Andrey Smirnov <smirnov.andrey@gmail.com>
This commit is contained in:
Andrey Smirnov 2019-04-17 00:31:33 +03:00 committed by GitHub
parent d29e27ee33
commit 7cbc177a59
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 44 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
internal/app/init/pkg/system/runner/containerd/containerd_test.go
View File

@ -77,7 +77,7 @@ func (suite *ContainerdSuite) SetupSuite() {
suite.Require().NoError(err)
}
func (suite *ContainerdSuite) TeardownSuite() {
func (suite *ContainerdSuite) TearDownSuite() {
suite.Require().NoError(suite.client.Close())
suite.Require().NoError(suite.containerdRunner.Stop())
@ -246,6 +246,49 @@ func (suite *ContainerdSuite) TestStopSigKill() {
<-done
}
func (suite *ContainerdSuite) TestImportSuccess() {
reqs := []*containerdrunner.ImportRequest{
{
Path: "/rootfs/usr/images/osd.tar",
Options: []containerd.ImportOpt{
containerd.WithIndexName("testtalos/osd"),
},
},
{
Path: "/rootfs/usr/images/proxyd.tar",
Options: []containerd.ImportOpt{
containerd.WithIndexName("testtalos/proxyd"),
},
},
}
suite.Assert().NoError(containerdrunner.Import(containerdNamespace, reqs...))
ctx := namespaces.WithNamespace(context.Background(), containerdNamespace)
for _, imageName := range []string{"testtalos/osd", "testtalos/proxyd"} {
image, err := suite.client.ImageService().Get(ctx, imageName)
suite.Require().NoError(err)
suite.Require().Equal(imageName, image.Name)
}
}
func (suite *ContainerdSuite) TestImportFail() {
reqs := []*containerdrunner.ImportRequest{
{
Path: "/rootfs/usr/images/osd.tar",
Options: []containerd.ImportOpt{
containerd.WithIndexName("testtalos/osd2"),
},
},
{
Path: "/rootfs/usr/images/nothere.tar",
Options: []containerd.ImportOpt{
containerd.WithIndexName("testtalos/nothere"),
},
},
}
suite.Assert().Error(containerdrunner.Import(containerdNamespace, reqs...))
}
func TestContainerdSuite(t *testing.T) {
suite.Run(t, new(ContainerdSuite))
}