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 and Description
class	ZookeeperTopologyHandler.ReconnectTask

Constructor Summary

Constructors

Constructor and Description
ZookeeperTopologyHandler(String puName, AttributeStore attributeStore)

Method Summary

Modifier and Type	Method and Description
void	addListener(ZookeeperClient zookeeperClient, SpaceConfig spaceConfig, int partitionId)
void	close()
static ClusterTopology	getClusterTopology(AttributeStore attributeStore, String puName, int generation)
ClusterTopology	getClusterTopology(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 Detail

ZookeeperTopologyHandler

public ZookeeperTopologyHandler(String puName,
                                AttributeStore attributeStore)

Method Detail

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 Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException