org.openspaces.admin.gsm

Interface GridServiceManager

All Superinterfaces:

AdminAware, AgentGridComponent, DiscoverableComponent, DumpProvider, GridComponent, LogProviderGridComponent, MachineAware, MetricProvider, OperatingSystemAware, TransportAware, VirtualMachineAware, ZoneAware

All Known Subinterfaces:

InternalGridServiceManager

All Known Implementing Classes:

DefaultGridServiceManager

public interface GridServiceManager
extends AgentGridComponent, LogProviderGridComponent, DumpProvider, MetricProvider

A Grid Service Manager is a manager for ProcessingUnit deployments (acting either as primary or backups for a certain processing unit deployment). It also knows which GridServiceContainers are around to be able to create ProcessingUnitInstance on them.

Author:

kimchy

Method Summary

Modifier and Type	Method and Description
boolean	deleteResource(String resourceName)
Map<String,String>	deleteUndeployedPuData(String puName) Delete data of a given undeployed tiered storage processing unit
Application	deploy(ApplicationConfig applicationConfig) Deploys an application consisting of one or more processing unit deployments.
Application	deploy(ApplicationConfig applicationConfig, long timeout, TimeUnit timeUnit) Deploys an application consisting of one or more processing unit deployments.
Application	deploy(ApplicationDeployment deployment) Deploys an application consisting of one or more processing unit deployments.
Application	deploy(ApplicationDeployment deployment, long timeout, TimeUnit timeUnit) Deploys an application consisting of one or more processing unit deployments.
ProcessingUnit	deploy(ElasticSpaceDeployment deployment) Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.
ProcessingUnit	deploy(ElasticSpaceDeployment deployment, long timeout, TimeUnit timeUnit) Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.
ProcessingUnit	deploy(ElasticStatefulProcessingUnitDeployment deployment) Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.
ProcessingUnit	deploy(ElasticStatefulProcessingUnitDeployment deployment, long timeout, TimeUnit timeUnit) Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.
ProcessingUnit	deploy(ElasticStatelessProcessingUnitDeployment deployment) Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.
ProcessingUnit	deploy(ElasticStatelessProcessingUnitDeployment deployment, long timeout, TimeUnit timeUnit) Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.
ProcessingUnit	deploy(MemcachedDeployment deployment) Deploys a memcached based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).
ProcessingUnit	deploy(MemcachedDeployment deployment, long timeout, TimeUnit timeUnit) Deploys a memcached based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).
ProcessingUnit	deploy(ProcessingUnitConfigHolder puConfigHolder) Deploys a new processing unit based on the specified configuration
ProcessingUnit	deploy(ProcessingUnitConfigHolder puConfigHolder, long timeout, TimeUnit timeUnit) Deploys a new processing unit based on the specified configuration
ProcessingUnit	deploy(ProcessingUnitDeployment deployment) Deploys a processing unit based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).
ProcessingUnit	deploy(ProcessingUnitDeployment deployment, long timeout, TimeUnit timeUnit) Deploys a processing unit based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).
ProcessingUnit	deploy(SpaceDeployment deployment) Deploys a space based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).
ProcessingUnit	deploy(SpaceDeployment deployment, long timeout, TimeUnit timeUnit) Deploys a space based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).
List<UndeployedPuMetaData>	getUnDeployedPus()
boolean	isActiveManager()
boolean	isDeployed(String processingUnitName) Determine if this deployment is known to this GSM.
void	setUndeployedInstanceIp(String puName, String instanceId, String ip, boolean validateHost) Set ip of an instance in an undeployed tiered storage processing unit.
void	setUndeployedLeader(String puName, int partitionId, String instanceId) Set leader of a partition in an undeployed tiered storage processing unit.
void	undeploy(String processingUnitName) Deprecated. Since 15.5 - use @ProcessingUnit.undeployAsync() instead.

Methods inherited from interface org.openspaces.admin.AgentGridComponent

getAgentId, getGridServiceAgent, kill, restart

Methods inherited from interface org.openspaces.admin.LogProviderGridComponent

logEntries, logEntriesDirect

Methods inherited from interface org.openspaces.admin.GridComponent

getUid

Methods inherited from interface org.openspaces.admin.DiscoverableComponent

isDiscovered

Methods inherited from interface org.openspaces.admin.AdminAware

getAdmin

Methods inherited from interface org.openspaces.admin.machine.MachineAware

getMachine

Methods inherited from interface org.openspaces.admin.transport.TransportAware

getTransport

