kubernetes/vendor/github.com/libopenstorage/openstorage/api/client/volume/client.go

const graphPath …

const volumePath …

const snapPath …

type volumeClient …

func newVolumeClient(c *client.Client) volume.VolumeDriver { … }

// String description of this driver.
func (v *volumeClient) Name() string { … }

func (v *volumeClient) Type() api.DriverType { … }

func (v *volumeClient) GraphDriverCreate(id string, parent string) error { … }

func (v *volumeClient) GraphDriverRemove(id string) error { … }

func (v *volumeClient) GraphDriverGet(id string, mountLabel string) (string, error) { … }

func (v *volumeClient) GraphDriverRelease(id string) error { … }

func (v *volumeClient) GraphDriverExists(id string) bool { … }

func (v *volumeClient) GraphDriverDiff(id string, parent string) io.Writer { … }

func (v *volumeClient) GraphDriverChanges(id string, parent string) ([]api.GraphDriverChanges, error) { … }

func (v *volumeClient) GraphDriverApplyDiff(id string, parent string, diff io.Reader) (int, error) { … }

func (v *volumeClient) GraphDriverDiffSize(id string, parent string) (int, error) { … }

// Create a new Vol for the specific volume spev.c.
// It returns a system generated VolumeID that uniquely identifies the volume
func (v *volumeClient) Create(locator *api.VolumeLocator, source *api.Source,
	spec *api.VolumeSpec) (string, error) { … }

// Status diagnostic information
func (v *volumeClient) Status() [][2]string { … }

// Inspect specified volumes.
// Errors ErrEnoEnt may be returned.
func (v *volumeClient) Inspect(ids []string) ([]*api.Volume, error) { … }

// Delete volume.
// Errors ErrEnoEnt, ErrVolHasSnaps may be returned.
func (v *volumeClient) Delete(volumeID string) error { … }

// Snap specified volume. IO to the underlying volume should be quiesced before
// calling this function.
// Errors ErrEnoEnt may be returned
func (v *volumeClient) Snapshot(volumeID string, readonly bool,
	locator *api.VolumeLocator) (string, error) { … }

// Restore specified volume to given snapshot state
func (v *volumeClient) Restore(volumeID string, snapID string) error { … }

// Stats for specified volume.
// Errors ErrEnoEnt may be returned
func (v *volumeClient) Stats(
	volumeID string,
	cumulative bool,
) (*api.Stats, error) { … }

// UsedSize returns allocated volume size.
// Errors ErrEnoEnt may be returned
func (v *volumeClient) UsedSize(
	volumeID string,
) (uint64, error) { … }

// Active Requests on all volume.
func (v *volumeClient) GetActiveRequests() (*api.ActiveRequests, error) { … }

// Shutdown and cleanup.
func (v *volumeClient) Shutdown() { … }

// Enumerate volumes that map to the volumeLocator. Locator fields may be regexp.
// If locator fields are left blank, this will return all volumes.
func (v *volumeClient) Enumerate(locator *api.VolumeLocator,
	labels map[string]string) ([]*api.Volume, error) { … }

// Enumerate snaps for specified volume
// Count indicates the number of snaps populated.
func (v *volumeClient) SnapEnumerate(ids []string,
	snapLabels map[string]string) ([]*api.Volume, error) { … }

// Attach map device to the host.
// On success the devicePath specifies location where the device is exported
// Errors ErrEnoEnt, ErrVolAttached may be returned.
func (v *volumeClient) Attach(volumeID string, attachOptions map[string]string) (string, error) { … }

// Detach device from the host.
// Errors ErrEnoEnt, ErrVolDetached may be returned.
func (v *volumeClient) Detach(volumeID string, unmountBeforeDetach bool) error { … }

func (v *volumeClient) MountedAt(mountPath string) string { … }

// Mount volume at specified path
// Errors ErrEnoEnt, ErrVolDetached may be returned.
func (v *volumeClient) Mount(volumeID string, mountPath string) error { … }

// Unmount volume at specified path
// Errors ErrEnoEnt, ErrVolDetached may be returned.
func (v *volumeClient) Unmount(volumeID string, mountPath string) error { … }

// Update volume
func (v *volumeClient) Set(volumeID string, locator *api.VolumeLocator,
	spec *api.VolumeSpec) error { … }

func (v *volumeClient) doVolumeSet(volumeID string,
	request *api.VolumeSetRequest) error { … }

func (v *volumeClient) doVolumeSetGetResponse(volumeID string,
	request *api.VolumeSetRequest) (*api.VolumeSetResponse, error) { … }