Package com.gigaspaces.internal.server.space

Class ZookeeperTopologyHandler

java.lang.Object

com.gigaspaces.internal.server.space.ZookeeperTopologyHandler

All Implemented Interfaces:

Closeable, AutoCloseable

public class ZookeeperTopologyHandler
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ZookeeperTopologyHandler.ReconnectTask

Constructor Summary

Constructors

Constructor	Description
ZookeeperTopologyHandler(String puName, AttributeStore attributeStore)

Method Summary

Modifier and Type	Method	Description
void	addListener(ZookeeperClient zookeeperClient, SpaceConfig spaceConfig, int partitionId)
void	close()
ClusterTopology	getClusterTopology(int generation)
static ClusterTopology	getClusterTopology(AttributeStore attributeStore, String puName, int generation)
ClusterTopologyState	getClusterTopologyState()
static String	getConsumerConfiguration(String pipelineName)
static String	getConsumers()
static String	getHeapReportStatePath(String puName)
static String	getHeapReportStatePath2(String puName)
static String	getPipelineConfiguration(String pipelineName)
static String	getSpaceNamesPath(String puName)
static String	getZkTopologyGenerationPath(String puName, int generation)
static String	getZkTopologyStatePath(String puName)
static String	pipelines()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ZookeeperTopologyHandler

public ZookeeperTopologyHandler(String puName,
 AttributeStore attributeStore)

Method Details

getZkTopologyStatePath

public static String getZkTopologyStatePath(String puName)

getSpaceNamesPath

public static String getSpaceNamesPath(String puName)

getHeapReportStatePath2

public static String getHeapReportStatePath2(String puName)

getHeapReportStatePath

public static String getHeapReportStatePath(String puName)

getPipelineConfiguration

public static String getPipelineConfiguration(String pipelineName)

getConsumerConfiguration

public static String getConsumerConfiguration(String pipelineName)

pipelines

public static String pipelines()

getConsumers

public static String getConsumers()

getZkTopologyGenerationPath

public static String getZkTopologyGenerationPath(String puName,
 int generation)

addListener

public void addListener(ZookeeperClient zookeeperClient,
 SpaceConfig spaceConfig,
 int partitionId)

getClusterTopologyState

public ClusterTopologyState getClusterTopologyState()
                                             throws IOException

Throws:

IOException

getClusterTopology

public ClusterTopology getClusterTopology(int generation)
                                   throws IOException

Throws:

IOException

getClusterTopology

public static ClusterTopology getClusterTopology(AttributeStore attributeStore,
 String puName,
 int generation)
                                          throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException