See: Description
| Interface | Description |
|---|---|
| SupervisorElectionListener |
Event listener for
SupervisorElectedEvents. |
| 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. |
| DepartedContainerModuleRedeployer |
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
DeploymentMessages. |
| 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.
|