mpi

Documentation

Index

• Constants
• func New(client pluginsinterface.PluginClientset, arguments []string) pluginsinterface.PluginInterface
• type MPIPlugin
  • func NewInstance(arguments []string) MPIPlugin
  • func (mp *MPIPlugin) GetMasterName() string
  • func (mp *MPIPlugin) GetMpiArguments() []string
  • func (mp *MPIPlugin) GetWorkerName() string
  • func (mp *MPIPlugin) Name() string
  • func (mp *MPIPlugin) OnJobAdd(job *batch.Job) error
  • func (mp *MPIPlugin) OnJobDelete(job *batch.Job) error
  • func (mp *MPIPlugin) OnJobUpdate(job *batch.Job) error
  • func (mp *MPIPlugin) OnPodCreate(pod *v1.Pod, job *batch.Job) error

Constants

const (
	// MPIPluginName is the name of the plugin
	MPIPluginName = "mpi"
	// DefaultPort is the default port for ssh
	DefaultPort = 22
	// DefaultMaster is the default task name of master host
	DefaultMaster = "master"
	// DefaultWorker is the default task name of worker host
	DefaultWorker = "worker"
	// MPIHost is the environment variable key of MPI host
	MPIHost = "MPI_HOST"
)

Functions

func New

func New(client pluginsinterface.PluginClientset, arguments []string) pluginsinterface.PluginInterface

New creates mpi plugin.

Types

type MPIPlugin

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

func NewInstance

func NewInstance(arguments []string) MPIPlugin

func (*MPIPlugin) GetMasterName

func (mp *MPIPlugin) GetMasterName() string

func (*MPIPlugin) GetMpiArguments

func (mp *MPIPlugin) GetMpiArguments() []string

func (*MPIPlugin) GetWorkerName

func (mp *MPIPlugin) GetWorkerName() string

func (*MPIPlugin) Name

func (mp *MPIPlugin) Name() string

func (*MPIPlugin) OnJobAdd

func (mp *MPIPlugin) OnJobAdd(job *batch.Job) error

func (*MPIPlugin) OnJobDelete

func (mp *MPIPlugin) OnJobDelete(job *batch.Job) error

func (*MPIPlugin) OnJobUpdate

func (mp *MPIPlugin) OnJobUpdate(job *batch.Job) error

func (*MPIPlugin) OnPodCreate

func (mp *MPIPlugin) OnPodCreate(pod *v1.Pod, job *batch.Job) error