- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for AttachedVolume (0.18 sec)
-
staging/src/k8s.io/client-go/applyconfigurations/core/v1/attachedvolume.go
// with apply. type AttachedVolumeApplyConfiguration struct { Name *v1.UniqueVolumeName `json:"name,omitempty"` DevicePath *string `json:"devicePath,omitempty"` } // AttachedVolumeApplyConfiguration constructs an declarative configuration of the AttachedVolume type for use with // apply. func AttachedVolume() *AttachedVolumeApplyConfiguration {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world.go
func (asw *actualStateOfWorld) getAttachedVolume( attachedVolume *attachedVolume, nodeAttachedTo *nodeAttachedTo) AttachedVolume { return AttachedVolume{ AttachedVolume: operationexecutor.AttachedVolume{ VolumeName: attachedVolume.volumeName, VolumeSpec: attachedVolume.spec, NodeName: nodeAttachedTo.nodeName, DevicePath: attachedVolume.devicePath, PluginIsAttachable: true, },
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/controller/volume/attachdetach/reconciler/reconciler.go
if hasOutOfServiceTaint { logger.V(4).Info("node has out-of-service taint", "node", klog.KRef("", string(attachedVolume.NodeName))) } verifySafeToDetach := !(forceDetatchTimeoutExpired || hasOutOfServiceTaint) err = rc.attacherDetacher.DetachVolume(logger, attachedVolume.AttachedVolume, verifySafeToDetach, rc.actualStateOfWorld)
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/kubelet/volumemanager/reconciler/reconciler_common.go
klog.InfoS(attachedVolume.GenerateMsgDetailed("Volume detached", fmt.Sprintf("DevicePath %q", attachedVolume.DevicePath))) } else { // Only detach if kubelet detach is enabled klog.V(5).InfoS(attachedVolume.GenerateMsgDetailed("Starting operationExecutor.DetachVolume", "")) err := rc.operationExecutor.DetachVolume(
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/volumemanager/cache/actual_state_of_world.go
attachedVolume *attachedVolume) AttachedVolume { seLinuxMountContext := "" if utilfeature.DefaultFeatureGate.Enabled(features.SELinuxMountReadWriteOncePod) { if attachedVolume.seLinuxMountContext != nil { seLinuxMountContext = *attachedVolume.seLinuxMountContext } } return AttachedVolume{ AttachedVolume: operationexecutor.AttachedVolume{
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/volume/util/operationexecutor/fakegenerator.go
} func (f *fakeOGCounter) GenerateDetachVolumeFunc(logger klog.Logger, volumeToDetach AttachedVolume, verifySafeToDetach bool, actualStateOfWorld ActualStateOfWorldAttacherUpdater) (volumetypes.GeneratedOperations, error) { return f.recordFuncCall("GenerateDetachVolumeFunc"), nil }
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/volume/util/operationexecutor/operation_executor_test.go
t.Parallel() // Arrange ch, quit, oe := setup() attachedVolumes := make([]AttachedVolume, numDevicesToUnmount) pdName := "pd-volume" // Act for i := range attachedVolumes { attachedVolumes[i] = AttachedVolume{ VolumeName: v1.UniqueVolumeName(pdName), NodeName: "node-name", }
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/reconciler/reconstruct.go
attachable := false for _, attachedVolume := range node.Status.VolumesAttached { 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) }
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/volume/util/operationexecutor/operation_executor.go
simpleMsg, detailedMsg := volume.GenerateMsg(prefixMsg, errSuffix(err)) return fmt.Errorf(simpleMsg), fmt.Errorf(detailedMsg) } // AttachedVolume represents a volume that is attached to a node. type AttachedVolume struct { // VolumeName is the unique identifier for the volume that is attached. VolumeName v1.UniqueVolumeName // VolumeSpec is the volume spec containing the specification for the
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/reconciler_test.go
Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } func createTestClient(attachedVolumes ...v1.AttachedVolume) *fake.Clientset { fakeClient := &fake.Clientset{} if len(attachedVolumes) == 0 { attachedVolumes = append(attachedVolumes, v1.AttachedVolume{ Name: "fake-plugin/fake-device1", DevicePath: "fake/path", }) } fakeClient.AddReactor("get", "nodes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0)