- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for ActualStateOfworld (0.21 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
controllerAttachDetachEnabled bool, loopSleepDuration time.Duration, waitForAttachTimeout time.Duration, nodeName types.NodeName, desiredStateOfWorld cache.DesiredStateOfWorld, actualStateOfWorld cache.ActualStateOfWorld, populatorHasAddedPods func() bool, operationExecutor operationexecutor.OperationExecutor, mounter mount.Interface, hostutil hostutil.HostUtils, volumePluginMgr *volumepkg.VolumePluginMgr,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_executor.go
// behavior. // // Once an operation completes successfully, the actualStateOfWorld is updated // to indicate the plugin is registered/unregistered. // // Once the operation is started, since it is executed asynchronously, // errors are simply logged and the goroutine is terminated without updating // actualStateOfWorld. type OperationExecutor interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
vm.desiredStateOfWorld, vm.actualStateOfWorld, kubeContainerRuntime, csiMigratedPluginManager, intreeToCSITranslator, volumePluginMgr) vm.reconciler = reconciler.NewReconciler( kubeClient, controllerAttachDetachEnabled, reconcilerLoopSleepPeriod, waitForAttachTimeout, nodeName, vm.desiredStateOfWorld, vm.actualStateOfWorld, vm.desiredStateOfWorldPopulator.HasAddedPods,
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/volume/util/operationexecutor/operation_executor.go
// VerifyVolumesAreAttached verifies volumes being used in entire cluster and if they are still attached to the node // If any volume is not attached right now, it will update actual state of world to reflect that. VerifyVolumesAreAttached(volumesToVerify map[types.NodeName][]AttachedVolume, actualStateOfWorld ActualStateOfWorldAttacherUpdater)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
verifyFunc: func(rcInstance *reconciler, fakePlugin *volumetesting.FakeVolumePlugin) error { mountedPods := rcInstance.actualStateOfWorld.GetMountedVolumes() if len(mountedPods) != 0 { return fmt.Errorf("expected 0 certain pods in asw got %d", len(mountedPods)) } allPods := rcInstance.actualStateOfWorld.GetAllMountedVolumes() if len(allPods) != 2 { return fmt.Errorf("expected 2 uncertain pods in asw got %d", len(allPods))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
kubeClient clientset.Interface, loopSleepDuration time.Duration, podManager PodManager, podStateProvider PodStateProvider, desiredStateOfWorld cache.DesiredStateOfWorld, actualStateOfWorld cache.ActualStateOfWorld, kubeContainerRuntime kubecontainer.Runtime, csiMigratedPluginManager csimigration.PluginManager, intreeToCSITranslator csimigration.InTreeToCSITranslator,
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/controller/volume/attachdetach/attach_detach_controller.go
// storage providers for the "true" state of the world. actualStateOfWorld cache.ActualStateOfWorld // attacherDetacher is used to start asynchronous attach and operations attacherDetacher operationexecutor.OperationExecutor // reconciler is used to run an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering attach // detach operations using the attacherDetacher.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
if volumeID != attachedVolume.Name { continue } rc.actualStateOfWorld.UpdateReconstructedDevicePath(volumeID, attachedVolume.DevicePath) attachable = true klog.V(4).InfoS("Updated devicePath from node status for volume", "volumeName", attachedVolume.Name, "path", attachedVolume.DevicePath) } rc.actualStateOfWorld.UpdateReconstructedVolumeAttachability(volumeID, attachable) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/metrics/metrics_test.go
// Add one plugin to DesiredStateOfWorld err := dsw.AddOrUpdatePlugin(fakePlugin.SocketPath) if err != nil { t.Fatalf("AddOrUpdatePlugin failed. Expected: <no error> Actual: <%v>", err) } // Add one plugin to ActualStateOfWorld err = asw.AddPlugin(fakePlugin) if err != nil { t.Fatalf("AddOrUpdatePlugin failed. Expected: <no error> Actual: <%v>", err) } metricCollector := &totalPluginsCollector{asw: asw, dsw: dsw}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 12:48:20 UTC 2019 - 2.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/metrics/metrics.go
} // Register registers Plugin Manager metrics. func Register(asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld) { registerMetrics.Do(func() { legacyregistry.CustomMustRegister(&totalPluginsCollector{asw: asw, dsw: dsw}) }) } type totalPluginsCollector struct { metrics.BaseStableCollector asw cache.ActualStateOfWorld dsw cache.DesiredStateOfWorld }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 08 01:16:57 UTC 2019 - 2.7K bytes - Viewed (0)