sshexec

Documentation

Index

• Constants
• Variables
• type CLICommandConfig
• type RemoteCommandTransport
• type SshConfig
• type SshExecutor
  • func NewSshExecutor(config *SshConfig) (*SshExecutor, error)
  • func (s *SshExecutor) AccessConnection(host string)
  • 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) FreeConnection(host string)
  • func (s *SshExecutor) PeerDetach(host, detachnode string) error
  • func (s *SshExecutor) PeerProbe(host, newnode string) error
  • func (s *SshExecutor) RebalanceOnExpansion() bool
  • func (s *SshExecutor) RemoteCommandExecute(host string, commands []string, timeoutMinutes int) ([]string, error)
  • func (s *SshExecutor) SetLogLevel(level string)
  • func (s *SshExecutor) SnapShotLimit() int
  • 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)
• type Ssher

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 CLICommandConfig

type CLICommandConfig struct {
	Fstab         string `json:"fstab"`
	Sudo          bool   `json:"sudo"`
	SnapShotLimit int    `json:"snapshot_limit"`

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

type RemoteCommandTransport

type RemoteCommandTransport interface {
	RemoteCommandExecute(host string, commands []string, timeoutMinutes int) ([]string, error)
	RebalanceOnExpansion() bool
	SnapShotLimit() int
}

type SshConfig

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

type SshExecutor

type SshExecutor struct {
	// "Public"
	Throttlemap    map[string]chan bool
	Lock           sync.Mutex
	RemoteExecutor RemoteCommandTransport
	Fstab          string
	// contains filtered or unexported fields
}

func NewSshExecutor

func NewSshExecutor(config *SshConfig) (*SshExecutor, error)

func (*SshExecutor) AccessConnection

func (s *SshExecutor) AccessConnection(host string)

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) FreeConnection

func (s *SshExecutor) FreeConnection(host string)

func (*SshExecutor) PeerDetach

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

func (*SshExecutor) PeerProbe

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

:TODO: Rename this function to NodeInit or something

func (*SshExecutor) RebalanceOnExpansion

func (s *SshExecutor) RebalanceOnExpansion() bool

func (*SshExecutor) RemoteCommandExecute

func (s *SshExecutor) RemoteCommandExecute(host string,
	commands []string,
	timeoutMinutes int) ([]string, error)

func (*SshExecutor) SetLogLevel

func (s *SshExecutor) SetLogLevel(level string)

func (*SshExecutor) SnapShotLimit

func (s *SshExecutor) SnapShotLimit() int

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)

type Ssher

type Ssher interface {
	ConnectAndExec(host string, commands []string, timeoutMinutes int, useSudo bool) ([]string, error)
}