public class ContainerListener
extends java.lang.Object
implements org.apache.curator.framework.recipes.cache.PathChildrenCacheListener
| Constructor and Description |
|---|
ContainerListener(ZooKeeperConnection zkConnection,
ContainerRepository containerRepository,
StreamFactory streamFactory,
JobFactory jobFactory,
org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments,
org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments,
org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
ContainerMatcher containerMatcher,
ModuleDeploymentWriter moduleDeploymentWriter,
DeploymentUnitStateCalculator stateCalculator,
java.util.concurrent.ScheduledExecutorService executorService,
java.util.concurrent.atomic.AtomicLong quietPeriod)
Construct a ContainerListener.
|
| Modifier and Type | Method and Description |
|---|---|
void |
childEvent(org.apache.curator.framework.CuratorFramework client,
org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event) |
public ContainerListener(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, StreamFactory streamFactory, JobFactory jobFactory, org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments, org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerMatcher containerMatcher, ModuleDeploymentWriter moduleDeploymentWriter, DeploymentUnitStateCalculator stateCalculator, java.util.concurrent.ScheduledExecutorService executorService, java.util.concurrent.atomic.AtomicLong quietPeriod)
zkConnection - ZooKeeper connectionstreamFactory - factory to construct StreamjobFactory - factory to construct JobstreamDeployments - cache of children for stream deployments pathjobDeployments - cache of children for job deployments pathmoduleDeploymentRequests - cache of children for requested module deployments pathcontainerMatcher - matches modules to containersmoduleDeploymentWriter - utility that writes deployment requests to zk pathstateCalculator - calculator for stream/job statequietPeriod - AtomicLong indicating quiet period for new container module deploymentspublic void childEvent(org.apache.curator.framework.CuratorFramework client,
org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent event)
throws java.lang.Exception
childEvent in interface org.apache.curator.framework.recipes.cache.PathChildrenCacheListenerjava.lang.Exception