org.springframework.xd.dirt.stream

Class AbstractInstancePersistingDeployer<D extends BaseDefinition,I extends BaseInstance<D>>

java.lang.Object

org.springframework.xd.dirt.stream.AbstractDeployer<D>

org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer<D,I>

All Implemented Interfaces:

ResourceDeployer<D>

Direct Known Subclasses:

StreamDeployer

public abstract class AbstractInstancePersistingDeployer<D extends BaseDefinition,I extends BaseInstance<D>>
extends AbstractDeployer<D>

Base support class for deployers that know how to deal with instances of a definition.

Author:

Eric Bottard, Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.xd.dirt.stream.AbstractDeployer

definitionKind

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractInstancePersistingDeployer(org.springframework.data.repository.PagingAndSortingRepository<D,java.lang.String> definitionRespository, DomainRepository<I,java.lang.String> instanceRepository, DeploymentMessageSender messageSender, XDParser parser, java.lang.String definitionKind)

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(java.lang.String name) Delete the Definition using the provided name.
void	deleteAll() Delete all the definitions
void	deploy(java.lang.String name)
void	deployAll() deploy all available undeployed resource definitions.
java.lang.Iterable<I>	deploymentInfo(java.lang.String first, java.lang.String last) Query deployment information about definitions whose ids range from first to last.
protected abstract I	makeInstance(D definition) Create an running instance out of the given definition;
void	undeploy(java.lang.String name)
void	undeployAll() Undeploy all the deployed resources.

Methods inherited from class org.springframework.xd.dirt.stream.AbstractDeployer

basicDeploy, basicUndeploy, findAll, findAll, findOne, getDefinitionRepository, parse, save, sendDeploymentRequests, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractInstancePersistingDeployer

protected AbstractInstancePersistingDeployer(org.springframework.data.repository.PagingAndSortingRepository<D,java.lang.String> definitionRespository,
                                  DomainRepository<I,java.lang.String> instanceRepository,
                                  DeploymentMessageSender messageSender,
                                  XDParser parser,
                                  java.lang.String definitionKind)

Method Detail

delete

public void delete(java.lang.String name)

Description copied from interface: ResourceDeployer

Delete the Definition using the provided name. The definition may also be undeployed as part of that process.

Parameters:

name - the name of the definition to delete

undeploy

public void undeploy(java.lang.String name)

deploy

public void deploy(java.lang.String name)

undeployAll

public void undeployAll()

Description copied from interface: ResourceDeployer

Undeploy all the deployed resources.

deployAll

public void deployAll()

Description copied from interface: ResourceDeployer

deploy all available undeployed resource definitions.

deleteAll

public void deleteAll()

Description copied from interface: ResourceDeployer

Delete all the definitions

Specified by:

deleteAll in interface ResourceDeployer<D extends BaseDefinition>

Overrides:

deleteAll in class AbstractDeployer<D extends BaseDefinition>

deploymentInfo

public java.lang.Iterable<I> deploymentInfo(java.lang.String first,
                                   java.lang.String last)

Query deployment information about definitions whose ids range from first to last.

makeInstance

protected abstract I makeInstance(D definition)

Create an running instance out of the given definition;