GigaSpaces XAP 9.7.2 API

org.openspaces.admin.pu
Class ProcessingUnitDeployment

java.lang.Object
  extended by org.openspaces.admin.pu.ProcessingUnitDeployment
All Implemented Interfaces:
ProcessingUnitDeploymentTopology

public class ProcessingUnitDeployment
extends Object
implements ProcessingUnitDeploymentTopology

A deployment of processing unit.

Author:
kimchy
See Also:
GridServiceManager.deploy(ProcessingUnitDeployment), GridServiceManagers.deploy(ProcessingUnitDeployment)

Constructor Summary
ProcessingUnitDeployment(File processingUnit)
          Constructs a processing unit deployment based on the specified processing unit file path (points either to a processing unit jar/zip file or a directory).
ProcessingUnitDeployment(String processingUnitName)
          Constructs a processing unit deployment based on the specified processing unit name (should exists under the [GS ROOT]/deploy directory.
 
Method Summary
 ProcessingUnitDeployment addDependencies(org.openspaces.admin.internal.pu.dependency.ProcessingUnitDetailedDependencies<? extends ProcessingUnitDependency> detailedDependencies)
          Postpones deployment of processing unit instances until the specified dependencies are met.
 ProcessingUnitDeployment addDependency(String requiredProcessingUnitName)
          Postpones deployment of processing unit instances deployment until the specified processing unit deployment is complete.
 ProcessingUnitDeployment addZone(String zone)
          Adds a zone where the processing unit is allowed to be deployed on.
 ProcessingUnitDeployment clusterSchema(String clusterSchema)
          Controls the cluster schema of the deployment.
 ProcessingUnitConfigHolder create()
          Converts this fluent API object to a lazy implementation of ProcessingUnitConfig
 String[] getDeploymentOptions()
          Deprecated. 
 Map<String,String> getElasticProperties()
          Deprecated. 
 String getProcessingUnit()
          Deprecated. 
 UserDetails getUserDetails()
          Deprecated. 
 Boolean isSecured()
           
 ProcessingUnitDeployment maxInstancesPerMachine(int maxInstancesPerMachine)
          Sets the maximum number of instances per machine.
 ProcessingUnitDeployment maxInstancesPerVM(int maxInstancesPerVM)
          Sets the maximum number of instances per java virtual machine.
 ProcessingUnitDeployment maxInstancesPerZone(String zone, int maxInstancesPerZone)
          Sets the maximum number of instances per zone.
 ProcessingUnitDeployment name(String name)
          Sets the processing unit name that will be deployed.
 ProcessingUnitDeployment numberOfBackups(int numberOfBackups)
          Sets the number of backups that will be deployed as part of this processing unit.
 ProcessingUnitDeployment numberOfInstances(int numberOfInstances)
          Sets the number of instances that will be deployed as part of this processing unit instance.
 ProcessingUnitDeployment partitioned(int numberOfParitions, int numberOfBackups)
          A convenient method allowing to easily configure the space deployment to deploy a partitioned topology with numberOfParitions instances each with numberOfBackups.
 ProcessingUnitDeployment primaryZone(String zone)
          Set the primary zone where the processing unit is allowed to be deployed on.
 ProcessingUnitDeployment replicated(boolean async, int numberOfInstances)
          A convenient method allowing to easily configure the space deployment to deploy a replicated (either sync or async) topology with numberOfInstances instances.
 ProcessingUnitDeployment secured(boolean secured)
          Will deploy a secured processing unit.
 ProcessingUnitDeployment setContextProperty(String key, String value)
          Sets a context deploy time property overriding any ${...}
 void setDependencies(ProcessingUnitDependencies<ProcessingUnitDependency> dependencies)
           
 ProcessingUnitDeployment setElasticProperty(String key, String value)
           
 ProcessingUnitDeployment slaLocation(File slaLocation)
          Sets an external SLA definition location to be loaded.
 ProcessingUnitDeployment slaLocation(String slaLocation)
          Sets an external SLA definition location to be loaded.
 ProcessingUnitDeployment userDetails(String userName, String password)
          Sets the username and password (effectively making the processing unit secured) for the processing unit deployment.
 ProcessingUnitDeployment userDetails(UserDetails userDetails)
          Sets the security user details for authentication and authorization of the processing unit.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ProcessingUnitDeployment

public ProcessingUnitDeployment(String processingUnitName)
Constructs a processing unit deployment based on the specified processing unit name (should exists under the [GS ROOT]/deploy directory.


ProcessingUnitDeployment

public ProcessingUnitDeployment(File processingUnit)
Constructs a processing unit deployment based on the specified processing unit file path (points either to a processing unit jar/zip file or a directory).

Method Detail

getProcessingUnit

@Deprecated
public String getProcessingUnit()
Deprecated. 

Returns the processing unit that will be deployed. Use ProcessingUnitConfig.getProcessingUnit() instead


name

public ProcessingUnitDeployment name(String name)
Sets the processing unit name that will be deployed. By default it will be based on the parameter passed in the constructor.


partitioned

public ProcessingUnitDeployment partitioned(int numberOfParitions,
                                            int numberOfBackups)
A convenient method allowing to easily configure the space deployment to deploy a partitioned topology with numberOfParitions instances each with numberOfBackups.

Exactly the same like calling clusterSchema("partitioned-sync2backup"), followed by numberOfInstances(numberOfParitions) and numberOfBackups(numberOfBackups).

Parameters:
numberOfParitions - The number of partitions
numberOfBackups - The number of backups
Returns:
This space deployment

replicated

public ProcessingUnitDeployment replicated(boolean async,
                                           int numberOfInstances)
A convenient method allowing to easily configure the space deployment to deploy a replicated (either sync or async) topology with numberOfInstances instances.

Exactly the same like calling clusterSchema("sync_replicated") or clusterSchema("async_replicated"), followed by numberOfInstances(numberOfInstances) and numberOfBackups(0).

Parameters:
numberOfInstances - The number of instances to form the replicated space
Returns:
This space deployment

clusterSchema

public ProcessingUnitDeployment clusterSchema(String clusterSchema)
Controls the cluster schema of the deployment. Only make sense to set it when there is an embedded space defined within the processing unit.


numberOfInstances

public ProcessingUnitDeployment numberOfInstances(int numberOfInstances)
Sets the number of instances that will be deployed as part of this processing unit instance. In case of partitioned-sync2backup, defines the number of partitions.


numberOfBackups

public ProcessingUnitDeployment numberOfBackups(int numberOfBackups)
Sets the number of backups that will be deployed as part of this processing unit. Only applicable when the processing unit has an embedded space.


maxInstancesPerVM

public ProcessingUnitDeployment maxInstancesPerVM(int maxInstancesPerVM)
Sets the maximum number of instances per java virtual machine.

On partitioned topology with backups topology, controls that a primary and a backup won't run on the same java virtual machine if set to 1.

On a non partitioned with backups topology, controls the maximum number of instances running on the same java virtual machine.


maxInstancesPerMachine

public ProcessingUnitDeployment maxInstancesPerMachine(int maxInstancesPerMachine)
Sets the maximum number of instances per machine.

On partitioned topology with backups topology, controls that a primary and a backup won't run on the same machine if set to 1.

On a non partitioned with backups topology, controls the maximum number of instances running on the same machine.


maxInstancesPerZone

public ProcessingUnitDeployment maxInstancesPerZone(String zone,
                                                    int maxInstancesPerZone)
Sets the maximum number of instances per zone.

On partitioned topology with backups topology, controls that a primary and a backup won't run on the same zone if set to 1. Note, for each zone this will have to be set.

On a non partitioned with backups topology, controls the maximum number of instances running on the same zone.


addZone

public ProcessingUnitDeployment addZone(String zone)
Adds a zone where the processing unit is allowed to be deployed on.


primaryZone

public ProcessingUnitDeployment primaryZone(String zone)
Set the primary zone where the processing unit is allowed to be deployed on.


setContextProperty

public ProcessingUnitDeployment setContextProperty(String key,
                                                   String value)
Sets a context deploy time property overriding any ${...} defined within a processing unit configuration.


secured

public ProcessingUnitDeployment secured(boolean secured)
Will deploy a secured processing unit. Note, by setting user details the processing unit will be secured automatically.

Specified by:
secured in interface ProcessingUnitDeploymentTopology

userDetails

public ProcessingUnitDeployment userDetails(UserDetails userDetails)
Sets the security user details for authentication and authorization of the processing unit.

Specified by:
userDetails in interface ProcessingUnitDeploymentTopology

slaLocation

public ProcessingUnitDeployment slaLocation(String slaLocation)
Sets an external SLA definition location to be loaded.


slaLocation

public ProcessingUnitDeployment slaLocation(File slaLocation)
Sets an external SLA definition location to be loaded.


userDetails

public ProcessingUnitDeployment userDetails(String userName,
                                            String password)
Sets the username and password (effectively making the processing unit secured) for the processing unit deployment.

Specified by:
userDetails in interface ProcessingUnitDeploymentTopology

isSecured

public Boolean isSecured()

getUserDetails

@Deprecated
public UserDetails getUserDetails()
Deprecated. 

Use ProcessingUnitConfig.getUserDetails() instead


addDependencies

public ProcessingUnitDeployment addDependencies(org.openspaces.admin.internal.pu.dependency.ProcessingUnitDetailedDependencies<? extends ProcessingUnitDependency> detailedDependencies)
Postpones deployment of processing unit instances until the specified dependencies are met. The following example postpones the deployment of this processing unit until B has completed the deployment and C has at least one instance deployed. deployment.addDependencies(new ProcessingUnitDeploymentDependenciesConfigurer().dependsOnDeployment("B").dependsOnMinimumNumberOfDeployedInstances("C",1).create())

Specified by:
addDependencies in interface ProcessingUnitDeploymentTopology
Since:
8.0.6
See Also:
ProcessingUnitDeploymentDependenciesConfigurer

addDependency

public ProcessingUnitDeployment addDependency(String requiredProcessingUnitName)
Postpones deployment of processing unit instances deployment until the specified processing unit deployment is complete. Same as: deployment.addDependencies(new ProcessingUnitDeploymentDependenciesConfigurer().dependsOnDeployment(requiredProcessingUnitName).create())

Specified by:
addDependency in interface ProcessingUnitDeploymentTopology
Since:
8.0.6

getDeploymentOptions

@Deprecated
public String[] getDeploymentOptions()
Deprecated. 

Transforms this deployment into a set of deployment options. Use ProcessingUnitConfig.toDeploymentOptions()


setElasticProperty

public ProcessingUnitDeployment setElasticProperty(String key,
                                                   String value)

setDependencies

public void setDependencies(ProcessingUnitDependencies<ProcessingUnitDependency> dependencies)

getElasticProperties

@Deprecated
public Map<String,String> getElasticProperties()
Deprecated. 

Use ProcessingUnitConfig.getElasticProperties() instead


create

public ProcessingUnitConfigHolder create()
Description copied from interface: ProcessingUnitDeploymentTopology
Converts this fluent API object to a lazy implementation of ProcessingUnitConfig

Specified by:
create in interface ProcessingUnitDeploymentTopology

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.