public abstract class AbstractInstancePersistingDeployer<D extends BaseDefinition,I extends BaseInstance<D>> extends AbstractDeployer<D>
definition の instances の処理方法を知っているデプロイヤーのための基本サポートクラス。| 修飾子と型 | フィールドと説明 |
|---|---|
protected DeploymentHandler | deploymentHandler |
protected DomainRepository<I,java.lang.String> | instanceRepository |
composedJobParser, definitionKind, parser| 修飾子 | コンストラクターと説明 |
|---|---|
protected | AbstractInstancePersistingDeployer(ZooKeeperConnection zkConnection, org.springframework.data.repository.PagingAndSortingRepository<D,java.lang.String> definitionRespository, DomainRepository<I,java.lang.String> instanceRepository, XDParser parser, DeploymentHandler deploymentHandler, ParsingContext definitionKind) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | beforeDelete(D definition) 削除されようとしている定義に対してアクションを実行するためにサブクラスがオーバーライドできるコールバックメソッド。 |
void | deleteAll() すべての定義を削除する |
void | deploy(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties) リソース (ジョブまたはストリーム) をデプロイします。 |
BaseInstance<D> | deploymentInfo(java.lang.String id)ID が指定されている定義に関する デプロイ情報を照会します。 |
java.lang.Iterable<I> | deploymentInfo(java.lang.String first, java.lang.String last)ID が first から last までの範囲の定義に関する デプロイ情報を照会します。 |
protected void | deployResource(java.lang.String deploymentUnitName) 指定された名前の デプロイユニットをデプロイします。 |
protected abstract I | makeInstance(D definition) 指定された定義から実行インスタンスを作成します。 |
void | undeploy(java.lang.String name) |
void | undeployAll() デプロイされたすべてのリソースをアンデプロイします。 |
protected void | undeployResource(java.lang.String deploymentUnitName) 指定された名前のデプロイユニットをデプロイ解除します |
void | validateBeforeDeploy(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties) デプロイする前に検証します。 |
void | validateBeforeUndeploy(java.lang.String name) デプロイ解除する前に検証してください。 |
afterSave, basicDeploy, createDefinition, createModuleDefinitions, delete, findAll, findAll, findOne, getDefinitionRepository, getDeploymentPath, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException, validateBeforeDelete, validateBeforeSaveprotected final DomainRepository<I extends BaseInstance<D>,java.lang.String> instanceRepository
protected final DeploymentHandler deploymentHandler
protected AbstractInstancePersistingDeployer(ZooKeeperConnection zkConnection, org.springframework.data.repository.PagingAndSortingRepository<D,java.lang.String> definitionRespository, DomainRepository<I,java.lang.String> instanceRepository, XDParser parser, DeploymentHandler deploymentHandler, ParsingContext definitionKind)
protected void beforeDelete(D definition)
AbstractDeployerAbstractDeployer<D extends BaseDefinition> の beforeDelete public void undeploy(java.lang.String name)
public void deploy(java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> properties)ResourceDeployername - リソースの名前 properties - 使用するデプロイプロパティ (NULL ではない可能性があります)public void undeployAll()
ResourceDeployerpublic void deleteAll()
ResourceDeployerResourceDeployer<D extends BaseDefinition> 内の deleteAll AbstractDeployer<D extends BaseDefinition> の deleteAll public java.lang.Iterable<I> deploymentInfo(java.lang.String first, java.lang.String last)
first から last までの範囲の定義に関する デプロイ情報を照会します。public BaseInstance<D> deploymentInfo(java.lang.String id)
protected final void deployResource(java.lang.String deploymentUnitName)
deploymentUnitName - デプロイユニット名 protected final void undeployResource(java.lang.String deploymentUnitName)
deploymentUnitName - デプロイユニット名 public void validateBeforeUndeploy(java.lang.String name)
DeploymentValidatorname - デプロイユニット名 public void validateBeforeDeploy(java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> properties)DeploymentValidatorname - デプロイユニット名