- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 320 for volumeNames (0.17 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
n = types.NodeName("operation-nodename") } volumeNames = append(volumeNames, v) podNames = append(podNames, p) nodeNames = append(nodeNames, n) } t.Run(fmt.Sprintf("Test %d", test.testID), func(t *testing.T) { if test.expectPass { testConcurrentOperationsPositive(t, volumeNames[0], podNames[0], nodeNames[0], volumeNames[1], podNames[1], nodeNames[1], ) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
asw.attachedVolumes[volumeName] = volumeObj if isAttached { asw.addVolumeToReportAsAttached(logger, volumeName, nodeName) } return volumeName, nil } func (asw *actualStateOfWorld) SetVolumesMountedByNode( logger klog.Logger, volumeNames []v1.UniqueVolumeName, nodeName types.NodeName) { asw.Lock() defer asw.Unlock() asw.inUseVolumes[nodeName] = sets.New(volumeNames...)
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/kubelet/eviction/helpers.go
func podLocalVolumeUsage(volumeNames []string, podStats statsapi.PodStats) v1.ResourceList { disk := resource.Quantity{Format: resource.BinarySI} inodes := resource.Quantity{Format: resource.DecimalSI} for _, volumeName := range volumeNames { for _, volumeStats := range podStats.VolumeStats { if volumeStats.Name == volumeName { disk.Add(*diskUsage(&volumeStats.FsStats))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
} } func makeFakeVolumeStats(volumeNames []string) []statsapi.VolumeStats { volumes := make([]statsapi.VolumeStats, len(volumeNames)) availableBytes := rand.Uint64() capacityBytes := rand.Uint64() usedBytes := rand.Uint64() / 100 inodes := rand.Uint64() inodesFree := rand.Uint64() inodesUsed := rand.Uint64() / 100 for i, name := range volumeNames { fsStats := statsapi.FsStats{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
"volumeName", attachedVolume.VolumeName) } else { metrics.RecordForcedDetachMetric(metrics.ForceDetachReasonOutOfService) logger.Info("attacherDetacher.DetachVolume started: node has out-of-service taint, force detaching", "node", klog.KRef("", string(attachedVolume.NodeName)), "volumeName", attachedVolume.VolumeName) } } } if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater_test.go
} volumeName1 := corev1.UniqueVolumeName("volume-name-1") volumeName2 := corev1.UniqueVolumeName("volume-name-2") volumeSpec1 := controllervolumetesting.GetTestVolumeSpec(string(volumeName1), volumeName1) volumeSpec2 := controllervolumetesting.GetTestVolumeSpec(string(volumeName2), volumeName2) nodeName1 := types.NodeName("testnode-1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 8.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
assert.NoError(t, asw.AddAttachUncertainReconstructedVolume(volumeName2, volumeSpec2, nodeName, "")) assert.NoError(t, asw.MarkDeviceAsUncertain(volumeName2, "/dev/reconstructed", "/var/lib/kubelet/plugins/global2", "")) assert.False(t, reconciler.StatesHasBeenSynced()) reconciler.volumesNeedUpdateFromNodeStatus = append(reconciler.volumesNeedUpdateFromNodeStatus, volumeName1, volumeName2) // Act - run reconcile loop just once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
podName := "pod-uid" volumeName := v1.UniqueVolumeName("volume-name") volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName) nodeName := k8stypes.NodeName("node-name") dsw.AddNode(nodeName) volumeExists := dsw.VolumeExists(volumeName, nodeName) if volumeExists { t.Fatalf( "Volume %q/node %q should not exist, but it does.", volumeName, nodeName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
newPod1 := controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1") attachDetachRecoveryTestCase(t, []*v1.Pod{newPod1}, []*v1.Pod{}) newPod1 = controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1") attachDetachRecoveryTestCase(t, []*v1.Pod{}, []*v1.Pod{newPod1}) newPod1 = controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1")
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/cache/actual_state_of_world.go
type volumeNotAttachedError struct { volumeName v1.UniqueVolumeName } func (err volumeNotAttachedError) Error() string { return fmt.Sprintf( "volumeName %q does not exist in the list of attached volumes", err.volumeName) } func newVolumeNotAttachedError(volumeName v1.UniqueVolumeName) error { return volumeNotAttachedError{ volumeName: volumeName, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0)