Function initLocalCRIImageService

integration/image_pull_timeout_test.go:508–529

initLocalCRIImageService uses containerd.Client to init CRI plugin. NOTE: We don't need to start the CRI plugin here because we just need the ImageService API.

(client *containerd.Client, tmpDir string, registryCfg criconfig.Registry, useLocalPull bool)

// NOTE: We don't need to start the CRI plugin here because we just need the
// ImageService API.
func initLocalCRIImageService(client *containerd.Client, tmpDir string, registryCfg criconfig.Registry, useLocalPull bool) (criserver.ImageService, error) {
	containerdRootDir := filepath.Join(tmpDir, "root")

	cfg := criconfig.ImageConfig{
		Snapshotter:              defaults.DefaultSnapshotter,
		Registry:                 registryCfg,
		ImagePullProgressTimeout: defaultImagePullProgressTimeout.String(),
		StatsCollectPeriod:       10,
		UseLocalImagePull:        useLocalPull,
	}

	return images.NewService(cfg, &images.CRIImageServiceOptions{
		ImageFSPaths: map[string]string{
			defaults.DefaultSnapshotter: containerdRootDir,
		},
		RuntimePlatforms: map[string]images.ImagePlatform{},
		Content:          client.ContentStore(),
		Images:           client.ImageService(),
		Client:           client,
		Transferrer:      client.TransferService(),
	})
}