Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 680 for attacher (0.96 sec)

  1. pkg/volume/csi/csi_attacher.go

    			klog.Error(log("attacher.VolumesAreAttached failed for attach.ID=%v: %v", attachID, err))
    			continue
    		}
    		klog.V(4).Info(log("attacher.VolumesAreAttached attachment [%v] has status.attached=%t", attachID, attach.Status.Attached))
    		attached[spec] = attach.Status.Attached
    	}
    
    	return attached, nil
    }
    
    func (c *csiAttacher) GetDeviceMountPath(spec *volume.Spec) (string, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 03 07:38:14 UTC 2023
    - 25.9K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_attacher_test.go

    				if attached.attached && !ok {
    					t.Error("failed to retrieve attached status for:", attached.spec)
    				}
    				if attached.attached != stat {
    					t.Errorf("expecting volume attachment %t, got %t", attached.attached, stat)
    				}
    			}
    		})
    	}
    }
    
    func TestAttacherVolumesAreAttachedWithInline(t *testing.T) {
    	type attachedSpec struct {
    		volName  string
    		spec     *volume.Spec
    		attached bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 58.1K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/testing/testvolumespec.go

    	}}
    }
    
    // Attacher
    type testPluginAttacher struct {
    	ErrorEncountered  *bool
    	attachedVolumeMap map[string][]string
    	pluginLock        *sync.RWMutex
    }
    
    func (attacher *testPluginAttacher) Attach(spec *volume.Spec, nodeName types.NodeName) (string, error) {
    	attacher.pluginLock.Lock()
    	defer attacher.pluginLock.Unlock()
    	if spec == nil {
    		*attacher.ErrorEncountered = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 17 08:48:30 UTC 2023
    - 16.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/storage/v1alpha1/types_swagger_doc_generated.go

    	"attached":           "attached indicates the volume is successfully attached. This field must only be set by the entity completing the attach operation, i.e. the external-attacher.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 03:26:35 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/storage/v1alpha1/generated.proto

    message VolumeAttachmentStatus {
      // attached indicates the volume is successfully attached.
      // This field must only be set by the entity completing the attach
      // operation, i.e. the external-attacher.
      optional bool attached = 1;
    
      // attachmentMetadata is populated with any
      // information returned by the attach operation, upon successful attach, that must be passed
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/storage/v1alpha1/types.go

    type VolumeAttachmentStatus struct {
    	// attached indicates the volume is successfully attached.
    	// This field must only be set by the entity completing the attach
    	// operation, i.e. the external-attacher.
    	Attached bool `json:"attached" protobuf:"varint,1,opt,name=attached"`
    
    	// attachmentMetadata is populated with any
    	// information returned by the attach operation, upon successful attach, that must be passed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 27 20:06:32 UTC 2023
    - 13.4K bytes
    - Viewed (0)
  7. pkg/apis/storage/validation/validation_test.go

    		Spec: storage.VolumeAttachmentSpec{
    			Attacher: "myattacher",
    			Source: storage.VolumeAttachmentSource{
    				PersistentVolumeName: &volumeName,
    			},
    			NodeName: "mynode",
    		},
    	}, {
    		ObjectMeta: metav1.ObjectMeta{Name: "foo-with-inlinespec"},
    		Spec: storage.VolumeAttachmentSpec{
    			Attacher: "myattacher",
    			Source: storage.VolumeAttachmentSource{
    				InlineVolumeSpec: &inlineSpec,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 69.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/storage/v1alpha1/generated.proto

    message VolumeAttachmentStatus {
      // attached indicates the volume is successfully attached.
      // This field must only be set by the entity completing the attach
      // operation, i.e. the external-attacher.
      optional bool attached = 1;
    
      // attachmentMetadata is populated with any
      // information returned by the attach operation, upon successful attach, that must be passed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. pkg/volume/volume.go

    	// error would confuse users.
    	Delete() error
    }
    
    // Attacher can attach a volume to a node.
    type Attacher interface {
    	DeviceMounter
    
    	// Attaches the volume specified by the given spec to the node with the given Name.
    	// On success, returns the device path where the device was attached on the
    	// node.
    	Attach(spec *Spec, nodeName types.NodeName) (string, error)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. pkg/volume/testing/testing.go

    // have a zero WaitForAttachCallCount. Otherwise it returns an error.
    func VerifyZeroWaitForAttachCallCount(fakeVolumePlugin *FakeVolumePlugin) error {
    	for _, attacher := range fakeVolumePlugin.GetAttachers() {
    		actualCallCount := attacher.GetWaitForAttachCallCount()
    		if actualCallCount != 0 {
    			return fmt.Errorf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
Back to top