volumize

Documentation

Index

• Constants
• func DoIt(device, volumeTag, fsType, mountPoint, clusterName string, minutes int) error
• func EnsureFilesystemsMounted() error
• func NormalizeDevice(device string) string
• func PersistFilesystem(device, fsType, mountPoint, fstabPath string) error
• type Volumizer
  • func NewVolumizer(sess *session.Session, availabilityZone, instanceID string) *Volumizer
  • func (v *Volumizer) AttachVolume(volume *ec2.Volume, device string) error
  • func (v *Volumizer) AttachedVolume(clusterName, volumeTag, device *string) (*ec2.Volume, error)
  • func (v *Volumizer) HasFilesystem(device, fstype string) (bool, error)
  • func (v *Volumizer) MakeFilesystem(device, fstype string) error
  • func (v *Volumizer) WaitForDevice(device string) error
  • func (v *Volumizer) WaitForVolume(clusterName, volumeTag *string, minutes time.Duration) (*ec2.Volume, error)

Constants

const (
	Blkid = "blkid"
	Mkfs  = "mkfs"
	Fstab = "/etc/fstab"
)

Functions

func DoIt

func DoIt(device, volumeTag, fsType, mountPoint, clusterName string, minutes int) error

func EnsureFilesystemsMounted

func EnsureFilesystemsMounted() error

func NormalizeDevice

func NormalizeDevice(device string) string

func PersistFilesystem

func PersistFilesystem(device, fsType, mountPoint, fstabPath string) error

Types

type Volumizer

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

func NewVolumizer

func NewVolumizer(sess *session.Session, availabilityZone, instanceID string) *Volumizer

func (*Volumizer) AttachVolume

func (v *Volumizer) AttachVolume(volume *ec2.Volume, device string) error

func (*Volumizer) AttachedVolume

func (v *Volumizer) AttachedVolume(clusterName, volumeTag, device *string) (*ec2.Volume, error)

func (*Volumizer) HasFilesystem

func (v *Volumizer) HasFilesystem(device, fstype string) (bool, error)

func (*Volumizer) MakeFilesystem

func (v *Volumizer) MakeFilesystem(device, fstype string) error

func (*Volumizer) WaitForDevice

func (v *Volumizer) WaitForDevice(device string) error

func (*Volumizer) WaitForVolume

func (v *Volumizer) WaitForVolume(clusterName, volumeTag *string, minutes time.Duration) (*ec2.Volume, error)