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:

JobDeployer, 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

Modifier and Type	Field and Description
protected DomainRepository<I,java.lang.String>	instanceRepository

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

definitionKind, parser

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	beforeDelete(D definition) Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.
void	deleteAll() Delete all the definitions
void	deploy(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties) Deploy a resource (job or stream).
BaseInstance<D>	deploymentInfo(java.lang.String id) Query deployment information about the definition whose ID is provided.
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

afterSave, basicDeploy, createDefinition, delete, findAll, findAll, findOne, getDefinitionRepository, getDeploymentPath, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException

Methods inherited from class java.lang.Object

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

Field Detail

instanceRepository

protected DomainRepository<I extends BaseInstance<D>,java.lang.String> instanceRepository

Constructor Detail

AbstractInstancePersistingDeployer

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

Method Detail

beforeDelete

protected void beforeDelete(D definition)

Description copied from class: AbstractDeployer

Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.

Overrides:

beforeDelete in class AbstractDeployer<D extends BaseDefinition>

undeploy

public void undeploy(java.lang.String name)

deploy

public void deploy(java.lang.String name,
          java.util.Map<java.lang.String,java.lang.String> properties)

Description copied from interface: ResourceDeployer

Deploy a resource (job or stream).

Parameters:

name - name of the resource

properties - deployment properties to use (may not be null)

undeployAll

public void undeployAll()

Description copied from interface: ResourceDeployer

Undeploy all the deployed resources.

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.

deploymentInfo

public BaseInstance<D> deploymentInfo(java.lang.String id)

Query deployment information about the definition whose ID is provided.

makeInstance

protected abstract I makeInstance(D definition)

Create an running instance out of the given definition;