vfs

Documentation

Index

• Constants
• func Init(root string, config map[string]string) (ConvoyDriver, error)
• type Device
  • func (dev *Device) ConfigFile() (string, error)
• type Driver
  • func (d *Driver) BackupOps() (BackupOperations, error)
  • func (d *Driver) CreateBackup(snapshotID, volumeID, destURL string, opts map[string]string) (string, error)
  • func (d *Driver) CreateSnapshot(req Request) error
  • func (d *Driver) CreateVolume(req Request) error
  • func (d *Driver) DeleteBackup(backupURL string) error
  • func (d *Driver) DeleteSnapshot(req Request) error
  • func (d *Driver) DeleteVolume(req Request) error
  • func (d *Driver) GetBackupInfo(backupURL string) (map[string]string, error)
  • func (d *Driver) GetSnapshotInfo(req Request) (map[string]string, error)
  • func (d *Driver) GetVolumeInfo(name string) (map[string]string, error)
  • func (d *Driver) Info() (map[string]string, error)
  • func (d *Driver) ListBackup(destURL string, opts map[string]string) (map[string]map[string]string, error)
  • func (d *Driver) ListSnapshot(opts map[string]string) (map[string]map[string]string, error)
  • func (d *Driver) ListVolume(opts map[string]string) (map[string]map[string]string, error)
  • func (d *Driver) MountPoint(req Request) (string, error)
  • func (d *Driver) MountVolume(req Request) (string, error)
  • func (d *Driver) Name() string
  • func (d *Driver) SnapshotOps() (SnapshotOperations, error)
  • func (d *Driver) UmountVolume(req Request) error
  • func (d *Driver) VolumeOps() (VolumeOperations, error)
• type Snapshot
• type VfsObjectStoreDriver
  • func (v *VfsObjectStoreDriver) Download(src, dst string) error
  • func (v *VfsObjectStoreDriver) FileExists(filePath string) bool
  • func (v *VfsObjectStoreDriver) FileSize(filePath string) int64
  • func (v *VfsObjectStoreDriver) GetURL() string
  • func (v *VfsObjectStoreDriver) Kind() string
  • func (v *VfsObjectStoreDriver) List(path string) ([]string, error)
  • func (v *VfsObjectStoreDriver) Read(src string) (io.ReadCloser, error)
  • func (v *VfsObjectStoreDriver) Remove(names ...string) error
  • func (v *VfsObjectStoreDriver) Upload(src, dst string) error
  • func (v *VfsObjectStoreDriver) Write(dst string, rs io.ReadSeeker) error
• type Volume
  • func (v *Volume) ConfigFile() (string, error)

Constants

const (
	KIND = "vfs"

	VFS_PATH = "vfs.path"

	MAX_CLEANUP_LEVEL = 10
)

const (
	DRIVER_NAME        = "vfs"
	DRIVER_CONFIG_FILE = "vfs.cfg"

	VOLUME_CFG_PREFIX = "volume_"
	VFS_CFG_PREFIX    = DRIVER_NAME + "_"
	CFG_POSTFIX       = ".json"

	SNAPSHOT_PATH = "snapshots"

	VFS_DEFAULT_VOLUME_SIZE = "vfs.defaultvolumesize"
	DEFAULT_VOLUME_SIZE     = "100G"
)

Functions

func Init

func Init(root string, config map[string]string) (ConvoyDriver, error)

Types

type Device

type Device struct {
	Root              string
	Path              string
	ConfigPath        string
	DefaultVolumeSize int64
}

func (*Device) ConfigFile

func (dev *Device) ConfigFile() (string, error)

type Driver

type Driver struct {
	Device
	// contains filtered or unexported fields
}

func (*Driver) BackupOps

func (d *Driver) BackupOps() (BackupOperations, error)

func (*Driver) CreateBackup

func (d *Driver) CreateBackup(snapshotID, volumeID, destURL string, opts map[string]string) (string, error)

func (*Driver) CreateSnapshot

func (d *Driver) CreateSnapshot(req Request) error

func (*Driver) CreateVolume

func (d *Driver) CreateVolume(req Request) error

func (*Driver) DeleteBackup

func (d *Driver) DeleteBackup(backupURL string) error

func (*Driver) DeleteSnapshot

func (d *Driver) DeleteSnapshot(req Request) error

func (*Driver) DeleteVolume

func (d *Driver) DeleteVolume(req Request) error

func (*Driver) GetBackupInfo

func (d *Driver) GetBackupInfo(backupURL string) (map[string]string, error)

func (*Driver) GetSnapshotInfo

func (d *Driver) GetSnapshotInfo(req Request) (map[string]string, error)

func (*Driver) GetVolumeInfo

func (d *Driver) GetVolumeInfo(name string) (map[string]string, error)

func (*Driver) Info

func (d *Driver) Info() (map[string]string, error)

func (*Driver) ListBackup

func (d *Driver) ListBackup(destURL string, opts map[string]string) (map[string]map[string]string, error)

func (*Driver) ListSnapshot

func (d *Driver) ListSnapshot(opts map[string]string) (map[string]map[string]string, error)

func (*Driver) ListVolume

func (d *Driver) ListVolume(opts map[string]string) (map[string]map[string]string, error)

func (*Driver) MountPoint

func (d *Driver) MountPoint(req Request) (string, error)

func (*Driver) MountVolume

func (d *Driver) MountVolume(req Request) (string, error)

func (*Driver) Name

func (d *Driver) Name() string

func (*Driver) SnapshotOps

func (d *Driver) SnapshotOps() (SnapshotOperations, error)

func (*Driver) UmountVolume

func (d *Driver) UmountVolume(req Request) error

func (*Driver) VolumeOps

func (d *Driver) VolumeOps() (VolumeOperations, error)

type Snapshot

type Snapshot struct {
	Name        string
	CreatedTime string
	VolumeUUID  string
	FilePath    string
}

type VfsObjectStoreDriver

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

func (*VfsObjectStoreDriver) Download

func (v *VfsObjectStoreDriver) Download(src, dst string) error

func (*VfsObjectStoreDriver) FileExists

func (v *VfsObjectStoreDriver) FileExists(filePath string) bool

func (*VfsObjectStoreDriver) FileSize

func (v *VfsObjectStoreDriver) FileSize(filePath string) int64

func (*VfsObjectStoreDriver) GetURL

func (v *VfsObjectStoreDriver) GetURL() string

func (*VfsObjectStoreDriver) Kind

func (v *VfsObjectStoreDriver) Kind() string

func (*VfsObjectStoreDriver) List

func (v *VfsObjectStoreDriver) List(path string) ([]string, error)

func (*VfsObjectStoreDriver) Read

func (v *VfsObjectStoreDriver) Read(src string) (io.ReadCloser, error)

func (*VfsObjectStoreDriver) Remove

func (v *VfsObjectStoreDriver) Remove(names ...string) error

func (*VfsObjectStoreDriver) Upload

func (v *VfsObjectStoreDriver) Upload(src, dst string) error

func (*VfsObjectStoreDriver) Write

func (v *VfsObjectStoreDriver) Write(dst string, rs io.ReadSeeker) error

type Volume

type Volume struct {
	Name         string
	Size         int64
	Path         string
	MountPoint   string
	PrepareForVM bool
	CreatedTime  string
	Snapshots    map[string]Snapshot
	// contains filtered or unexported fields
}

func (*Volume) ConfigFile

func (v *Volume) ConfigFile() (string, error)