mpi

Documentation

Index

• func NewBackend(kubeClient kubernetes.Interface, kubeflowClient clientset.Interface, ...) backends.Backend
• type Backend
  • func (b *Backend) SyncChainerJob(chjob *apisv1alpha1.ChainerJob) error

Functions

func NewBackend

func NewBackend(
	kubeClient kubernetes.Interface,
	kubeflowClient clientset.Interface,
	serviceAccountLister corelister.ServiceAccountLister,
	roleLister rbaclister.RoleLister,
	roleBindingLister rbaclister.RoleBindingLister,
	configMapLister corelister.ConfigMapLister,
	jobLister batchlister.JobLister,
	statefulSetLister appslister.StatefulSetLister,
	recorder record.EventRecorder,
) backends.Backend

NewBackend is constructor for Backend

Types

type Backend

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

Backend is responsible for syncing ChainerJob with backend:mpi

func (*Backend) SyncChainerJob

func (b *Backend) SyncChainerJob(chjob *apisv1alpha1.ChainerJob) error

SyncChainerJob is main function to sync ChainerJob with "backend: mpi"