driver

package

v0.0.0-...-c8d7028 Latest Latest Go to latest Published: Oct 3, 2017 License: GPL-3.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func MountPoint(voldir string, name string) (string, string)

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

func NewCassFsDriver(config *DriverConfig) *CassFsDriver

func (c *CassFsDriver) Capabilities() *volume.CapabilitiesResponse

func (c *CassFsDriver) Create(r *volume.CreateRequest) error

func (c *CassFsDriver) Get(r *volume.GetRequest) (*volume.GetResponse, error)

func (c *CassFsDriver) List() (*volume.ListResponse, error)

func (c *CassFsDriver) Mount(r *volume.MountRequest) (*volume.MountResponse, error)

func (c *CassFsDriver) Path(r *volume.PathRequest) (*volume.PathResponse, error)

func (c *CassFsDriver) Remove(r *volume.RemoveRequest) error

func (c *CassFsDriver) Unmount(r *volume.UnmountRequest) error

type DriverConfig struct {
	Consistency string
	Keyspace    string
	Server      string
	StateDir    string
	VolumeDir   string
}

type Mount struct {
	Name        string
	Hash        string
	Environment string
	Owner       int
	Clients     int
	Location    string
}

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

func NewVolumeDb(config *DriverConfig) (*VolumeDb, error)

func (v *VolumeDb) CreateVolume(name string, owner int, env string) (*Mount, error)

func (v *VolumeDb) DeleteVolume(name string) (*Mount, error)

func (v *VolumeDb) FindVolume(name string) (*Mount, error)

func (v *VolumeDb) GetAll() ([]*Mount, error)

func (v *VolumeDb) MountVolume(name string) (*Mount, error)

func (v *VolumeDb) UnmountVolume(name string) (*Mount, error)