- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for AllReady (0.2 sec)
-
pkg/kubelet/config/sources.go
type SourcesReady interface { // AddSource adds the specified source to the set of sources managed. AddSource(source string) // AllReady returns true if the currently configured sources have all been seen. AllReady() bool } // NewSourcesReady returns a SourcesReady with the specified function. func NewSourcesReady(sourcesReadyFn SourcesReadyFn) SourcesReady { return &sourcesImpl{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_ready_provider.go
) // FakeReadyProvider implements a fake ready provider type FakeReadyProvider struct { kubecontainer.SourcesReadyProvider } // AllReady notifies caller that the Fake Provider is ready. func (frp *FakeReadyProvider) AllReady() bool { return true } // NewFakeReadyProvider creates a FakeReadyProvider object func NewFakeReadyProvider() kubecontainer.SourcesReadyProvider {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 1K bytes - Viewed (0) -
pkg/kubelet/container/container_gc.go
} // SourcesReadyProvider knows how to determine if configuration sources are ready type SourcesReadyProvider interface { // AllReady returns true if the currently configured sources have all been seen. AllReady() bool } // TODO(vmarmol): Preferentially remove pod infra containers. type realContainerGC struct { // Container runtime runtime Runtime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
pendingAdmissionPod *v1.Pod } var _ Manager = &manager{} type sourcesReadyStub struct{} func (s *sourcesReadyStub) AddSource(source string) {} func (s *sourcesReadyStub) AllReady() bool { return true } // NewManager creates new cpu manager based on provided policy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
} type sourcesReadyStub struct{} func (s *sourcesReadyStub) AddSource(source string) {} func (s *sourcesReadyStub) AllReady() bool { return true } // Manager interface provides methods for Kubelet to manage pod memory. type Manager interface { // Start is called during Kubelet initialization.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/devicemanager/manager.go
// PodReusableDevices is a map by pod name of devices to reuse. type PodReusableDevices map[string]map[string]sets.Set[string] func (s *sourcesReadyStub) AddSource(source string) {} func (s *sourcesReadyStub) AllReady() bool { return true } // NewManagerImpl creates a new manager. func NewManagerImpl(topology []cadvisorapi.Node, topologyAffinityStore topologymanager.Store) (*ManagerImpl, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
// Only once all sources are ready do we attempt to reconcile. // This ensures that the call to m.activePods() below will succeed with // the actual active pods list. if m.sourcesReady == nil || !m.sourcesReady.AllReady() { return } // Get the full list of active pods. activePods := sets.New[string]() for _, p := range m.activePods() { activePods.Insert(string(p.UID)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
klog.InfoS("Desired state populator starts to run") wait.PollUntil(dswp.loopSleepDuration, func() (bool, error) { done := sourcesReady.AllReady() dswp.populatorLoop() return done, nil }, stopCh) dswp.hasAddedPodsLock.Lock() if !dswp.hasAddedPods { klog.InfoS("Finished populating initial desired state of world") dswp.hasAddedPods = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// found in the runtime cache. func (kl *Kubelet) deletePod(pod *v1.Pod) error { if pod == nil { return fmt.Errorf("deletePod does not allow nil pod") } if !kl.sourcesReady.AllReady() { // If the sources aren't ready, skip deletion, as we may accidentally delete pods // for sources that haven't reported yet. return fmt.Errorf("skipping delete because sources aren't ready yet") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)