disk

May 4, 2018

Changes in this version

+ const DiskBackendKey

+ const LockedFileKey

+ const MaxAttachedDisks

+ func IsLockedError(err error) bool

+ func LockedDisks(err error) []string

+ func LockedVMDKFilter(vm *mo.VirtualMachine) bool

+ type Filesystem interface

+ Mkfs func(op trace.Operation, devPath, label string) error

+ Mount func(op trace.Operation, devPath, targetPath string, options []string) error

+ SetLabel func(op trace.Operation, devPath, labelName string) error

+ Unmount func(op trace.Operation, path string) error

+ type FilesystemType uint8

+ const Ext4

+ const Ntfs

+ const VolumeDataDir

+ const Xfs

+ type InUseError struct

+ type Manager struct

+ Disks map[uint64]*VirtualDisk

+ func NewDiskManager(op trace.Operation, session *session.Session, v *view.ContainerView) (*Manager, error)

+ func (m *Manager) AttachAndMount(op trace.Operation, datastoreURI *object.DatastorePath, persistent bool) (string, error)

+ func (m *Manager) Create(op trace.Operation, config *VirtualDiskConfig) (*VirtualDisk, error)

+ func (m *Manager) CreateAndAttach(op trace.Operation, config *VirtualDiskConfig) (*VirtualDisk, error)

+ func (m *Manager) Detach(op trace.Operation, config *VirtualDiskConfig) error

+ func (m *Manager) DetachAll(op trace.Operation) error

+ func (m *Manager) DiskFinder(op trace.Operation, filter func(p string) bool) (string, error)

+ func (m *Manager) DiskParent(op trace.Operation, config *VirtualDiskConfig) (*object.DatastorePath, error)

+ func (m *Manager) Get(op trace.Operation, config *VirtualDiskConfig) (*VirtualDisk, error)

+ func (m *Manager) InUse(op trace.Operation, config *VirtualDiskConfig, ...) ([]*vm.VirtualMachine, error)

+ func (m *Manager) Owners(op trace.Operation, url *url.URL, filter func(vm *mo.VirtualMachine) bool) ([]*vm.VirtualMachine, error)

+ func (m *Manager) UnmountAndDetach(op trace.Operation, datastoreURI *object.DatastorePath, persistent bool) error

+ type Semaphore struct

+ func NewSemaphore(r, n string) *Semaphore

+ func (r *Semaphore) Count() uint64

+ func (r *Semaphore) Decrement() uint64

+ func (r *Semaphore) Increment() uint64

+ type VirtualDisk struct

+ DevicePath string

+ func NewVirtualDisk(op trace.Operation, config *VirtualDiskConfig, disks map[uint64]*VirtualDisk) (*VirtualDisk, error)

+ func (d *VirtualDisk) Attached() bool

+ func (d *VirtualDisk) AttachedByOther() bool

+ func (d *VirtualDisk) DiskPath() url.URL

+ func (d *VirtualDisk) InUseByOther() bool

+ func (d *VirtualDisk) Mkfs(op trace.Operation, labelName string) error

+ func (d *VirtualDisk) Mount(op trace.Operation, options []string) (string, error)

+ func (d *VirtualDisk) MountPath() (string, error)

+ func (d *VirtualDisk) Mounted() bool

+ func (d *VirtualDisk) MountedByOther() bool

+ func (d *VirtualDisk) SetLabel(op trace.Operation, labelName string) error

+ func (d *VirtualDisk) Unmount(op trace.Operation) error

+ type VirtualDiskConfig struct

+ CapacityInKB int64

+ DatastoreURI *object.DatastorePath

+ DiskMode types.VirtualDiskMode

+ Filesystem Filesystem

+ ParentDatastoreURI *object.DatastorePath

+ func NewNonPersistentDisk(URI *object.DatastorePath) *VirtualDiskConfig

+ func NewPersistentDisk(URI *object.DatastorePath) *VirtualDiskConfig

+ func (d *VirtualDiskConfig) Hash() uint64

+ func (d *VirtualDiskConfig) IsPersistent() bool

+ func (d *VirtualDiskConfig) WithCapacity(capacity int64) *VirtualDiskConfig

+ func (d *VirtualDiskConfig) WithFilesystem(ftype FilesystemType) *VirtualDiskConfig

+ func (d *VirtualDiskConfig) WithParent(parent *object.DatastorePath) *VirtualDiskConfig

+ type Vmdk struct

+ func (v *Vmdk) Mount(op trace.Operation, uri *url.URL, persistent bool) (string, func(), error)