client

Documentation

Index

• type Client
  • func NewClient(cfg *restclient.Config) (Client, error)

Types

type Client

type Client interface {
	// PyTorchJob CRUD operations
	CreatePyTorchJob(job *kubeflowv1.PyTorchJob) error
	GetPyTorchJob(namespace string, name string) (*kubeflowv1.PyTorchJob, error)
	UpdatePyTorchJob(namespace string, name string, job *kubeflowv1.PyTorchJob, data []byte) error
	DeletePyTorchJob(namespace string, name string) error

	// generate TFJob, MPIJob, XGBoostJob, PaddleJob CRUD
	CreateTFJob(job *kubeflowv1.TFJob) error
	GetTFJob(namespace string, name string) (*kubeflowv1.TFJob, error)
	UpdateTFJob(namespace string, name string, job *kubeflowv1.TFJob, data []byte) error
	DeleteTFJob(namespace string, name string) error

	CreateMPIJob(job *kubeflowv1.MPIJob) error
	GetMPIJob(namespace string, name string) (*kubeflowv1.MPIJob, error)
	UpdateMPIJob(namespace string, name string, job *kubeflowv1.MPIJob, data []byte) error
	DeleteMPIJob(namespace string, name string) error

	CreateXGBoostJob(job *kubeflowv1.XGBoostJob) error
	GetXGBoostJob(namespace string, name string) (*kubeflowv1.XGBoostJob, error)
	UpdateXGBoostJob(namespace string, name string, job *kubeflowv1.XGBoostJob, data []byte) error
	DeleteXGBoostJob(namespace string, name string) error

	CreatePaddleJob(job *kubeflowv1.PaddleJob) error
	GetPaddleJob(namespace string, name string) (*kubeflowv1.PaddleJob, error)
	UpdatePaddleJob(namespace string, name string, job *kubeflowv1.PaddleJob, data []byte) error
	DeletePaddleJob(namespace string, name string) error
}

func NewClient

func NewClient(cfg *restclient.Config) (Client, error)

New creates our client wrapper object for the actual kubeVirt and kubernetes clients we use.