ssh

Documentation

Index

• type SshDispatcher
  • func NewSshDispatcher(remotes []dispatch.UserQualifiedHostname, privateKeyFile string) (*SshDispatcher, error)
  • func (s *SshDispatcher) Cleanup() error
  • func (s *SshDispatcher) DownloadProject(node dispatch.Node, source string) error
  • func (s *SshDispatcher) GetMasterNode() dispatch.Node
  • func (s *SshDispatcher) GetNodes() []dispatch.Node
  • func (s *SshDispatcher) GetWorkerNodes() []dispatch.Node
  • func (s *SshDispatcher) Ready() bool
  • func (s *SshDispatcher) SendCommands(node dispatch.Node, cmds ...dispatch.Command) error
  • func (s *SshDispatcher) SendCommandsContext(ctx context.Context, node dispatch.Node, cmds ...dispatch.Command) error
  • func (s *SshDispatcher) SendFile(node dispatch.Node, src string, dst string) error

Types

type SshDispatcher

type SshDispatcher struct {
	NumNodes int
	// Remotes to SSH to. First address is the master node.
	Remotes        []dispatch.UserQualifiedHostname
	PrivateKeyFile string
	// contains filtered or unexported fields
}

func NewSshDispatcher

func NewSshDispatcher(remotes []dispatch.UserQualifiedHostname, privateKeyFile string) (*SshDispatcher, error)

func (*SshDispatcher) Cleanup

func (s *SshDispatcher) Cleanup() error

func (*SshDispatcher) DownloadProject

func (s *SshDispatcher) DownloadProject(node dispatch.Node, source string) error

func (*SshDispatcher) GetMasterNode

func (s *SshDispatcher) GetMasterNode() dispatch.Node

func (*SshDispatcher) GetNodes

func (s *SshDispatcher) GetNodes() []dispatch.Node

func (*SshDispatcher) GetWorkerNodes

func (s *SshDispatcher) GetWorkerNodes() []dispatch.Node

func (*SshDispatcher) Ready

func (s *SshDispatcher) Ready() bool

func (*SshDispatcher) SendCommands

func (s *SshDispatcher) SendCommands(node dispatch.Node, cmds ...dispatch.Command) error

func (*SshDispatcher) SendCommandsContext

func (s *SshDispatcher) SendCommandsContext(ctx context.Context, node dispatch.Node, cmds ...dispatch.Command) error

func (*SshDispatcher) SendFile

func (s *SshDispatcher) SendFile(node dispatch.Node, src string, dst string) error