org.springframework.xd.dirt.server

Class JobDeploymentListener

java.lang.Object

org.springframework.xd.dirt.server.InitialDeploymentListener

org.springframework.xd.dirt.server.JobDeploymentListener

All Implemented Interfaces:

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

public class JobDeploymentListener
extends InitialDeploymentListener

Listener implementation that handles job deployment requests.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.xd.dirt.server.InitialDeploymentListener

containerMatcher, containerRepository, moduleDeploymentWriter, stateCalculator

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	onChildAdded(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.ChildData data) Handle the creation of a new job deployment.
void	recalculateJobStates(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments) Iterate all deployed jobs, recalculate the deployment status of each, and create an ephemeral node indicating the job state.

Methods inherited from class org.springframework.xd.dirt.server.InitialDeploymentListener

childEvent, createModuleDeploymentRequestsPath, onChildRemoved

Methods inherited from class java.lang.Object

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

Constructor Detail

JobDeploymentListener

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

Construct a JobDeploymentListener.

Parameters:

zkConnection - ZooKeeper connection

moduleDeploymentRequests - the requested module deployments

containerRepository - repository to obtain container data

jobFactory - factory to construct Job

containerMatcher - matches modules to containers

stateCalculator - calculator for job state

Method Detail

onChildAdded

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

Handle the creation of a new job deployment.

Specified by:

onChildAdded in class InitialDeploymentListener

Parameters:

client - curator client

data - job deployment request data

Throws:

java.lang.Exception

recalculateJobStates

public void recalculateJobStates(org.apache.curator.framework.CuratorFramework client,
                        org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments)
                          throws java.lang.Exception

Iterate all deployed jobs, recalculate the deployment status of each, and create an ephemeral node indicating the job state. This is typically invoked upon leader election.

Parameters:

client - curator client

jobDeployments - curator cache of job deployments

Throws:

java.lang.Exception