Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newRuntimeState (0.33 sec)

  1. pkg/kubelet/runtime.go

    	s.RLock()
    	defer s.RUnlock()
    	errs := []error{}
    	if s.storageError != nil {
    		errs = append(errs, s.storageError)
    	}
    	return utilerrors.NewAggregate(errs)
    }
    
    func newRuntimeState(runtimeSyncThreshold time.Duration) *runtimeState {
    	return &runtimeState{
    		lastBaseRuntimeSync:      time.Time{},
    		baseRuntimeSyncThreshold: runtimeSyncThreshold,
    		networkError:             ErrNetworkUnknown,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. pkg/kubelet/runonce_test.go

    		reasonCache:      NewReasonCache(),
    		clock:            clock.RealClock{},
    		kubeClient:       &fake.Clientset{},
    		hostname:         testKubeletHostname,
    		nodeName:         testKubeletHostname,
    		runtimeState:     newRuntimeState(time.Second),
    		hostutil:         hostutil.NewFakeHostUtil(nil),
    	}
    	kb.containerManager = cm.NewStubContainerManager()
    
    	plug := &volumetest.FakeVolumePlugin{PluginName: "fake", Host: nil}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_test.go

    	kubelet.hostutil = hostutil.NewFakeHostUtil(nil)
    	kubelet.subpather = &subpath.FakeSubpath{}
    
    	kubelet.hostname = testKubeletHostname
    	kubelet.nodeName = types.NodeName(testKubeletHostname)
    	kubelet.runtimeState = newRuntimeState(maxWaitForContainerRuntime)
    	kubelet.runtimeState.setNetworkState(nil)
    	kubelet.rootDirectory = t.TempDir()
    	kubelet.podLogsDirectory = t.TempDir()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    			RelistThreshold: genericPlegRelistThreshold,
    		}
    		klet.pleg = pleg.NewGenericPLEG(klet.containerRuntime, eventChannel, genericRelistDuration, klet.podCache, clock.RealClock{})
    	}
    
    	klet.runtimeState = newRuntimeState(maxWaitForContainerRuntime)
    	klet.runtimeState.addHealthCheck("PLEG", klet.pleg.Healthy)
    	if utilfeature.DefaultFeatureGate.Enabled(features.EventedPLEG) {
    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