Package org.openspaces.admin.internal.driver

Class InternalAdminDriver

java.lang.Object

org.openspaces.admin.internal.driver.InternalAdminDriver

Direct Known Subclasses:

KubernetesAdminDriver, ServiceGridAdminDriver

public abstract class InternalAdminDriver
extends Object

Since:

15.5

Author:

Niv Ingberg

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	InternalAdminDriver.UndeployListener

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InternalAdminDriver(InternalAdmin admin)

Method Summary

Modifier and Type	Method	Description
protected void	afterDeploy(ProcessingUnit pu, long deadline)
protected void	afterUndeploy(String pu, Collection<String> spaceNames, int numberOfPlannedInstances)
protected void	beforeDeploy(ProcessingUnitConfig puConfig)
void	beforeUndeployK8s(ProcessingUnit pu, UndeployOptions options)
abstract boolean	checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu)
abstract void	deleteSpaceInstancesPersistentData(UndeployedPuMetaData puMetaData, String spaceName, InternalSpaceDeleteInstancePersistentDataEventListener listener)
void	deleteTieredStorageData(String puName, InternalSpaceDeleteInstancePersistentDataEventListener listener)
protected abstract void	deploy(ProcessingUnitConfig puConfig, String applicationName)
ProcessingUnit	deploy(ProcessingUnitConfig puConfig, String applicationName, long timeout, TimeUnit timeUnit)
ProcessingUnit	deploy(ProcessingUnitConfigHolder puConfigHolder)
ProcessingUnit	deploy(ProcessingUnitConfigHolder puConfigHolder, String applicationName, long timeout, TimeUnit timeUnit)
abstract com.gigaspaces.grid.gsm.PUDetails	getPuDetails(ProcessingUnit pu)
abstract QuiesceManager	getQuiesceManager()
abstract ResourcesResponse	getResources(String serviceName, String partitionId)
UndeployedPuMetaData	getUndeployedPu(String puName)
List<UndeployedPuMetaData>	getUnDeployedPus()
protected boolean	hasZkNode(String puName)
protected abstract boolean	implicitContainers()
protected String	initNameIfNeeded(ProcessingUnitConfig puConfig)
abstract boolean	isDeployed(String puName)	For service grid only
protected abstract boolean	isOrphanInstancesBeingProvisioned(String puName)
protected boolean	isPersistent(String puName)
void	postDeploy(ProcessingUnit pu)	This method is intended for usage by kubernetes operator only - the operator calls predeploy, performs the actual provisioning, then calls postdeploy
void	postUndeployK8s(String puName)
void	preDeploy(ProcessingUnitConfigHolder puConfigHolder, boolean deleteMetadata)	This method is intended for usage by kubernetes operator only - the operator calls predeploy, performs the actual provisioning, then calls postdeploy
abstract void	scaleIn(ProcessingUnit pu, int factor, String memory, String cpu)
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)
void	setUndeployedInstanceIp(String puName, String instanceId, String ip, boolean validateHost)
void	setUndeployedLeader(String puName, int partitionId, String instanceId)
abstract SpaceCfg	toCfg(String id)
protected abstract void	undeploy(String puName)
CompletableFuture<?>	undeployAsync(ProcessingUnit pu)
CompletableFuture<?>	undeployAsync(ProcessingUnit pu, UndeployOptions options)
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 Details

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 Details

InternalAdminDriver

protected InternalAdminDriver(InternalAdmin admin)

Method Details

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)

preDeploy

public void preDeploy(ProcessingUnitConfigHolder puConfigHolder,
 boolean deleteMetadata)

This method is intended for usage by kubernetes operator only - the operator calls predeploy, performs the actual provisioning, then calls postdeploy

Since:

16.0

postDeploy

public void postDeploy(ProcessingUnit pu)

This method is intended for usage by kubernetes operator only - the operator calls predeploy, performs the actual provisioning, then calls postdeploy

Since:

16.0

beforeUndeployK8s

public void beforeUndeployK8s(ProcessingUnit pu,
 UndeployOptions options)

postUndeployK8s

public void postUndeployK8s(String puName)

initNameIfNeeded

protected String initNameIfNeeded(ProcessingUnitConfig puConfig)

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)

isPersistent

protected boolean isPersistent(String puName)
                        throws IOException

Throws:

IOException

undeployAsync

public CompletableFuture<?> undeployAsync(ProcessingUnit pu)

undeployAsync

public CompletableFuture<?> undeployAsync(ProcessingUnit pu,
 UndeployOptions options)

deploy

protected abstract void deploy(ProcessingUnitConfig puConfig,
 String applicationName)

toCfg

public abstract SpaceCfg toCfg(String id)

afterDeploy

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

Throws:

IOException

afterUndeploy

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

Throws:

IOException

getUnDeployedPus

public List<UndeployedPuMetaData> getUnDeployedPus()

getUndeployedPu

public UndeployedPuMetaData getUndeployedPu(String puName)
                                     throws IOException

Throws:

IOException

setUndeployedLeader

public void setUndeployedLeader(String puName,
 int partitionId,
 String instanceId)

setUndeployedInstanceIp

public void setUndeployedInstanceIp(String puName,
 String instanceId,
 String ip,
 boolean validateHost)

deleteTieredStorageData

public void deleteTieredStorageData(String puName,
 InternalSpaceDeleteInstancePersistentDataEventListener listener)

deleteSpaceInstancesPersistentData

public abstract void deleteSpaceInstancesPersistentData(UndeployedPuMetaData puMetaData,
 String spaceName,
 InternalSpaceDeleteInstancePersistentDataEventListener listener)
                                                 throws AdminException

Throws:

AdminException

scaleIn

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

scaleOut

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

getPuDetails

public abstract com.gigaspaces.grid.gsm.PUDetails getPuDetails(ProcessingUnit pu)
                                                        throws RemoteException

Throws:

RemoteException

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)

checkIfPartitionHasAlreadyProvidedResource

public abstract boolean checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu,
 Integer partitionId,
 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()