return criclient.NewRemoteRuntimeService(endpoint, defaultTimeout, nil, nil)
}

func (*defaultImpl) NewRemoteImageService(endpoint string, connectionTimeout time.Duration) (criapi.ImageManagerService, error) {
	return criclient.NewRemoteImageService(endpoint, connectionTimeout, nil, nil)
}

}

func (fake *fakeImpl) ListPodSandboxReturns(res []*v1.PodSandbox, err error) {
	fake.listPodSandboxReturns = struct {
		res []*v1.PodSandbox
		err error
	}{res, err}
}

func (fake *fakeImpl) NewRemoteImageService(string, time.Duration) (cri.ImageManagerService, error) {
	fakeReturns := fake.newRemoteImageServiceReturns
	return fakeReturns.res, fakeReturns.err
}

	if err != nil {
		return errors.Wrap(err, "failed to create new CRI runtime service")
	}
	runtime.runtimeService = runtimeService

	imageService, err := runtime.impl.NewRemoteImageService(runtime.criSocket, defaultTimeout)
	if err != nil {
		return errors.Wrap(err, "failed to create new CRI image service")
	}
	runtime.imageService = imageService

	return nil
}

		}

		var imageService internalapi.ImageManagerService = fakeRemoteRuntime.ImageService
		if config.UseHostImageService {
			imageService, err = remote.NewRemoteImageService(c.ImageServiceEndpoint, 15*time.Second, noop.NewTracerProvider(), &logger)
			if err != nil {
				return fmt.Errorf("Failed to init image service, error: %w", err)
			}
		}

	kubelet.runtimeService = runtimeSvc

	fakeRuntime.ImageService.SetFakeImageSize(100)
	fakeRuntime.ImageService.SetFakeImages([]string{"test:latest"})
	logger := klog.Background()
	imageSvc, err := remote.NewRemoteImageService(endpoint, 15*time.Second, tp, &logger)
	assert.NoError(t, err)

	kubelet.containerRuntime, err = kuberuntime.NewKubeGenericRuntimeManager(
		kubelet.recorder,
		kubelet.livenessManager,

		return err
	}
	if kubeDeps.RemoteImageService, err = remote.NewRemoteImageService(remoteImageEndpoint, kubeCfg.RuntimeRequestTimeout.Duration, tp, &logger); err != nil {
		return err
	}

	kubeDeps.useLegacyCadvisorStats = cadvisor.UsingLegacyCadvisorStats(kubeCfg.ContainerRuntimeEndpoint)