Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newRuntimeState (0.17 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)
Back to top