edu.iu.dsc.tws.examples.internal.rsched

Class K8sControllerExample

java.lang.Object

edu.iu.dsc.tws.examples.internal.rsched.K8sControllerExample

public final class K8sControllerExample
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static void	createCM(KubernetesController controller, JobAPI.Job job)
static void	createCMWatcher(KubernetesController controller, java.lang.String jobID)
static void	getJobFromConfigMap(KubernetesController controller, java.lang.String jobID)
static void	main(java.lang.String[] args)
static void	test1(JobAPI.Job job) test method
static void	testJM(KubernetesController controller, java.lang.String jobID)
static void	testPVC(Config config, KubernetesController controller, java.lang.String jobID)
static void	testUploader(Config config, KubernetesController controller, java.lang.String jobID)
static void	testWorker(KubernetesController controller, java.lang.String jobID, int wID)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

testUploader

public static void testUploader(Config config,
                                KubernetesController controller,
                                java.lang.String jobID)

testPVC

public static void testPVC(Config config,
                           KubernetesController controller,
                           java.lang.String jobID)

createCM

public static void createCM(KubernetesController controller,
                            JobAPI.Job job)

createCMWatcher

public static void createCMWatcher(KubernetesController controller,
                                   java.lang.String jobID)

getJobFromConfigMap

public static void getJobFromConfigMap(KubernetesController controller,
                                       java.lang.String jobID)

testWorker

public static void testWorker(KubernetesController controller,
                              java.lang.String jobID,
                              int wID)

testJM

public static void testJM(KubernetesController controller,
                          java.lang.String jobID)

test1

public static void test1(JobAPI.Job job)

test method