k8saccesser

Documentation

Index

• Constants
• func GetK8sResourceAccesser() *k8sResourceAccesser
• func InitK8sResourceAccesser(config *rest.Config, clientset *kubernetes.Clientset, isDaemonMode bool) error
• func NewK8sResourceAccesser(config *rest.Config, clientset *kubernetes.Clientset, isDaemonMode bool) (*k8sResourceAccesser, error)

Constants

const (
	TensorflowCRDName             = "tfjobs.kubeflow.org"
	TensorflowCRDNameInDaemonMode = "TFJob.kubeflow.org"

	MPICRDName             = "mpijobs.kubeflow.org"
	MPICRDNameInDaemonMode = "MPIJob.kubeflow.org"

	PytorchCRDName             = "pytorchjobs.kubeflow.org"
	PytorchCRDNameInDaemonMode = "PyTorchJob.kubeflow.org"

	ETCRDName             = "trainingjobs.kai.alibabacloud.com"
	ETCRDNameInDaemonMode = "TrainingJob.kai.alibabacloud.com"

	VolcanoCRDName             = "jobs.batch.volcano.sh"
	VolcanoCRDNameInDaemonMode = "Job.batch.volcano.sh"

	SparkCRDNameInDaemonMode = "Sparkapplication.sparkoperator.k8s.io"
	SparkCRDName             = "sparkapplications.sparkoperator.k8s.io"

	RayJobCRDName             = "rayjobs.ray.io"
	RayJobCRDNameInDaemonMode = "RayJob.ray.io"

	LWSCRDName             = "leaderworkersets.leaderworkerset.x-k8s.io"
	LWSCRDNameInDaemonMode = "Leaderworkerset.leaderworkerset.x-k8s.io"
)

Functions

func GetK8sResourceAccesser

func GetK8sResourceAccesser() *k8sResourceAccesser

func InitK8sResourceAccesser

func InitK8sResourceAccesser(config *rest.Config, clientset *kubernetes.Clientset, isDaemonMode bool) error

func NewK8sResourceAccesser

func NewK8sResourceAccesser(config *rest.Config, clientset *kubernetes.Clientset, isDaemonMode bool) (*k8sResourceAccesser, error)