org.openspaces.admin.internal.driver

Class InternalAdminDriver

java.lang.Object

org.openspaces.admin.internal.driver.InternalAdminDriver

Direct Known Subclasses:

ElasticGridAdminDriver, KubernetesAdminDriver, ServiceGridAdminDriver

public abstract class InternalAdminDriver
extends Object

Since:

15.5

Author:

Niv Ingberg

Field Summary

Fields

Modifier and Type	Field and Description
protected InternalAdmin	admin
protected org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore	attributeStore
protected org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	InternalAdminDriver(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
protected void	afterDeploy(ProcessingUnit pu, ProcessingUnitConfig puConfig, long deadline)
protected void	afterUndeploy(ProcessingUnit pu, Collection<String> spaceNames)
protected void	beforeDeploy(ProcessingUnitConfig puConfig)
ProcessingUnit	deploy(ProcessingUnitConfigHolder puConfigHolder)
ProcessingUnit	deploy(ProcessingUnitConfigHolder puConfigHolder, String applicationName, long timeout, TimeUnit timeUnit)
protected abstract void	deploy(ProcessingUnitConfig puConfig, String applicationName)
ProcessingUnit	deploy(ProcessingUnitConfig puConfig, String applicationName, long timeout, TimeUnit timeUnit)
abstract List<File>	generateDump()
abstract QuiesceManager	getQuiesceManager()
abstract ResourcesResponse	getResources(String serviceName, String partitionId)
protected boolean	hasZkNode(String puName)
protected abstract boolean	implicitContainers()
abstract boolean	isDeployed(String puName) For service grid only
protected abstract boolean	isOrphanInstancesBeingProvisioned(String puName)
abstract void	scaleIn(ProcessingUnit pu, int factor)
abstract void	scaleOut(ProcessingUnit pu, int factor, String memory, String cpu)
void	scaleUpDown(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
protected abstract void	scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
protected abstract void	undeploy(String puName)
CompletableFuture<?>	undeployAsync(ProcessingUnit pu)
abstract void	validateScaleUpDownInput(String memory, String cpu)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.apache.commons.logging.Log logger

admin

protected final InternalAdmin admin

attributeStore

protected final org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore

Constructor Detail

InternalAdminDriver

protected InternalAdminDriver(InternalAdmin admin)

Method Detail

getQuiesceManager

public abstract QuiesceManager getQuiesceManager()

deploy

public ProcessingUnit deploy(ProcessingUnitConfigHolder puConfigHolder)

deploy

public ProcessingUnit deploy(ProcessingUnitConfigHolder puConfigHolder,
                             String applicationName,
                             long timeout,
                             TimeUnit timeUnit)

deploy

public ProcessingUnit deploy(ProcessingUnitConfig puConfig,
                             String applicationName,
                             long timeout,
                             TimeUnit timeUnit)

beforeDeploy

protected void beforeDeploy(ProcessingUnitConfig puConfig)
                     throws IOException

Throws:

IOException

isDeployed

public abstract boolean isDeployed(String puName)

For service grid only

hasZkNode

protected boolean hasZkNode(String puName)

undeployAsync

public CompletableFuture<?> undeployAsync(ProcessingUnit pu)

deploy

protected abstract void deploy(ProcessingUnitConfig puConfig,
                               String applicationName)

afterDeploy

protected void afterDeploy(ProcessingUnit pu,
                           ProcessingUnitConfig puConfig,
                           long deadline)
                    throws IOException

Throws:

IOException

afterUndeploy

protected void afterUndeploy(ProcessingUnit pu,
                             Collection<String> spaceNames)
                      throws IOException

Throws:

IOException

scaleIn

public abstract void scaleIn(ProcessingUnit pu,
                             int factor)

scaleOut

public abstract void scaleOut(ProcessingUnit pu,
                              int factor,
                              String memory,
                              String cpu)

scaleUpDownUnsafe

protected abstract void scaleUpDownUnsafe(ProcessingUnit pu,
                                          Integer partitionId,
                                          String memory,
                                          String cpu,
                                          Long timeout,
                                          PuScaleVStatusChangedEventListener listener)

scaleUpDown

public void scaleUpDown(ProcessingUnit pu,
                        Integer partitionId,
                        String memory,
                        String cpu,
                        Long timeout,
                        PuScaleVStatusChangedEventListener listener)

validateScaleUpDownInput

public abstract void validateScaleUpDownInput(String memory,
                                              String cpu)

getResources

public abstract ResourcesResponse getResources(String serviceName,
                                               String partitionId)

undeploy

protected abstract void undeploy(String puName)

isOrphanInstancesBeingProvisioned

protected abstract boolean isOrphanInstancesBeingProvisioned(String puName)

implicitContainers

protected abstract boolean implicitContainers()

generateDump

public abstract List<File> generateDump()