Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewRemoteRuntimeService (0.34 sec)

  1. 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)
  2. 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)
Back to top