org.springframework.xd.dirt.test

Class ResourceStateVerifier

java.lang.Object

org.springframework.xd.dirt.test.ResourceStateVerifier

public class ResourceStateVerifier
extends java.lang.Object

Verifies the state of resources (job or stream) by polling repository state until the resource is in the expected state or the operation times out. For use with SingleNodeApplication testing.

Since:

1.0

Author:

David Turanski

See Also:

SingleNodeIntegrationTestSupport

Constructor Summary

Constructors

Constructor and Description
ResourceStateVerifier(DeploymentStatusRepository<?,java.lang.String> deploymentStatusRepository, DomainRepository<? extends BaseDefinition,java.lang.String> domainRepository)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	waitForCreate(java.lang.String resourceName) Wait for a resource definition to be created.
DeploymentUnitStatus.State	waitForDeploy(java.lang.String resourceName) Wait for a named resource to be completely deployed.
DeploymentUnitStatus.State	waitForDeploy(java.lang.String resourceName, boolean allowIncomplete) Wait for a named resource to be deployed.
boolean	waitForDestroy(java.lang.String resourceName) Wait for a resource definition to be destroyed.
DeploymentUnitStatus.State	waitForUndeploy(java.lang.String resourceName) Wait for a named resource to be undeployed.

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceStateVerifier

public ResourceStateVerifier(DeploymentStatusRepository<?,java.lang.String> deploymentStatusRepository,
                     DomainRepository<? extends BaseDefinition,java.lang.String> domainRepository)

Parameters:

deploymentStatusRepository - the repository that tracks deployment status

domainRepository - the resource definition repository

Method Detail

waitForDeploy

public DeploymentUnitStatus.State waitForDeploy(java.lang.String resourceName)

Wait for a named resource to be completely deployed.

Parameters:

resourceName - the name of the resource being deployed

Returns:

the deployment status, either State.deployed or the current State when this operation timed out.

waitForDeploy

public DeploymentUnitStatus.State waitForDeploy(java.lang.String resourceName,
                                       boolean allowIncomplete)

Wait for a named resource to be deployed.

Parameters:

resourceName - the name of the resource being deployed

allowIncomplete - if true, will return on State.incomplete or State.deployed

Returns:

one of the expected States or the current State when this operation timed out.

waitForUndeploy

public DeploymentUnitStatus.State waitForUndeploy(java.lang.String resourceName)

Wait for a named resource to be undeployed.

Parameters:

resourceName - the name of the resource being undeployed

Returns:

either State.undeployed or the current state when the operation timed out.

waitForCreate

public boolean waitForCreate(java.lang.String resourceName)

Wait for a resource definition to be created.

Parameters:

resourceName - the name of the resource being created.

Returns:

true if the resource exists; false otherwise.

waitForDestroy

public boolean waitForDestroy(java.lang.String resourceName)

Wait for a resource definition to be destroyed.

Parameters:

resourceName - the name of the resource being destroyed.

Returns:

true if the resource does not exist; false otherwise.