Methods inherited from interface org.openspaces.admin.os.OperatingSystemAware

getOperatingSystem

Methods inherited from interface org.openspaces.admin.vm.VirtualMachineAware

getVirtualMachine

Methods inherited from interface org.openspaces.admin.zone.ZoneAware

getZones

Methods inherited from interface org.openspaces.admin.dump.DumpProvider

generateDump, generateDump

Methods inherited from interface org.openspaces.admin.metrics.MetricProvider

reloadMetricConfiguration

Method Detail

undeploy

@Deprecated
void undeploy(String processingUnitName)

Deprecated. Since 15.5 - use @ProcessingUnit.undeployAsync() instead.

Undeploys the processing unit based on its name. // wait for the lookup event of the processing unit by name. ProcessingUnit pu = admin.getProcessingUnits().waitFor("mypuname"); // wait for the lookup event of the grid service manager that manages the processing unit. pu.waitForManaged(); // undeploy the processing unit. pu.undeploy();

deploy

ProcessingUnit deploy(ProcessingUnitDeployment deployment)
               throws ProcessingUnitAlreadyDeployedException

Deploys a processing unit based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait indefinitely and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

ProcessingUnit deploy(ProcessingUnitDeployment deployment,
                      long timeout,
                      TimeUnit timeUnit)
               throws ProcessingUnitAlreadyDeployedException

Deploys a processing unit based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

ProcessingUnit deploy(SpaceDeployment deployment)
               throws ProcessingUnitAlreadyDeployedException

Deploys a space based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait indefinitely and return the actual processing unit that can be used.

Note, deploying just a space is simply deploying a built in processing unit that starts just an embedded space.

Throws:

ProcessingUnitAlreadyDeployedException

deploy

ProcessingUnit deploy(SpaceDeployment deployment,
                      long timeout,
                      TimeUnit timeUnit)
               throws ProcessingUnitAlreadyDeployedException

Deploys a space based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Note, deploying just a space is simply deploying a built in processing unit that starts just an embedded space.

Throws:

ProcessingUnitAlreadyDeployedException

deploy

ProcessingUnit deploy(MemcachedDeployment deployment)
               throws ProcessingUnitAlreadyDeployedException

Deploys a memcached based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait indefinitely and return the actual processing unit that can be used.

Note, deploying just a memcached is simply deploying a built in processing unit that starts / connects to a space (holding the memcached entries) and exposing the memcached protocol.

Throws:

ProcessingUnitAlreadyDeployedException

deploy

ProcessingUnit deploy(MemcachedDeployment deployment,
                      long timeout,
                      TimeUnit timeUnit)
               throws ProcessingUnitAlreadyDeployedException

Deploys a memcached based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Note, deploying just a memcached is simply deploying a built in processing unit that starts / connects to a space (holding the memcached entries) and exposing the memcached protocol.

Throws:

ProcessingUnitAlreadyDeployedException

deploy

@Deprecated
ProcessingUnit deploy(ElasticSpaceDeployment deployment)
                           throws ProcessingUnitAlreadyDeployedException

Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.

Deploys an elastic space based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait indefinitely and return the actual processing unit that can be used.

Note, deploying just a space is simply deploying a built in processing unit that starts just an embedded space.

Throws:

ProcessingUnitAlreadyDeployedException

deploy

@Deprecated
ProcessingUnit deploy(ElasticSpaceDeployment deployment,
                                  long timeout,
                                  TimeUnit timeUnit)
                           throws ProcessingUnitAlreadyDeployedException

Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.

Deploys an elastic space based on the space deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Note, deploying just a space is simply deploying a built in processing unit that starts just an embedded space.

Throws:

ProcessingUnitAlreadyDeployedException

deploy

@Deprecated
ProcessingUnit deploy(ElasticStatefulProcessingUnitDeployment deployment)
                           throws ProcessingUnitAlreadyDeployedException

Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.

Deploys an elastic processing unit that has an embedded space based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait indefinitely and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

@Deprecated
ProcessingUnit deploy(ElasticStatefulProcessingUnitDeployment deployment,
                                  long timeout,
                                  TimeUnit timeUnit)
                           throws ProcessingUnitAlreadyDeployedException

Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.

Deploys an elastic processing unit that has an embedded space based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

@Deprecated
ProcessingUnit deploy(ElasticStatelessProcessingUnitDeployment deployment)
                           throws ProcessingUnitAlreadyDeployedException

Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.

Deploys an elastic processing unit that does not have an embedded space based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait indefinitely and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

@Deprecated
ProcessingUnit deploy(ElasticStatelessProcessingUnitDeployment deployment,
                                  long timeout,
                                  TimeUnit timeUnit)
                           throws ProcessingUnitAlreadyDeployedException

Deprecated. Since 12.1 - Elastic deployments support will be replaced with a different solution in upcoming releases, contact support for additional information.

Deploys an elastic processing unit that does not have an embedded space based on the processing unit deployment information on the given grid service manager (it will act as the primary GSM for the deployed processing unit).

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

Application deploy(ApplicationDeployment deployment)
            throws ApplicationAlreadyDeployedException,
                   ProcessingUnitAlreadyDeployedException

Deploys an application consisting of one or more processing unit deployments.

The deployment process will wait indefinitely

Returns:

An application containing the actual processing units that can be used.

Throws:

ApplicationAlreadyDeployedException - - Application with the same name has already been deployed.

ProcessingUnitAlreadyDeployedException - - Processing unit with the same name has already been deployed. Processing Unit names are globally unique (regardless of the application name)

deploy

Application deploy(ApplicationDeployment deployment,
                   long timeout,
                   TimeUnit timeUnit)
            throws ApplicationAlreadyDeployedException,
                   ProcessingUnitAlreadyDeployedException

Deploys an application consisting of one or more processing unit deployments.

The deployment process will wait for the given timeout

Returns:

An application containing the actual processing units that can be used or null if timeout expired.

Throws:

ApplicationAlreadyDeployedException - - Application with the same name has already been deployed.

ProcessingUnitAlreadyDeployedException - - Processing unit with the same name has already been deployed. Processing Unit names are globally unique (regardless of the application name)

deploy

ProcessingUnit deploy(ProcessingUnitConfigHolder puConfigHolder)

Deploys a new processing unit based on the specified configuration

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

deploy

ProcessingUnit deploy(ProcessingUnitConfigHolder puConfigHolder,
                      long timeout,
                      TimeUnit timeUnit)

Deploys a new processing unit based on the specified configuration

The deployment process will wait for the given timeout and return the actual processing unit that can be used.

Throws:

ProcessingUnitAlreadyDeployedException - - processing unit with the same name has already been deployed.

isDeployed

boolean isDeployed(String processingUnitName)

Determine if this deployment is known to this GSM.

Parameters:

processingUnitName - the name of the deployed processing unit.

Returns:

true if this deployment is known; false otherwise.

deploy

Application deploy(ApplicationConfig applicationConfig)

Deploys an application consisting of one or more processing unit deployments.

The deployment process will wait indefinitely

Returns:

An application containing the actual processing units that can be used.

Throws:

ApplicationAlreadyDeployedException - - Application with the same name has already been deployed.

ProcessingUnitAlreadyDeployedException - - Processing unit with the same name has already been deployed. Processing Unit names are globally unique (regardless of the application name)

deploy

Application deploy(ApplicationConfig applicationConfig,
                   long timeout,
                   TimeUnit timeUnit)
            throws ApplicationAlreadyDeployedException,
                   ProcessingUnitAlreadyDeployedException

Deploys an application consisting of one or more processing unit deployments.

The deployment process will wait for the given timeout

Returns:

An application configuration containing the actual processing units that can be used or null if timeout expired.

Throws:

ApplicationAlreadyDeployedException - - Application with the same name has already been deployed.

ProcessingUnitAlreadyDeployedException - - Processing unit with the same name has already been deployed. Processing Unit names are globally unique (regardless of the application name)

isActiveManager

boolean isActiveManager()

Returns:

true if managing at least one deployment ; false otherwise

Since:

12.1

deleteResource

boolean deleteResource(String resourceName)

Returns:

true if successfully deleted the resource folder from the deploy folder ; false otherwise

Since:

12.1

getUnDeployedPus

List<UndeployedPuMetaData> getUnDeployedPus()

Returns:

List of persistent undeployed processing units

deleteUndeployedPuData

Map<String,String> deleteUndeployedPuData(String puName)

Delete data of a given undeployed tiered storage processing unit

Returns:

response of deletion status for each pu instance

setUndeployedLeader

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

Set leader of a partition in an undeployed tiered storage processing unit.

Throws:

AdminException - - failed to find undeployed processing unit / partition id / instance id

setUndeployedInstanceIp

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

Set ip of an instance in an undeployed tiered storage processing unit.

Throws:

AdminException - - failed to find undeployed processing unit / partition id / instance id