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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEPLOYMENT_TIMEOUT_PROPERTY Property for specifying the deployment timeout.
static java.lang.String	QUIET_PERIOD_PROPERTY Property for specifying the quiet period for deployments to new containers.

Constructor Summary

Constructors

Constructor and Description

DeploymentSupervisor(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, AdminRepository adminRepository, AdminAttributes adminAttributes, StreamDefinitionRepository streamDefinitionRepository, JobDefinitionRepository jobDefinitionRepository, ModuleRegistry moduleRegistry, ModuleOptionsMetadataResolver moduleOptionsMetadataResolver, org.springframework.xd.dirt.server.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

Field Detail

QUIET_PERIOD_PROPERTY

public static final java.lang.String QUIET_PERIOD_PROPERTY

Property for specifying the quiet period for deployments to new containers.

See Also:

Constant Field Values

DEPLOYMENT_TIMEOUT_PROPERTY

public static final java.lang.String DEPLOYMENT_TIMEOUT_PROPERTY

Property for specifying the deployment timeout.

See Also:

Constant Field Values

Constructor Detail

DeploymentSupervisor

public DeploymentSupervisor(ZooKeeperConnection zkConnection,
                    ContainerRepository containerRepository,
                    AdminRepository adminRepository,
                    AdminAttributes adminAttributes,
                    StreamDefinitionRepository streamDefinitionRepository,
                    JobDefinitionRepository jobDefinitionRepository,
                    ModuleRegistry moduleRegistry,
                    ModuleOptionsMetadataResolver moduleOptionsMetadataResolver,
                    org.springframework.xd.dirt.server.ContainerMatcher containerMatcher,
                    DeploymentUnitStateCalculator stateCalculator)

Construct a DeploymentSupervisor.

Parameters:

zkConnection - ZooKeeper connection

containerRepository - repository for the containers

adminRepository - repository for the admins

adminAttributes - attributes for the admin

streamDefinitionRepository - repository for streams definitions

jobDefinitionRepository - repository for job definitions

moduleRegistry - registry 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