mpi

Documentation

Index

• Constants
• func New(client pluginsinterface.PluginClientset, arguments []string) pluginsinterface.PluginInterface
• type Plugin
  • func NewInstance(arguments []string) Plugin
  • func (mp *Plugin) GetMasterName() string
  • func (mp *Plugin) GetMpiArguments() []string
  • func (mp *Plugin) GetWorkerName() string
  • func (mp *Plugin) Name() string
  • func (mp *Plugin) OnJobAdd(job *batch.Job) error
  • func (mp *Plugin) OnJobDelete(job *batch.Job) error
  • func (mp *Plugin) OnJobUpdate(job *batch.Job) error
  • func (mp *Plugin) 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 Plugin

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

func NewInstance

func NewInstance(arguments []string) Plugin

func (*Plugin) GetMasterName

func (mp *Plugin) GetMasterName() string

func (*Plugin) GetMpiArguments

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

func (*Plugin) GetWorkerName

func (mp *Plugin) GetWorkerName() string

func (*Plugin) Name

func (mp *Plugin) Name() string

func (*Plugin) OnJobAdd

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

func (*Plugin) OnJobDelete

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

func (*Plugin) OnJobUpdate

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

func (*Plugin) OnPodCreate

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