org.springframework.xd.dirt.server

Class DefaultStateCalculator

java.lang.Object

org.springframework.xd.dirt.server.DefaultStateCalculator

All Implemented Interfaces:

DeploymentUnitStateCalculator

public class DefaultStateCalculator
extends java.lang.Object
implements DeploymentUnitStateCalculator

Default DeploymentUnitStateCalculator implementation for streams and jobs. This implementation uses the following criteria:

• If all expected modules are deployed, the state is considered deployed.
• If one or more of the modules do not have the number of expected instances but there is at least one instance of each module, the state is considered incomplete.
• If one or more of the modules do not have any instances deployed, the state is considered failed.

Author:

Patrick Peralta

Constructor Summary

Constructors

Constructor and Description
DefaultStateCalculator()

Method Summary

Methods

Modifier and Type	Method and Description
DeploymentUnitStatus	calculate(DeploymentUnit deploymentUnit, ModuleDeploymentPropertiesProvider<ModuleDeploymentProperties> provider, java.util.Collection<ModuleDeploymentStatus> deploymentStatuses) For a given deployment unit (stream or job) calculate the overall status.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStateCalculator

public DefaultStateCalculator()

Method Detail

calculate

public DeploymentUnitStatus calculate(DeploymentUnit deploymentUnit,
                             ModuleDeploymentPropertiesProvider<ModuleDeploymentProperties> provider,
                             java.util.Collection<ModuleDeploymentStatus> deploymentStatuses)

For a given deployment unit (stream or job) calculate the overall status.

Specified by:

calculate in interface DeploymentUnitStateCalculator

Parameters:

deploymentUnit - deployment unit (stream or job)

provider - deployment properties provider

deploymentStatuses - deployment statuses for each module in the deployment unit.

Returns:

the status for the stream/job