- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewRemoteImageService (0.27 sec)
-
cmd/kubeadm/app/util/runtime/impl.go
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) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 06:58:01 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime_fake_test.go
} 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 06:58:01 UTC 2024 - 4K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
} 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) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
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,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
return err } if kubeDeps.RemoteImageService, err = remote.NewRemoteImageService(remoteImageEndpoint, kubeCfg.RuntimeRequestTimeout.Duration, tp, &logger); err != nil { return err } kubeDeps.useLegacyCadvisorStats = cadvisor.UsingLegacyCadvisorStats(kubeCfg.ContainerRuntimeEndpoint)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)