multipass

package

v0.0.0-...-c6bcdba Latest Latest Go to latest Published: Dec 26, 2024 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kev-cao/log-console

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL