public abstract class InternalAdminDriver extends Object
Modifier and Type | Field and Description |
---|---|
protected InternalAdmin |
admin |
protected org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore |
attributeStore |
protected org.apache.commons.logging.Log |
logger |
Modifier | Constructor and Description |
---|---|
protected |
InternalAdminDriver(InternalAdmin admin) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterDeploy(ProcessingUnit pu,
ProcessingUnitConfig puConfig,
long deadline) |
protected void |
afterUndeploy(String puName,
Collection<String> spaceNames) |
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 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,
Integer memory,
Integer cpu) |
abstract void |
scaleUpDown(ProcessingUnit pu,
List<Integer> partitionsIds,
String memory,
String cpu,
PuScaleVStatusChangedEventListener listener) |
protected abstract void |
undeploy(String puName) |
CompletableFuture<?> |
undeployAsync(ProcessingUnit pu) |
protected final org.apache.commons.logging.Log logger
protected final InternalAdmin admin
protected final org.openspaces.zookeeper.attribute_store.ZooKeeperAttributeStore attributeStore
protected InternalAdminDriver(InternalAdmin admin)
public abstract QuiesceManager getQuiesceManager()
public ProcessingUnit deploy(ProcessingUnitConfigHolder puConfigHolder)
public ProcessingUnit deploy(ProcessingUnitConfigHolder puConfigHolder, String applicationName, long timeout, TimeUnit timeUnit)
public ProcessingUnit deploy(ProcessingUnitConfig puConfig, String applicationName, long timeout, TimeUnit timeUnit)
public abstract boolean isDeployed(String puName)
protected boolean hasZkNode(String puName)
public CompletableFuture<?> undeployAsync(ProcessingUnit pu)
protected abstract void deploy(ProcessingUnitConfig puConfig, String applicationName)
protected void afterDeploy(ProcessingUnit pu, ProcessingUnitConfig puConfig, long deadline) throws IOException
IOException
protected void afterUndeploy(String puName, Collection<String> spaceNames) throws IOException
IOException
public abstract void scaleIn(ProcessingUnit pu, int factor)
public abstract void scaleOut(ProcessingUnit pu, int factor, Integer memory, Integer cpu)
public abstract void scaleUpDown(ProcessingUnit pu, List<Integer> partitionsIds, String memory, String cpu, PuScaleVStatusChangedEventListener listener)
public abstract ResourcesResponse getResources(String serviceName, String partitionId)
protected abstract void undeploy(String puName)
protected abstract boolean isOrphanInstancesBeingProvisioned(String puName)
protected abstract boolean implicitContainers()
Copyright © GigaSpaces.