volume

package

v0.3.1 Latest Latest Go to latest Published: Apr 4, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	MetadataFileMaxSize = 4 * 1024
)

This section is empty.

func WithLimiter(limiter limit.Limiter) func(*VolumeManager)

func WithMounter(mounter mount.Interface) func(*VolumeManager)

type AccessType int

const (
	MountAccess AccessType = iota
	BlockAccess
)

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

func NewStateManager(workspacePath string) (*StateManager, error)

func (s *StateManager) DeleteVolumeState(id string) error

func (s *StateManager) GetTotalVolumesSize() int64

func (s *StateManager) GetVolumeStateByID(id string) *VolumeState

func (s *StateManager) GetVolumeStateByName(name string) *VolumeState

func (s *StateManager) GetVolumes() []VolumeState

func (s *StateManager) SaveVolumeState(volume *VolumeState) (err error)

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

func NewVolumeManager(volumesDir string, sm *StateManager, options ...VolumeManagerOption) (*VolumeManager, error)

func (v *VolumeManager) CreateVolume(volID, name string, capacity int64, volAccessType AccessType) error

func (v *VolumeManager) DeleteVolume(volID string) error

func (v *VolumeManager) GetAvailableCapacity() (int64, error)

func (v *VolumeManager) GetVolumeStateByID(id string) *VolumeState

func (v *VolumeManager) GetVolumeStateByName(name string) *VolumeState

func (v *VolumeManager) Mount(volumeID, targetPath, fsType string, mountOptions []string) error

func (v *VolumeManager) SupportedAccessTypes() []AccessType

func (v *VolumeManager) SupportedFilesystems() []string

func (v *VolumeManager) Unmount(targetPath string) error

type VolumeManagerOption func(v *VolumeManager)

type VolumeState struct {
	Name    string `json:"name"`
	ID      string `json:"id"`
	LimitID uint32 `json:"limitID"`
	Size    int64  `json:"size"`
}

func (vs *VolumeState) IsEmpty() bool

func (vs *VolumeState) VolumePath(volumesDir string) string