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,
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, DeploymentUnitStateCalculator stateCalculator, java.util.concurrent.ScheduledExecutorService executorService, java.util.concurrent.atomic.AtomicLong quietPeriod)
zkConnection
- ZooKeeper connectionstreamFactory
- factory to construct Stream
jobFactory
- factory to construct Job
streamDeployments
- 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 containersstateCalculator
- 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.PathChildrenCacheListener
java.lang.Exception