org.springframework.xd.dirt.server.admin.deployment.zk

Class DefaultDeploymentStateRecalculator

java.lang.Object

org.springframework.xd.dirt.server.admin.deployment.zk.DefaultDeploymentStateRecalculator

All Implemented Interfaces:

SupervisorElectionListener

public class DefaultDeploymentStateRecalculator
extends java.lang.Object
implements SupervisorElectionListener

Stream/Job deployment state re-calculator upon leadership election.

Author:

Patrick Peralta, Ilayaperumal Gopinathan

Field Summary

Fields

Modifier and Type	Field and Description
protected JobFactory	jobFactory Factory to construct Job instance
protected DeploymentUnitStateCalculator	stateCalculator Deployment unit state calculator
protected StreamFactory	streamFactory Factory to construct Stream instance

Constructor Summary

Constructors

Constructor and Description
DefaultDeploymentStateRecalculator()

Method Summary

Methods

Modifier and Type	Method and Description
void	onSupervisorElected(SupervisorElectedEvent supervisorElectedEvent) The action to perform after the admin leader is elected.
void	recalculateJobStates(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.
void	recalculateStreamStates(org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments) Iterate all deployed streams, recalculate the state of each, and create an ephemeral node indicating the stream state.

Methods inherited from class java.lang.Object

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

Field Detail

streamFactory

@Autowired
protected StreamFactory streamFactory

Factory to construct Stream instance

jobFactory

@Autowired
protected JobFactory jobFactory

Factory to construct Job instance

stateCalculator

@Autowired
protected DeploymentUnitStateCalculator stateCalculator

Deployment unit state calculator

Constructor Detail

DefaultDeploymentStateRecalculator

public DefaultDeploymentStateRecalculator()

Method Detail

recalculateStreamStates

public void recalculateStreamStates(org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments)
                             throws java.lang.Exception

Iterate all deployed streams, recalculate the state of each, and create an ephemeral node indicating the stream state. This is typically invoked upon leader election.

Throws:

java.lang.Exception

recalculateJobStates

public void recalculateJobStates(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.

Throws:

java.lang.Exception

onSupervisorElected

public void onSupervisorElected(SupervisorElectedEvent supervisorElectedEvent)
                         throws java.lang.Exception

Description copied from interface: SupervisorElectionListener

The action to perform after the admin leader is elected.

Specified by:

onSupervisorElected in interface SupervisorElectionListener

Parameters:

supervisorElectedEvent - the leader elected event

Throws:

java.lang.Exception