integration tests

Signed-off-by: Matthew Endsley <mendsley@gmail.com>

Author: mendsley

integration/container/create_test.go

@@ -21,6 +21,7 @@ import (
 	"github.com/docker/docker/oci"
 	"github.com/docker/docker/pkg/stringid"
 	"github.com/docker/docker/testutil"
+	"github.com/docker/go-units"
 	ocispec "github.com/opencontainers/image-spec/specs-go/v1"
 	"gotest.tools/v3/assert"
 	is "gotest.tools/v3/assert/cmp"
@@ -790,3 +791,42 @@ func TestContainerdContainerImageInfo(t *testing.T) {
 		assert.Equal(t, ctr.Image, "")
 	}
 }
+
+func TestContainerdSnapshotQuota(t *testing.T) {
+	skip.If(t, !testEnv.RuntimeIsWindowsContainerd() || !testEnv.UsingSnapshotter(), "Only testing windows snapshotter runtime")
+
+	ctx := setupTest(t)
+
+	apiClient := testEnv.APIClient()
+	defer apiClient.Close()
+
+	info, err := apiClient.Info(ctx)
+	assert.NilError(t, err)
+
+	skip.If(t, info.Containerd == nil, "requires containerd")
+
+	const containerSize = "32G"
+	expectedSize, err := units.RAMInBytes(containerSize)
+	assert.NilError(t, err)
+
+	id := testContainer.Create(ctx, t, apiClient, func(cfg *testContainer.TestContainerConfig) {
+		cfg.Config.Image = "mcr.microsoft.com/windows/servercore:ltsc2022"
+		cfg.HostConfig.StorageOpt = make(map[string]string)
+		cfg.HostConfig.StorageOpt["size"] = containerSize
+	})
+	defer apiClient.ContainerRemove(ctx, id, container.RemoveOptions{Force: true})
+
+	err = apiClient.ContainerStart(ctx, id, container.StartOptions{})
+	assert.NilError(t, err)
+
+	c8dClient, err := containerd.New(info.Containerd.Address, containerd.WithDefaultNamespace(info.Containerd.Namespaces.Containers))
+	assert.NilError(t, err)
+	defer c8dClient.Close()
+
+	snapshotInfo, err := c8dClient.SnapshotService("windows").Stat(ctx, id)
+	assert.NilError(t, err)
+
+	rootfsLabel, ok := snapshotInfo.Labels["containerd.io/snapshot/windows/rootfs.sizebytes"]
+	assert.Assert(t, ok, "Snapshot does not cotain rootfs quota label")
+	assert.Equal(t, rootfsLabel, expectedSize, "Container snapshot size does not match")
+}