disks

Documentation

Index

• type AttacherDetacher
  • func NewAttacherDetacher(c client.Connector, l boshlog.Logger, adm IscsiNodeAdministrator) AttacherDetacher
  • func NewAttacherDetacherForInstance(in *resource.Instance, c client.Connector, l boshlog.Logger) (AttacherDetacher, error)
• type AttacherDetacherFactory
• type Creator
  • func NewCreator(c client.Connector, l boshlog.Logger, loc resource.Location) Creator
• type CreatorFactory
• type Finder
  • func NewFinder(c client.Connector, l boshlog.Logger, loc resource.Location) Finder
• type FinderFactory
• type InstanceAttacherDetacherFactory
• type IscsciNodeAdministratorFactory
• type IscsiNodeAdministrator
  • func NewRemoteIscsiNodeAdministrator(remoteUser string, remoteIP string, localIdentityFilePath string, ...) IscsiNodeAdministrator
• type SSHCmdResultHandler
• type SSHCmdRunner
  • func NewSSHCmdRunner(user string, remoteIP string, identityPath string, logger boshlog.Logger) SSHCmdRunner
• type Terminator
  • func NewTerminator(c client.Connector, l boshlog.Logger) Terminator
• type TerminatorFactory
• type VolumeFaultyError
  • func (e VolumeFaultyError) Error() string
• type VolumeTerminatedError
  • func (e VolumeTerminatedError) Error() string

Types

type AttacherDetacher

type AttacherDetacher interface {
	AttachVolumeToInstance(v *resource.Volume, in *resource.Instance) error
	DetachVolumeFromInstance(v *resource.Volume) error
}

func NewAttacherDetacher

func NewAttacherDetacher(c client.Connector, l boshlog.Logger, adm IscsiNodeAdministrator) AttacherDetacher

func NewAttacherDetacherForInstance

func NewAttacherDetacherForInstance(in *resource.Instance, c client.Connector, l boshlog.Logger) (AttacherDetacher, error)

type AttacherDetacherFactory

type AttacherDetacherFactory func(c client.Connector, l boshlog.Logger, adm IscsiNodeAdministrator) (AttacherDetacher, error)

type Creator

type Creator interface {
	CreateVolume(name string, sizeinMB int64) (*resource.Volume, error)
}

func NewCreator

func NewCreator(c client.Connector, l boshlog.Logger, loc resource.Location) Creator

type CreatorFactory

type CreatorFactory func(client.Connector, boshlog.Logger, resource.Location) Creator

type Finder

type Finder interface {
	FindVolume(volumeID string) (*resource.Volume, error)
	FindAllAttachedVolumes(instanceID string) ([]*resource.Volume, error)
}

func NewFinder

func NewFinder(c client.Connector, l boshlog.Logger, loc resource.Location) Finder

type FinderFactory

type FinderFactory func(client.Connector, boshlog.Logger, resource.Location) Finder

type InstanceAttacherDetacherFactory

type InstanceAttacherDetacherFactory func(*resource.Instance, client.Connector, boshlog.Logger) (AttacherDetacher, error)

type IscsciNodeAdministratorFactory

type IscsciNodeAdministratorFactory func(remoteUser string, remoteIP string, localIdentityFilePath string,
	logger boshlog.Logger) IscsiNodeAdministrator

type IscsiNodeAdministrator

type IscsiNodeAdministrator interface {
	RunAttachmentCommands(scsiIQN string, scsiServer string,
		scsiServerPort int64) (resolvedDevicePath string, err error)
}

func NewRemoteIscsiNodeAdministrator

func NewRemoteIscsiNodeAdministrator(remoteUser string, remoteIP string,
	localIdentityFilePath string, logger boshlog.Logger) IscsiNodeAdministrator

type SSHCmdResultHandler

type SSHCmdResultHandler func(stdout string, stderr string) (retry bool, reasonToRetry string)

type SSHCmdRunner

type SSHCmdRunner interface {
	RunCommand(cmd string, resultHandler SSHCmdResultHandler, maxAttempts int, durationBetweenAttempts time.Duration) error
	Connect(maxAttempts int, durationBetweenAttempts time.Duration) error
}

func NewSSHCmdRunner

func NewSSHCmdRunner(user string, remoteIP string, identityPath string,
	logger boshlog.Logger) SSHCmdRunner

type Terminator

type Terminator interface {
	DeleteVolume(volumeID string) error
}

func NewTerminator

func NewTerminator(c client.Connector, l boshlog.Logger) Terminator

type TerminatorFactory

type TerminatorFactory func(client.Connector, boshlog.Logger) Terminator

type VolumeFaultyError

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

func (VolumeFaultyError) Error

func (e VolumeFaultyError) Error() string

type VolumeTerminatedError

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

func (VolumeTerminatedError) Error

func (e VolumeTerminatedError) Error() string