- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,172 for attacher (0.12 sec)
-
pkg/apis/storage/v1beta1/zz_generated.conversion.go
} func autoConvert_v1beta1_VolumeAttachmentSpec_To_storage_VolumeAttachmentSpec(in *v1beta1.VolumeAttachmentSpec, out *storage.VolumeAttachmentSpec, s conversion.Scope) error { out.Attacher = in.Attacher if err := Convert_v1beta1_VolumeAttachmentSource_To_storage_VolumeAttachmentSource(&in.Source, &out.Source, s); err != nil { return err } out.NodeName = in.NodeName return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 04 08:51:01 UTC 2022 - 41K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
func() (bool, error) { for i, attacher := range fakePlugin.GetAttachers() { actualCallCount := attacher.GetAttachCallCount() if actualCallCount == expectedAttachCallCount { return true, nil } t.Logf( "Warning: Wrong attacher[%v].GetAttachCallCount(). Expected: <%v> Actual: <%v>. Will try next attacher.", i, expectedAttachCallCount, actualCallCount)
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/volume/util/operationexecutor/operation_generator.go
return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) } // Execute attach devicePath, attachErr := volumeAttacher.Attach( volumeToAttach.VolumeSpec, volumeToAttach.NodeName) if attachErr != nil { uncertainNode := volumeToAttach.NodeName if derr, ok := attachErr.(*volerr.DanglingAttachError); ok { uncertainNode = derr.CurrentNode }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
staging/src/k8s.io/api/storage/v1alpha1/generated.pb.go
if err != nil { return 0, err } i -= size i = encodeVarintGenerated(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 i -= len(m.Attacher) copy(dAtA[i:], m.Attacher) i = encodeVarintGenerated(dAtA, i, uint64(len(m.Attacher))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *VolumeAttachmentStatus) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 76.5K bytes - Viewed (0) -
pkg/volume/flexvolume/plugin.go
func (plugin *flexVolumeAttachablePlugin) NewAttacher() (volume.Attacher, error) { return &flexVolumeAttacher{plugin}, nil } func (plugin *flexVolumeAttachablePlugin) NewDeviceMounter() (volume.DeviceMounter, error) { return plugin.NewAttacher() } // NewDetacher is part of the volume.AttachableVolumePlugin interface. func (plugin *flexVolumeAttachablePlugin) NewDetacher() (volume.Detacher, error) { return &flexVolumeDetacher{plugin}, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
// 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 // volume that is attached. VolumeSpec *volume.Spec // NodeName is the identifier for the node that the volume is attached to. NodeName types.NodeName
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/cache/actual_state_of_world.go
// volumes that should be attached to this node. // If a pod with the same name does not exist under the specified // volume, false is returned. VolumeExistsWithSpecName(podName volumetypes.UniquePodName, volumeSpecName string) bool // VolumeExists returns true if the given volume exists in the list of // attached volumes in the cache, indicating the volume is attached to this // node.
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/attach_detach_controller.go
// to which nodes. // The data structure is populated upon successful completion of attach and // detach actions triggered by the controller and a periodic sync with // storage providers for the "true" state of the world. actualStateOfWorld cache.ActualStateOfWorld // attacherDetacher is used to start asynchronous attach and operations
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/volume/plugins.go
// to a node before mounting. type AttachableVolumePlugin interface { DeviceMountableVolumePlugin NewAttacher() (Attacher, error) NewDetacher() (Detacher, error) // CanAttach tests if provided volume spec is attachable CanAttach(spec *Spec) (bool, error) } // DeviceMountableVolumePlugin is an extended interface of VolumePlugin and is used
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
var _ volume.DeviceMountableVolumePlugin = &csiPlugin{} func (p *csiPlugin) NewAttacher() (volume.Attacher, error) { return p.newAttacherDetacher() } func (p *csiPlugin) NewDeviceMounter() (volume.DeviceMounter, error) { return p.NewAttacher() } func (p *csiPlugin) NewDetacher() (volume.Detacher, error) { return p.newAttacherDetacher() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0)