k8s_client

Documentation

Index

• Variables
• func AbortTask(executionId uuid.UUID) error
• func BuildJobName(taskEx *models.TaskExecution) string
• func ConnectToK8SInCluster() *kubernetes.Clientset
• func ConnectToK8s(kubeConfigPath *string) *kubernetes.Clientset
• func GetJobStatus(executionId uuid.UUID) (models.Status, error)
• func InitK8SClientSet(kubeConfigPath *string)
• func LaunchK8sJob(jobName *string, taskEx *models.TaskExecution)

Variables

var ClientSet *kubernetes.Clientset

Functions

func AbortTask

func AbortTask(executionId uuid.UUID) error

func BuildJobName

func BuildJobName(taskEx *models.TaskExecution) string

func ConnectToK8SInCluster

func ConnectToK8SInCluster() *kubernetes.Clientset

func ConnectToK8s

func ConnectToK8s(kubeConfigPath *string) *kubernetes.Clientset

func GetJobStatus

func GetJobStatus(executionId uuid.UUID) (models.Status, error)

func InitK8SClientSet

func InitK8SClientSet(kubeConfigPath *string)

func LaunchK8sJob

func LaunchK8sJob(
	jobName *string,
	taskEx *models.TaskExecution,
)