See: Description
Interface | Description |
---|---|
SupervisorElectionListener |
Event listener for
SupervisorElectedEvent s. |
Class | Description |
---|---|
ContainerListener |
Listener implementation that is invoked when containers are added/removed/modified.
|
ContainerMatchingModuleRedeployer |
The
ModuleRedeployer that deploys the unallocated stream/job modules. |
DefaultDeploymentStateRecalculator |
Stream/Job deployment state re-calculator upon leadership election.
|
DefaultModuleDeploymentPropertiesProvider |
Default implementation that retrieves the
ModuleDeploymentProperties for the given
ModuleDescriptor . |
DepartingContainerModuleRedeployer |
The
ModuleRedeployer that re-deploys the stream/job modules that were
deployed into the departing container. |
DeploymentConfiguration |
Configuration class that holds the beans required for deployment management.
|
DeploymentLoader |
Utility for loading streams and jobs for the purpose of deployment.
|
DeploymentMessageConsumer |
Consumer for
DeploymentMessage
which delegates to the corresponding @ResourceDeployer
to process the deployment requests. |
DeploymentQueue |
This class controls the lifecycle operations of the ZK distributed queue that
holds the
DeploymentMessage s. |
DeploymentSupervisor |
Process that watches ZooKeeper for Container arrivals and departures from
the XD cluster.
|
ModuleDeploymentWriter |
Utility class to write module deployment requests under
/xd/deployments/modules . |
ModuleRedeployer |
Abstract ModuleRedeployer that deploy/re-deploys the unallocated/orphaned modules.
|
ModuleRedeployer.ModuleDeployment |
Holds information about a module that needs to be re-deployed.
|
SupervisorElectedEvent |
Event that is fired after a admin leader is elected.
|
ZKDeploymentHandler |
Abstract class that has common implementations of ZK based deployments.
|
ZKDeploymentMessagePublisher |
ZooKeeper based
DeploymentMessagePublisher that publishes
deployment messages into a ZooKeeper/Curator
distributed queue. |
ZKJobDeploymentHandler |
Deployment handler that is responsible for the deployment of a Job.
|
ZKStreamDeploymentHandler |
Deployment handler that is responsible for deploying Stream.
|