Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewFakeRuntimeService (0.31 sec)

  1. pkg/kubelet/logs/container_log_manager_test.go

    	dir, err := os.MkdirTemp("", "test-rotate-logs")
    	require.NoError(t, err)
    	defer os.RemoveAll(dir)
    
    	const (
    		testMaxFiles = 3
    		testMaxSize  = 10
    	)
    	now := time.Now()
    	f := critest.NewFakeRuntimeService()
    	c := &containerLogManager{
    		runtimeService: f,
    		policy: LogRotatePolicy{
    			MaxSize:  testMaxSize,
    			MaxFiles: testMaxFiles,
    		},
    		osInterface: container.RealOS{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. pkg/kubelet/pleg/evented_test.go

    	return &EventedPLEG{
    		runtime:        &containertest.FakeRuntime{},
    		clock:          testingclock.NewFakeClock(time.Time{}),
    		cache:          kubecontainer.NewCache(),
    		runtimeService: critest.NewFakeRuntimeService(),
    		eventChannel:   make(chan *PodLifecycleEvent, 100),
    	}
    }
    
    func TestHealthyEventedPLEG(t *testing.T) {
    	metrics.Register()
    	pleg := newTestEventedPLEG()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 01 07:45:05 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  3. pkg/kubelet/stats/cri_stats_provider_test.go

    		mockRuntimeCache   = new(kubecontainertest.MockRuntimeCache)
    		mockPodManager     = new(kubepodtest.MockManager)
    		resourceAnalyzer   = new(fakeResourceAnalyzer)
    		fakeRuntimeService = critest.NewFakeRuntimeService()
    		fakeImageService   = critest.NewFakeImageService()
    	)
    
    	infos := map[string]cadvisorapiv2.ContainerInfo{
    		"/":                           getTestContainerInfo(seedRoot, "", "", ""),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 54.5K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    }
    
    func customTestRuntimeManager(keyring *credentialprovider.BasicDockerKeyring) (*apitest.FakeRuntimeService, *apitest.FakeImageService, *kubeGenericRuntimeManager, error) {
    	fakeRuntimeService := apitest.NewFakeRuntimeService()
    	fakeImageService := apitest.NewFakeImageService()
    	// Only an empty machineInfo is needed here, because in unit test all containers are besteffort,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
Back to top