edu.iu.dsc.tws.rsched.schedulers.k8s.driver

Class K8sScaler

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.k8s.driver.K8sScaler

All Implemented Interfaces:

IScalerPerCluster

public class K8sScaler
extends java.lang.Object
implements IScalerPerCluster

Constructor Summary

Constructors

Constructor and Description
K8sScaler(Config config, JobAPI.Job job, KubernetesController k8sController)

Method Summary

Modifier and Type	Method and Description
boolean	isScalable() whether this job is scalable
boolean	scaleDownWorkers(int instancesToRemove, int numberOfWorkers) remove workers from the scalable compute resource
boolean	scaleUpWorkers(int instancesToAdd) add new workers to the scalable compute resource

Methods inherited from class java.lang.Object

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

Constructor Detail

K8sScaler

public K8sScaler(Config config,
                 JobAPI.Job job,
                 KubernetesController k8sController)

Method Detail

isScalable

public boolean isScalable()

Description copied from interface: IScalerPerCluster

whether this job is scalable

Specified by:

isScalable in interface IScalerPerCluster

Returns:

true if scalable

scaleUpWorkers

public boolean scaleUpWorkers(int instancesToAdd)

add new workers to the scalable compute resource

Specified by:

scaleUpWorkers in interface IScalerPerCluster

Returns:

scaleDownWorkers

public boolean scaleDownWorkers(int instancesToRemove,
                                int numberOfWorkers)

remove workers from the scalable compute resource

Specified by:

scaleDownWorkers in interface IScalerPerCluster

Parameters:

instancesToRemove -

numberOfWorkers - number of workers before the scale down

Returns: