- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewRemoteRuntimeService (0.38 sec)
-
cmd/kubeadm/app/util/runtime/impl.go
} func (*defaultImpl) NewRemoteRuntimeService(endpoint string, connectionTimeout time.Duration) (criapi.RuntimeService, error) { return criclient.NewRemoteRuntimeService(endpoint, defaultTimeout, 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
fake.newRemoteImageServiceReturns = struct { res cri.ImageManagerService err error }{res, err} } func (fake *fakeImpl) NewRemoteRuntimeService(string, time.Duration) (cri.RuntimeService, error) { fakeReturns := fake.newRemoteRuntimeServiceReturns 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
func (runtime *CRIRuntime) SetImpl(impl impl) { runtime.impl = impl } // Connect establishes a connection with the CRI runtime. func (runtime *CRIRuntime) Connect() error { runtimeService, err := runtime.impl.NewRemoteRuntimeService(runtime.criSocket, defaultTimeout) if err != nil { return errors.Wrap(err, "failed to create new CRI runtime service") } runtime.runtimeService = runtimeService
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
return fmt.Errorf("Failed to start fake runtime, error: %w", err) } defer fakeRemoteRuntime.Stop() logger := klog.Background() runtimeService, err := remote.NewRemoteRuntimeService(endpoint, 15*time.Second, noop.NewTracerProvider(), &logger) if err != nil { return fmt.Errorf("Failed to init runtime 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
} func createRemoteRuntimeService(endpoint string, t *testing.T, tp oteltrace.TracerProvider) internalapi.RuntimeService { logger := klog.Background() runtimeService, err := remote.NewRemoteRuntimeService(endpoint, 15*time.Second, tp, &logger) require.NoError(t, err) return runtimeService } func TestNewMainKubeletStandAlone(t *testing.T) { tempDir, err := os.MkdirTemp("", "logs")
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
if utilfeature.DefaultFeatureGate.Enabled(features.KubeletTracing) { tp = kubeDeps.TracerProvider } logger := klog.Background() if kubeDeps.RemoteRuntimeService, err = remote.NewRemoteRuntimeService(kubeCfg.ContainerRuntimeEndpoint, kubeCfg.RuntimeRequestTimeout.Duration, tp, &logger); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)