org.springframework.xd.dirt.server

Class DeploymentSupervisor

java.lang.Object

org.springframework.xd.dirt.server.DeploymentSupervisor

All Implemented Interfaces:

java.util.EventListener, org.springframework.beans.factory.DisposableBean, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

public class DeploymentSupervisor
extends java.lang.Object
implements org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>, org.springframework.beans.factory.DisposableBean

Process that watches ZooKeeper for Container arrivals and departures from the XD cluster. Each DeploymentSupervisor instance will attempt to request leadership, but at any given time only one DeploymentSupervisor instance in the cluster will have leadership status.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

See Also:

LeaderSelector

Constructor Summary

Constructors

Constructor and Description

DeploymentSupervisor(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, StreamDefinitionRepository streamDefinitionRepository, JobDefinitionRepository jobDefinitionRepository, ModuleDefinitionRepository moduleDefinitionRepository, ModuleOptionsMetadataResolver moduleOptionsMetadataResolver, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator) Construct a DeploymentSupervisor.

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
void	onApplicationEvent(org.springframework.context.ApplicationEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

DeploymentSupervisor

public DeploymentSupervisor(ZooKeeperConnection zkConnection,
                    ContainerRepository containerRepository,
                    StreamDefinitionRepository streamDefinitionRepository,
                    JobDefinitionRepository jobDefinitionRepository,
                    ModuleDefinitionRepository moduleDefinitionRepository,
                    ModuleOptionsMetadataResolver moduleOptionsMetadataResolver,
                    ContainerMatcher containerMatcher,
                    DeploymentUnitStateCalculator stateCalculator)

Construct a DeploymentSupervisor.

Parameters:

zkConnection - ZooKeeper connection

containerRepository - repository for the containers

streamDefinitionRepository - repository for streams definitions

jobDefinitionRepository - repository for job definitions

moduleDefinitionRepository - repository for modules

moduleOptionsMetadataResolver - resolver for module options metadata

containerMatcher - matches modules to containers

stateCalculator - calculator for stream/job state

Method Detail

onApplicationEvent

public void onApplicationEvent(org.springframework.context.ApplicationEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean