sshexec

Documentation

Index

• Constants
• Variables
• type SshConfig
• type SshExecutor
  • func NewSshExecutor(config *SshConfig) *SshExecutor
  • func (s *SshExecutor) BrickCreate(host string, brick *executors.BrickRequest) (*executors.BrickInfo, error)
  • func (s *SshExecutor) BrickDestroy(host string, brick *executors.BrickRequest) error
  • func (s *SshExecutor) BrickDestroyCheck(host string, brick *executors.BrickRequest) error
  • func (s *SshExecutor) DeviceSetup(host, device, vgid string) (d *executors.DeviceInfo, e error)
  • func (s *SshExecutor) DeviceTeardown(host, device, vgid string) error
  • func (s *SshExecutor) PeerDetach(host, detachnode string) error
  • func (s *SshExecutor) PeerProbe(host, newnode string) error
  • func (s *SshExecutor) VolumeCreate(host string, volume *executors.VolumeRequest) (*executors.VolumeInfo, error)
  • func (s *SshExecutor) VolumeDestroy(host string, volume string) error
  • func (s *SshExecutor) VolumeDestroyCheck(host, volume string) error
  • func (s *SshExecutor) VolumeExpand(host string, volume *executors.VolumeRequest) (*executors.VolumeInfo, error)

Constants

const (
	VGDISPLAY_SIZE_KB                  = 11
	VGDISPLAY_PHYSICAL_EXTENT_SIZE     = 12
	VGDISPLAY_TOTAL_NUMBER_EXTENTS     = 13
	VGDISPLAY_ALLOCATED_NUMBER_EXTENTS = 14
	VGDISPLAY_FREE_NUMBER_EXTENTS      = 15
)

Variables

var (
	ErrSshPrivateKey = errors.New("Unable to read private key file")
)

Types

type SshConfig

type SshConfig struct {
	PrivateKeyFile string `json:"keyfile"`
	User           string `json:"user"`
	Port           string `json:"port"`

	// Experimental Settings
	RebalanceOnExpansion bool `json:"rebalance_on_expansion"`
}

type SshExecutor

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

func NewSshExecutor

func NewSshExecutor(config *SshConfig) *SshExecutor

func (*SshExecutor) BrickCreate

func (s *SshExecutor) BrickCreate(host string,
	brick *executors.BrickRequest) (*executors.BrickInfo, error)

func (*SshExecutor) BrickDestroy

func (s *SshExecutor) BrickDestroy(host string,
	brick *executors.BrickRequest) error

func (*SshExecutor) BrickDestroyCheck

func (s *SshExecutor) BrickDestroyCheck(host string,
	brick *executors.BrickRequest) error

func (*SshExecutor) DeviceSetup

func (s *SshExecutor) DeviceSetup(host, device, vgid string) (d *executors.DeviceInfo, e error)

func (*SshExecutor) DeviceTeardown

func (s *SshExecutor) DeviceTeardown(host, device, vgid string) error

func (*SshExecutor) PeerDetach

func (s *SshExecutor) PeerDetach(host, detachnode string) error

func (*SshExecutor) PeerProbe

func (s *SshExecutor) PeerProbe(host, newnode string) error

func (*SshExecutor) VolumeCreate

func (s *SshExecutor) VolumeCreate(host string,
	volume *executors.VolumeRequest) (*executors.VolumeInfo, error)

func (*SshExecutor) VolumeDestroy

func (s *SshExecutor) VolumeDestroy(host string, volume string) error

func (*SshExecutor) VolumeDestroyCheck

func (s *SshExecutor) VolumeDestroyCheck(host, volume string) error

func (*SshExecutor) VolumeExpand

func (s *SshExecutor) VolumeExpand(host string,
	volume *executors.VolumeRequest) (*executors.VolumeInfo, error)