- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 35 for ActualStateOfworld (0.29 sec)
-
pkg/volume/util/operationexecutor/operation_executor_test.go
} return volumetypes.GeneratedOperations{ OperationFunc: opFunc, } } func (fopg *fakeOperationGenerator) GenerateUnmountVolumeFunc(volumeToUnmount MountedVolume, actualStateOfWorld ActualStateOfWorldMounterUpdater, podsDir string) (volumetypes.GeneratedOperations, error) { opFunc := func() volumetypes.OperationContext { startOperationAndBlock(fopg.ch, fopg.quit)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics_test.go
mapper, err := fakePlugin.NewBlockVolumeMapper(volumeSpec, pod, volume.VolumeOptions{}) if err != nil { t.Fatalf("NewBlockVolumeMapper failed. Expected: <no error> Actual: <%v>", err) } // Add one volume to ActualStateOfWorld devicePath := "fake/device/path" logger, _ := ktesting.NewTestContext(t) err = asw.MarkVolumeAsAttached(logger, "", volumeSpec, "", devicePath) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics.go
// Register registers metrics in A/D Controller. func Register(pvcLister corelisters.PersistentVolumeClaimLister, pvLister corelisters.PersistentVolumeLister, podLister corelisters.PodLister, asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld, pluginMgr *volume.VolumePluginMgr, csiMigratedPluginManager csimigration.PluginManager, intreeToCSITranslator csimigration.InTreeToCSITranslator) { registerMetrics.Do(func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 10 06:30:05 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics.go
count, ok := v[state] if !ok { count = map[string]int64{} } count[plugin]++ v[state] = count } // Register registers Volume Manager metrics. func Register(asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld, pluginMgr *volume.VolumePluginMgr) { registerMetrics.Do(func() { legacyregistry.CustomMustRegister(&totalVolumesCollector{asw: asw, dsw: dsw, pluginMgr: pluginMgr})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 06 16:48:59 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
allAttachedVolumes := map[v1.UniqueVolumeName]cache.AttachedVolume{} for _, v := range adc.actualStateOfWorld.GetAttachedVolumesForNode(nodeName) { allAttachedVolumes[v.VolumeName] = v } for _, attachedVolume := range node.Status.VolumesAttached { attachedState := adc.actualStateOfWorld.GetAttachState(attachedVolume.Name, nodeName) if attachedState != cache.AttachStateAttached {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
dsw cache.DesiredStateOfWorld, asw cache.ActualStateOfWorld, newSize resource.Quantity) []v1.UniqueVolumeName { dswp.ReprocessPod(uniquePodName) dswp.findAndAddNewPods() return getResizeRequiredVolumes(dsw, asw, newSize) } func getResizeRequiredVolumes(dsw cache.DesiredStateOfWorld, asw cache.ActualStateOfWorld, newSize resource.Quantity) []v1.UniqueVolumeName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/node_expander_test.go
} resizeOp := nodeResizeOperationOpts{ pvc: pvc, pv: pv, volumePlugin: fakePlugin, vmt: vmt, actualStateOfWorld: nil, pluginResizeOpts: volume.NodeResizeOptions{ VolumeSpec: vmt.VolumeSpec, NewSize: *desiredSize, OldSize: *actualSize, }, } ogInstance, _ := og.(*operationGenerator)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
} func runReconciler(reconciler Reconciler) { go reconciler.Run(wait.NeverStop) } func waitForRegistration( t *testing.T, socketPath string, previousTimestamp time.Time, asw cache.ActualStateOfWorld) { err := retryWithExponentialBackOff( time.Duration(500*time.Millisecond), func() (bool, error) { registeredPlugins := asw.GetRegisteredPlugins() for _, plugin := range registeredPlugins {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
} } } }) } } } func waitForUncertainGlobalMount(t *testing.T, volumeName v1.UniqueVolumeName, asw cache.ActualStateOfWorld) { // check if volume is globally mounted in uncertain state err := retryWithExponentialBackOff( testOperationBackOffDuration, func() (bool, error) { unmountedVolumes := asw.GetUnmountedVolumes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0)