mpi

Documentation

Index

• Constants
• type MpiGrouper
  • func NewMpiGrouper(client client.Client, kubeflowGrouper *kubeflow.KubeflowDistributedGrouper) *MpiGrouper
  • func (mg *MpiGrouper) GetPodGroupMetadata(topOwner *unstructured.Unstructured, pod *v1.Pod, ...) (*podgroup.Metadata, error)
  • func (mg *MpiGrouper) Name() string

Constants

const (
	ReplicaSpecName = "mpiReplicaSpecs"
	MasterName      = "Launcher"
	WorkerName      = "Worker"
)

Types

type MpiGrouper

type MpiGrouper struct {
	*kubeflow.KubeflowDistributedGrouper
	// contains filtered or unexported fields
}

func NewMpiGrouper

func NewMpiGrouper(client client.Client, kubeflowGrouper *kubeflow.KubeflowDistributedGrouper) *MpiGrouper

func (*MpiGrouper) GetPodGroupMetadata

func (mg *MpiGrouper) GetPodGroupMetadata(topOwner *unstructured.Unstructured, pod *v1.Pod, _ ...*metav1.PartialObjectMetadata) (*podgroup.Metadata, error)

func (*MpiGrouper) Name

func (mg *MpiGrouper) Name() string