public class ZookeeperTopologyHandler extends Object implements Closeable
Modifier and Type | Class and Description |
---|---|
class |
ZookeeperTopologyHandler.ReconnectTask |
Constructor and Description |
---|
ZookeeperTopologyHandler(String puName,
AttributeStore attributeStore) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(ZookeeperClient zookeeperClient,
SpaceConfig spaceConfig,
int partitionId) |
void |
close() |
ClusterTopology |
getClusterTopology(int generation) |
ClusterTopologyState |
getClusterTopologyState() |
static String |
getZkTopologyGenerationPath(String puName,
int generation) |
static String |
getZkTopologyStatePath(String puName) |
public ZookeeperTopologyHandler(String puName, AttributeStore attributeStore)
public static String getZkTopologyGenerationPath(String puName, int generation)
public void addListener(ZookeeperClient zookeeperClient, SpaceConfig spaceConfig, int partitionId)
public ClusterTopologyState getClusterTopologyState() throws IOException
IOException
public ClusterTopology getClusterTopology(int generation) throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © GigaSpaces.