volume

Documentation

Index

• type API
• type Server
  • func NewServer(hostAPI API) (*Server, error)
  • func (s *Server) DismountVolume(context context.Context, request *internal.DismountVolumeRequest, ...) (*internal.DismountVolumeResponse, error)
  • func (s *Server) FormatVolume(context context.Context, request *internal.FormatVolumeRequest, ...) (*internal.FormatVolumeResponse, error)
  • func (s *Server) GetVolumeDiskNumber(context context.Context, request *internal.VolumeDiskNumberRequest, ...) (*internal.VolumeDiskNumberResponse, error)
  • func (s *Server) GetVolumeIDFromMount(context context.Context, request *internal.VolumeIDFromMountRequest, ...) (*internal.VolumeIDFromMountResponse, error)
  • func (s *Server) IsVolumeFormatted(context context.Context, request *internal.IsVolumeFormattedRequest, ...) (*internal.IsVolumeFormattedResponse, error)
  • func (s *Server) ListVolumesOnDisk(context context.Context, request *internal.ListVolumesOnDiskRequest, ...) (*internal.ListVolumesOnDiskResponse, error)
  • func (s *Server) MountVolume(context context.Context, request *internal.MountVolumeRequest, ...) (*internal.MountVolumeResponse, error)
  • func (s *Server) ResizeVolume(context context.Context, request *internal.ResizeVolumeRequest, ...) (*internal.ResizeVolumeResponse, error)
  • func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI
  • func (s *Server) VolumeStats(context context.Context, request *internal.VolumeStatsRequest, ...) (*internal.VolumeStatsResponse, error)
  • func (s *Server) WriteVolumeCache(context context.Context, request *internal.WriteVolumeCacheRequest, ...) (*internal.WriteVolumeCacheResponse, error)

Types

type API

type API interface {
	ListVolumesOnDisk(diskID string) (volumeIDs []string, err error)
	// MountVolume mounts the volume at the requested global staging path
	MountVolume(volumeID, path string) error
	// DismountVolume gracefully dismounts a volume
	DismountVolume(volumeID, path string) error
	// IsVolumeFormatted checks if a volume is formatted with NTFS
	IsVolumeFormatted(volumeID string) (bool, error)
	// FormatVolume formats a volume with the provided file system
	FormatVolume(volumeID string) error
	// ResizeVolume performs resizing of the partition and file system for a block based volume
	ResizeVolume(volumeID string, size int64) error
	// VolumeStats gets the volume information
	VolumeStats(volumeID string) (int64, int64, error)
	// GetVolumeDiskNumber returns the disk number for where the volume is at
	GetVolumeDiskNumber(volumeID string) (int64, error)
	// GetVolumeIDFromMount returns the volume id of a given mount
	GetVolumeIDFromMount(mount string) (string, error)
	// WriteVolumeCache writes volume cache to disk
	WriteVolumeCache(volumeID string) error
}

type Server

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

func NewServer

func NewServer(hostAPI API) (*Server, error)

func (*Server) DismountVolume

func (s *Server) DismountVolume(context context.Context, request *internal.DismountVolumeRequest, version apiversion.Version) (*internal.DismountVolumeResponse, error)

func (*Server) FormatVolume

func (s *Server) FormatVolume(context context.Context, request *internal.FormatVolumeRequest, version apiversion.Version) (*internal.FormatVolumeResponse, error)

func (*Server) GetVolumeDiskNumber

func (s *Server) GetVolumeDiskNumber(context context.Context, request *internal.VolumeDiskNumberRequest, version apiversion.Version) (*internal.VolumeDiskNumberResponse, error)

func (*Server) GetVolumeIDFromMount

func (s *Server) GetVolumeIDFromMount(context context.Context, request *internal.VolumeIDFromMountRequest, version apiversion.Version) (*internal.VolumeIDFromMountResponse, error)

func (*Server) IsVolumeFormatted

func (s *Server) IsVolumeFormatted(context context.Context, request *internal.IsVolumeFormattedRequest, version apiversion.Version) (*internal.IsVolumeFormattedResponse, error)

func (*Server) ListVolumesOnDisk

func (s *Server) ListVolumesOnDisk(context context.Context, request *internal.ListVolumesOnDiskRequest, version apiversion.Version) (*internal.ListVolumesOnDiskResponse, error)

func (*Server) MountVolume

func (s *Server) MountVolume(context context.Context, request *internal.MountVolumeRequest, version apiversion.Version) (*internal.MountVolumeResponse, error)

func (*Server) ResizeVolume

func (s *Server) ResizeVolume(context context.Context, request *internal.ResizeVolumeRequest, version apiversion.Version) (*internal.ResizeVolumeResponse, error)

func (*Server) VersionedAPIs

func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI

func (*Server) VolumeStats

func (s *Server) VolumeStats(context context.Context, request *internal.VolumeStatsRequest, version apiversion.Version) (*internal.VolumeStatsResponse, error)

func (*Server) WriteVolumeCache

func (s *Server) WriteVolumeCache(context context.Context, request *internal.WriteVolumeCacheRequest, version apiversion.Version) (*internal.WriteVolumeCacheResponse, error)