- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ReconcilerStatesHasBeenSynced (0.49 sec)
-
pkg/kubelet/volumemanager/volume_manager_fake.go
inuse := []v1.UniqueVolumeName{} for v := range f.volumes { inuse = append(inuse, v) } return inuse } // ReconcilerStatesHasBeenSynced is not implemented func (f *FakeVolumeManager) ReconcilerStatesHasBeenSynced() bool { return true } // VolumeIsAttached is not implemented func (f *FakeVolumeManager) VolumeIsAttached(volumeName v1.UniqueVolumeName) bool { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
GetVolumesInUse() []v1.UniqueVolumeName // ReconcilerStatesHasBeenSynced returns true only after the actual states in reconciler // has been synced at least once after kubelet starts so that it is safe to update mounted // volume list retrieved from actual state. ReconcilerStatesHasBeenSynced() bool // VolumeIsAttached returns true if the given volume is attached to this // node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
} return nil } } // VolumesInUse returns a Setter that updates the volumes in use on the node. func VolumesInUse(syncedFunc func() bool, // typically Kubelet.volumeManager.ReconcilerStatesHasBeenSynced volumesInUseFunc func() []v1.UniqueVolumeName, // typically Kubelet.volumeManager.GetVolumesInUse ) Setter { return func(ctx context.Context, node *v1.Node) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
kl.containerManager.Status, kl.shutdownManager.ShutdownStatus, kl.recordNodeStatusEvent, kl.supportLocalStorageCapacityIsolation()), nodestatus.VolumesInUse(kl.volumeManager.ReconcilerStatesHasBeenSynced, kl.volumeManager.GetVolumesInUse), // TODO(mtaufen): I decided not to move this setter for now, since all it does is send an event
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
kubelet.volumeManager = fakeVolumeManager // Only test VolumesInUse setter kubelet.setNodeStatusFuncs = []func(context.Context, *v1.Node) error{ nodestatus.VolumesInUse(kubelet.volumeManager.ReconcilerStatesHasBeenSynced, kubelet.volumeManager.GetVolumesInUse), } kubeClient := testKubelet.fakeKubeClient
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0)