- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for actualStateOfWorld (0.32 sec)
-
pkg/kubelet/pluginmanager/cache/actual_state_of_world.go
PluginExistsWithCorrectTimestamp(pluginInfo PluginInfo) bool } // NewActualStateOfWorld returns a new instance of ActualStateOfWorld func NewActualStateOfWorld() ActualStateOfWorld { return &actualStateOfWorld{ socketFileToInfo: make(map[string]PluginInfo), } } type actualStateOfWorld struct { // socketFileToInfo is a map containing the set of successfully registered plugins
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 24 21:20:24 UTC 2022 - 4.1K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/fakegenerator.go
} func (f *fakeOGCounter) GenerateUnmountVolumeFunc(volumeToUnmount MountedVolume, actualStateOfWorld ActualStateOfWorldMounterUpdater, podsDir string) (volumetypes.GeneratedOperations, error) { return f.recordFuncCall("GenerateUnmountVolumeFunc"), nil } func (f *fakeOGCounter) GenerateAttachVolumeFunc(logger klog.Logger, volumeToAttach VolumeToAttach, actualStateOfWorld ActualStateOfWorldAttacherUpdater) volumetypes.GeneratedOperations {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
// contains kubelet volume manager specific state. type ActualStateOfWorld interface { // ActualStateOfWorld must implement the methods required to allow // operationexecutor to interact with it. operationexecutor.ActualStateOfWorldMounterUpdater // ActualStateOfWorld must implement the methods required to allow // operationexecutor to interact with it. operationexecutor.ActualStateOfWorldAttacherUpdater
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
func (s AttachState) String() string { return []string{"Attached", "Uncertain", "Detached"}[s] } // NewActualStateOfWorld returns a new instance of ActualStateOfWorld. func NewActualStateOfWorld(volumePluginMgr *volume.VolumePluginMgr) ActualStateOfWorld { return &actualStateOfWorld{ attachedVolumes: make(map[v1.UniqueVolumeName]attachedVolume), nodesToUpdateStatusFor: make(map[types.NodeName]nodeToUpdateStatusFor),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
// Along with volumeToMount and actualStateOfWorld, the function expects current size of volume on the node as an argument. The current // size here always refers to capacity last recorded in actualStateOfWorld from pvc.Status.Capacity
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager.go
// reconciler runs an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering register // and unregister operations using the operationExecutor. reconciler reconciler.Reconciler // actualStateOfWorld is a data structure containing the actual state of // the world according to the manager: i.e. which plugins are registered.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
tests := []struct { name string opCallback func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error verifyCallback func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error }{ { name: "marking volume mounted should remove volume from found during reconstruction", opCallback: func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
nodeLister corelisters.NodeLister, actualStateOfWorld cache.ActualStateOfWorld) NodeStatusUpdater { return &nodeStatusUpdater{ actualStateOfWorld: actualStateOfWorld, nodeLister: nodeLister, kubeClient: kubeClient, } } type nodeStatusUpdater struct { kubeClient clientset.Interface nodeLister corelisters.NodeLister actualStateOfWorld cache.ActualStateOfWorld }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler.go
desiredStateOfWorld: desiredStateOfWorld, actualStateOfWorld: actualStateOfWorld, handlers: make(map[string]cache.PluginHandler), } } type reconciler struct { operationExecutor operationexecutor.OperationExecutor loopSleepDuration time.Duration desiredStateOfWorld cache.DesiredStateOfWorld actualStateOfWorld cache.ActualStateOfWorld handlers map[string]cache.PluginHandler
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
continue } } // Because the detach operation updates the ActualStateOfWorld before // marking itself complete, it's possible for the volume to be removed // from the ActualStateOfWorld between the GetAttachedVolumes() check // and the IsOperationSafeToRetry() check above. // Check the ActualStateOfWorld again to avoid issuing an unnecessary // detach.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0)