disk

package
v1.5.0-rc5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 11, 2019 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DiskBackendKey = "msg.disk.noBackEnd"
	LockedFileKey  = "msg.fileio.lock"
)
View Source 
const (
	// You can assign the device to (1:z ), where 1 is SCSI controller 1 and z is a virtual device node from 0 to 15.
	// https://pubs.vmware.com/vsphere-65/index.jsp#com.vmware.vsphere.vm_admin.doc/GUID-5872D173-A076-42FE-8D0B-9DB0EB0E7362.html
	MaxAttachedDisks = 16
)

Variables

This section is empty.

Functions

func IsLockedError 

func IsLockedError(err error) bool

IsLockedError will determine if the error received is: a. related to a vmdk b. due to the vmdk being locked It will return false in absence of confirmation, meaning incomplete vim errors will return false

func LockedDisks 

func LockedDisks(err error) []string

LockedDisks returns locked devices path in the error if it's device lock error

func LockedVMDKFilter 

func LockedVMDKFilter(vm *mo.VirtualMachine) bool

Types

type Filesystem 

type Filesystem interface {
	Mkfs(op trace.Operation, devPath, label string) error
	SetLabel(op trace.Operation, devPath, labelName string) error
	Mount(op trace.Operation, devPath, targetPath string, options []string) error
	Unmount(op trace.Operation, path string) error
}

Filesystem defines the interface for handling an attached virtual disk

type FilesystemType 

type FilesystemType uint8

FilesystemType represents the filesystem in use by a virtual disk 

const (
	// Ext4 represents the ext4 file system
	Ext4 FilesystemType = iota + 1

	// Xfs represents the XFS file system
	Xfs

	// Ntfs represents the NTFS file system
	Ntfs

	// used to isolate applications from the lost+found in the root of ext4
	VolumeDataDir = "/.vic.vol.data"
)

type InUseError 

type InUseError struct {
	// contains filtered or unexported fields
}

InUseError is returned when a detach is attempted on a disk that is still in use

type Manager 

type Manager struct {

	// map of URIs to VirtualDisk structs so that we can return the same instance to the caller, required for ref counting
	Disks map[uint64]*VirtualDisk
	// contains filtered or unexported fields
}

Manager manages disks for the vm it runs on. The expectation is this is run from a VM on a vsphere instance. This VM creates disks on ESX, attaches them to itself, writes to them, then detaches them.

func NewDiskManager 

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

NewDiskManager creates a new Manager instance associated with the caller VM

func (*Manager) AttachAndMount 

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

AttachAndMount creates and attaches a vmdk as a non-persistent disk, mounts it, and returns the mount path.

func (*Manager) Create 

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

Create creates a disk without a parent (and doesn't attach it).

func (*Manager) CreateAndAttach 

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

CreateAndAttach creates a new VMDK, attaches it and ensures that the device becomes visible to the caller. Returns a VirtualDisk corresponding to the created and attached disk.

func (*Manager) Detach 

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

Detach attempts to detach a virtual disk

func (*Manager) DetachAll 

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

func (*Manager) DiskFinder 

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

func (*Manager) DiskParent 

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

DiskParent returns the parent for an existing disk, based on the disk datastore URI in the config, and ignoring any parent specified in the config. datastore path will be nil if the disk has no parent

func (*Manager) Get 

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

Gets a disk given a datastore path URI to the vmdk

func (*Manager) InUse 

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

func (*Manager) Owners 

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

func (*Manager) UnmountAndDetach 

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

UnmountAndDetach unmounts and detaches a disk, subsequently cleaning the mount path

type Semaphore 

type Semaphore struct {
	// contains filtered or unexported fields
}

Semaphore represents the number of references to a disk

func NewSemaphore 

func NewSemaphore(r, n string) *Semaphore

NewSemaphore creates and returns a Semaphore initialized to 0

func (*Semaphore) Count 

func (r *Semaphore) Count() uint64

Count returns the current reference count

func (*Semaphore) Decrement 

func (r *Semaphore) Decrement() uint64

Decrement decreases the reference count by one

func (*Semaphore) Increment 

func (r *Semaphore) Increment() uint64

Increment increases the reference count by one

type VirtualDisk 

type VirtualDisk struct {
	*VirtualDiskConfig

	// The device node the disk is attached to
	DevicePath string
	// contains filtered or unexported fields
}

VirtualDisk represents a VMDK in the datastore, the device node it may be attached at (if it's attached), the mountpoint it is mounted at (if mounted), and other configuration.

func NewVirtualDisk 

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

NewVirtualDisk creates and returns a new VirtualDisk object associated with the given datastore formatted with the specified FilesystemType

func (*VirtualDisk) Attached 

func (d *VirtualDisk) Attached() bool

Attached returns true if this disk is attached, false otherwise

func (*VirtualDisk) AttachedByOther 

func (d *VirtualDisk) AttachedByOther() bool

AttachedByOther returns true if the attached references are > 1

func (*VirtualDisk) DiskPath 

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

DiskPath returns a URL referencing the path of the virtual disk on the datastore

func (*VirtualDisk) InUseByOther 

func (d *VirtualDisk) InUseByOther() bool

InUseByOther returns true if the disk is currently attached or mounted by someone else

func (*VirtualDisk) Mkfs 

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

Mkfs formats the disk with Filesystem and sets the disk label

func (*VirtualDisk) Mount 

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

Mount attempts to mount this disk. A NOP occurs if the disk is already mounted It returns the path at which the disk is mounted Enhancement: allow provision of mount path and refcount for: 

specific mount point and options

func (*VirtualDisk) MountPath 

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

MountPath returns the path on which the virtual disk is mounted, or an error if the disk is not mounted

func (*VirtualDisk) Mounted 

func (d *VirtualDisk) Mounted() bool

Mounted returns true if the virtual disk is mounted, false otherwise

func (*VirtualDisk) MountedByOther 

func (d *VirtualDisk) MountedByOther() bool

MountedByOther returns true if the mounted references are > 1

func (*VirtualDisk) SetLabel 

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

SetLabel sets this disk's label

func (*VirtualDisk) Unmount 

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

Unmount attempts to unmount a virtual disk

type VirtualDiskConfig 

type VirtualDiskConfig struct {
	// The URI in the datastore this disk can be found with
	DatastoreURI *object.DatastorePath

	// The URI in the datastore to the parent of this disk
	ParentDatastoreURI *object.DatastorePath

	// The size of the disk
	CapacityInKB int64

	// Underlying filesystem
	Filesystem Filesystem

	DiskMode types.VirtualDiskMode
}

func NewNonPersistentDisk 

func NewNonPersistentDisk(URI *object.DatastorePath) *VirtualDiskConfig

func NewPersistentDisk 

func NewPersistentDisk(URI *object.DatastorePath) *VirtualDiskConfig

func (*VirtualDiskConfig) Hash 

func (d *VirtualDiskConfig) Hash() uint64

func (*VirtualDiskConfig) IsPersistent 

func (d *VirtualDiskConfig) IsPersistent() bool

func (*VirtualDiskConfig) WithCapacity 

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

func (*VirtualDiskConfig) WithFilesystem 

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

func (*VirtualDiskConfig) WithParent 

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

type Vmdk 

type Vmdk struct {
	*Manager
	*datastore.Helper
	*session.Session
}

Vmdk is intended to be embedded by stores that manage VMDK-based data resources

func (*Vmdk) Mount 

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

Mount mounts the disk, returning the mount path and the function used to unmount/detaches when no longer in use

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.