org.openspaces.admin.internal.driver

Class KubernetesAdminDriver

java.lang.Object

org.openspaces.admin.internal.driver.InternalAdminDriver

org.openspaces.admin.internal.driver.KubernetesAdminDriver

public class KubernetesAdminDriver
extends InternalAdminDriver

Since:

15.5

Author:

Niv Ingberg

Nested Class Summary

Nested classes/interfaces inherited from class org.openspaces.admin.internal.driver.InternalAdminDriver

InternalAdminDriver.UndeployListener

Field Summary

Fields inherited from class org.openspaces.admin.internal.driver.InternalAdminDriver

admin, attributeStore, logger

Constructor Summary

Constructors

Constructor and Description
KubernetesAdminDriver(InternalAdmin admin)

Method Summary

Modifier and Type	Method and Description
protected void	beforeDeploy(ProcessingUnitConfig puConfig)
boolean	checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu, Integer partitionId, String memory, String cpu)
void	deleteSpaceInstancesPersistentData(UndeployedPuMetaData puMetaData, String spaceName, InternalSpaceDeleteInstancePersistentDataEventListener listener)
protected void	deploy(ProcessingUnitConfig puConfig, String applicationName)
com.gigaspaces.grid.gsm.PUDetails	getPuDetails(ProcessingUnit pu)
QuiesceManager	getQuiesceManager()
ResourcesWrapper	getResources(io.fabric8.kubernetes.api.model.apps.StatefulSet statefulSet)
ResourcesResponse	getResources(String serviceName, String partitionId)
protected boolean	implicitContainers()
boolean	isDeployed(String puName) For service grid only
protected boolean	isOrphanInstancesBeingProvisioned(String puName)
void	scaleIn(ProcessingUnit pu, int factor)
void	scaleOut(ProcessingUnit pu, int factor, String memory, String cpu)
void	scaleUpDownUnsafe(ProcessingUnit pu, Integer partitionId, String memory, String cpu, Long timeout, PuScaleVStatusChangedEventListener listener)
protected void	undeploy(String puName)
CompletableFuture<?>	undeployAsync(ProcessingUnit pu, UndeployOptions options)
void	validateScaleUpDownInput(String memory, String cpu)

Methods inherited from class org.openspaces.admin.internal.driver.InternalAdminDriver

afterDeploy, afterUndeploy, beforeUndeployK8s, deleteTieredStorageData, deploy, deploy, deploy, getUndeployedPu, getUnDeployedPus, hasZkNode, initNameIfNeeded, isPersistent, postDeploy, postUndeployK8s, preDeploy, scaleUpDown, setUndeployedInstanceIp, setUndeployedLeader, undeployAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesAdminDriver

public KubernetesAdminDriver(InternalAdmin admin)

Method Detail

getQuiesceManager

public QuiesceManager getQuiesceManager()

Specified by:

getQuiesceManager in class InternalAdminDriver

isDeployed

public boolean isDeployed(String puName)

Description copied from class: InternalAdminDriver

For service grid only

Specified by:

isDeployed in class InternalAdminDriver

undeployAsync

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

Overrides:

undeployAsync in class InternalAdminDriver

beforeDeploy

protected void beforeDeploy(ProcessingUnitConfig puConfig)

Overrides:

beforeDeploy in class InternalAdminDriver

deploy

protected void deploy(ProcessingUnitConfig puConfig,
                      String applicationName)

Specified by:

deploy in class InternalAdminDriver

deleteSpaceInstancesPersistentData

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

Specified by:

deleteSpaceInstancesPersistentData in class InternalAdminDriver

scaleIn

public void scaleIn(ProcessingUnit pu,
                    int factor)

Specified by:

scaleIn in class InternalAdminDriver

scaleOut

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

Specified by:

scaleOut in class InternalAdminDriver

getPuDetails

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

Specified by:

getPuDetails in class InternalAdminDriver

getResources

public ResourcesResponse getResources(String serviceName,
                                      String partitionId)

Specified by:

getResources in class InternalAdminDriver

getResources

public ResourcesWrapper getResources(io.fabric8.kubernetes.api.model.apps.StatefulSet statefulSet)

scaleUpDownUnsafe

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

Specified by:

scaleUpDownUnsafe in class InternalAdminDriver

checkIfPartitionHasAlreadyProvidedResource

public boolean checkIfPartitionHasAlreadyProvidedResource(ProcessingUnit pu,
                                                          Integer partitionId,
                                                          String memory,
                                                          String cpu)

Specified by:

checkIfPartitionHasAlreadyProvidedResource in class InternalAdminDriver

validateScaleUpDownInput

public void validateScaleUpDownInput(String memory,
                                     String cpu)

Specified by:

validateScaleUpDownInput in class InternalAdminDriver

undeploy

protected void undeploy(String puName)

Specified by:

undeploy in class InternalAdminDriver

isOrphanInstancesBeingProvisioned

protected boolean isOrphanInstancesBeingProvisioned(String puName)

Specified by:

isOrphanInstancesBeingProvisioned in class InternalAdminDriver

implicitContainers

protected boolean implicitContainers()

Specified by:

implicitContainers in class InternalAdminDriver