multipass

Documentation

Index

• type MultipassDispatcher
  • func NewMultipassDispatcher(numNodes int, masterName, workerName string) *MultipassDispatcher
  • func (m MultipassDispatcher) Cleanup() error
  • func (m MultipassDispatcher) DownloadProject(node dispatch.Node, source string) error
  • func (m MultipassDispatcher) GetMasterNode() dispatch.Node
  • func (m MultipassDispatcher) GetNodes() []dispatch.Node
  • func (m MultipassDispatcher) GetWorkerNodes() []dispatch.Node
  • func (m *MultipassDispatcher) LaunchNodes() error
  • func (m MultipassDispatcher) Ready() bool
  • func (m MultipassDispatcher) SendCommands(node dispatch.Node, cmds ...dispatch.Command) error
  • func (m MultipassDispatcher) SendCommandsContext(ctx context.Context, node dispatch.Node, cmds ...dispatch.Command) error
  • func (m MultipassDispatcher) SendFile(node dispatch.Node, src, dst string) error
  • func (m MultipassDispatcher) Teardown() error

Types

type MultipassDispatcher

type MultipassDispatcher struct {
	NumNodes   int
	MasterName string
	// Workers will be named $WorkerName-1, $WorkerName-2, ...
	WorkerName  string
	MasterNode  dispatch.Node
	WorkerNodes []dispatch.Node
}

func NewMultipassDispatcher

func NewMultipassDispatcher(numNodes int, masterName, workerName string) *MultipassDispatcher

func (MultipassDispatcher) Cleanup

func (m MultipassDispatcher) Cleanup() error

func (MultipassDispatcher) DownloadProject

func (m MultipassDispatcher) DownloadProject(node dispatch.Node, source string) error

func (MultipassDispatcher) GetMasterNode

func (m MultipassDispatcher) GetMasterNode() dispatch.Node

func (MultipassDispatcher) GetNodes

func (m MultipassDispatcher) GetNodes() []dispatch.Node

func (MultipassDispatcher) GetWorkerNodes

func (m MultipassDispatcher) GetWorkerNodes() []dispatch.Node

func (*MultipassDispatcher) LaunchNodes

func (m *MultipassDispatcher) LaunchNodes() error

func (MultipassDispatcher) Ready

func (m MultipassDispatcher) Ready() bool

func (MultipassDispatcher) SendCommands

func (m MultipassDispatcher) SendCommands(node dispatch.Node, cmds ...dispatch.Command) error

func (MultipassDispatcher) SendCommandsContext

func (m MultipassDispatcher) SendCommandsContext(
	ctx context.Context,
	node dispatch.Node,
	cmds ...dispatch.Command,
) error

func (MultipassDispatcher) SendFile

func (m MultipassDispatcher) SendFile(node dispatch.Node, src, dst string) error

func (MultipassDispatcher) Teardown

func (m MultipassDispatcher) Teardown() error