org.springframework.xd.dirt.server

Class InitialDeploymentListener

java.lang.Object

org.springframework.xd.dirt.server.InitialDeploymentListener

All Implemented Interfaces:

org.apache.curator.framework.recipes.cache.PathChildrenCacheListener

Direct Known Subclasses:

JobDeploymentListener, StreamDeploymentListener

public abstract class InitialDeploymentListener
extends java.lang.Object
implements org.apache.curator.framework.recipes.cache.PathChildrenCacheListener

Abstract deployment listener that handles fresh stream/job deployment requests.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Field Summary

Fields

Modifier and Type	Field and Description
protected ContainerMatcher	containerMatcher Container matcher for matching modules to containers.
protected ContainerRepository	containerRepository Repository from which to obtain containers in the cluster.
protected ModuleDeploymentWriter	moduleDeploymentWriter Utility for writing module deployment requests to ZooKeeper.
protected DeploymentUnitStateCalculator	stateCalculator State calculator for stream state.

Constructor Summary

Constructors

Constructor and Description
InitialDeploymentListener(ZooKeeperConnection zkConnection, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerRepository containerRepository, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator) Construct a PrimaryDeploymentListener.

Method Summary

Methods

Modifier and Type	Method and Description
void	childEvent(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event) Handle child events for the Paths.STREAMS path.
protected void	createModuleDeploymentRequestsPath(org.apache.curator.framework.CuratorFramework client, ModuleDescriptor descriptor, RuntimeModuleDeploymentProperties deploymentProperties) Create ModuleDeploymentRequestsPath for the given ModuleDescriptor and the RuntimeModuleDeploymentProperties.
protected abstract void	onChildAdded(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.ChildData data) Handle the new deployment requests.
protected void	onChildRemoved(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.ChildData data) Handle the removal of module deployment requests.

Methods inherited from class java.lang.Object

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

Field Detail

containerMatcher

protected final ContainerMatcher containerMatcher

Container matcher for matching modules to containers.

containerRepository

protected final ContainerRepository containerRepository

Repository from which to obtain containers in the cluster.

moduleDeploymentWriter

protected final ModuleDeploymentWriter moduleDeploymentWriter

Utility for writing module deployment requests to ZooKeeper.

stateCalculator

protected final DeploymentUnitStateCalculator stateCalculator

State calculator for stream state.

Constructor Detail

InitialDeploymentListener

public InitialDeploymentListener(ZooKeeperConnection zkConnection,
                         org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
                         ContainerRepository containerRepository,
                         ContainerMatcher containerMatcher,
                         DeploymentUnitStateCalculator stateCalculator)

Construct a PrimaryDeploymentListener.

Parameters:

zkConnection - ZooKeeper connection

moduleDeploymentRequests - the requested module deployments

containerRepository - repository to obtain container data

containerMatcher - matches modules to containers

stateCalculator - calculator for stream state

Method Detail

childEvent

public void childEvent(org.apache.curator.framework.CuratorFramework client,
              org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event)
                throws java.lang.Exception

Handle child events for the Paths.STREAMS path.

Specified by:

childEvent in interface org.apache.curator.framework.recipes.cache.PathChildrenCacheListener

Throws:

java.lang.Exception

onChildAdded

protected abstract void onChildAdded(org.apache.curator.framework.CuratorFramework client,
                org.apache.curator.framework.recipes.cache.ChildData data)
                              throws java.lang.Exception

Handle the new deployment requests.

Parameters:

client - the curator client

data - the data that represents the module deployments

Throws:

java.lang.Exception

onChildRemoved

protected void onChildRemoved(org.apache.curator.framework.CuratorFramework client,
                  org.apache.curator.framework.recipes.cache.ChildData data)
                       throws java.lang.Exception

Handle the removal of module deployment requests.

Parameters:

client - the curator client

data - the module deployment data

Throws:

java.lang.Exception

createModuleDeploymentRequestsPath

protected void createModuleDeploymentRequestsPath(org.apache.curator.framework.CuratorFramework client,
                                      ModuleDescriptor descriptor,
                                      RuntimeModuleDeploymentProperties deploymentProperties)

Create ModuleDeploymentRequestsPath for the given ModuleDescriptor and the RuntimeModuleDeploymentProperties.

Parameters:

client - the curator client

descriptor - the module descriptor

deploymentProperties - the runtime deployment properties