Package com.gigaspaces.internal.server.space

Class ZookeeperLastPrimaryHandler

java.lang.Object

com.gigaspaces.internal.server.space.ZookeeperLastPrimaryHandler

public class ZookeeperLastPrimaryHandler
extends Object

Created by tamirs on 5/9/17.

Constructor Summary

Constructors

Constructor	Description
ZookeeperLastPrimaryHandler(SpaceImpl spaceImpl, AttributeStore attributeStore, org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
String	getAttributeStoreKey()
String	getLastPrimaryName()
String	getLastPrimaryNameMemoryXtend()
static String	getSeparator()
String	getUnhealthyName()
boolean	isLastPrimary()
boolean	isUnhealthy()
void	removeLastPrimaryRecord()
void	removeUnhealthyRecord()
void	setMeAsLastPrimary()
void	setMeAsUnHealthy()
static String	toId(String instanceId, String uid)
static String	toPath(String spaceName, String partitionId)
static String	toUnHealthyPath(String spaceName, String partitionId)

Methods inherited from class java.lang.Object

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

Constructor Details

ZookeeperLastPrimaryHandler

public ZookeeperLastPrimaryHandler(SpaceImpl spaceImpl,
 AttributeStore attributeStore,
 org.slf4j.Logger logger)

Method Details

toUnHealthyPath

public static String toUnHealthyPath(String spaceName,
 String partitionId)

removeLastPrimaryRecord

public void removeLastPrimaryRecord()
                             throws IOException

Throws:

IOException

removeUnhealthyRecord

public void removeUnhealthyRecord()
                           throws IOException

Throws:

IOException

setMeAsLastPrimary

public void setMeAsLastPrimary()
                        throws IOException

Throws:

IOException

setMeAsUnHealthy

public void setMeAsUnHealthy()
                      throws IOException

Throws:

IOException

isLastPrimary

public boolean isLastPrimary()

isUnhealthy

public boolean isUnhealthy()

getLastPrimaryName

public String getLastPrimaryName()
                          throws IOException

Throws:

IOException

getUnhealthyName

public String getUnhealthyName()
                        throws IOException

Throws:

IOException

getLastPrimaryNameMemoryXtend

public String getLastPrimaryNameMemoryXtend()
                                     throws IOException

Throws:

IOException

getAttributeStoreKey

public String getAttributeStoreKey()

getSeparator

public static String getSeparator()

toPath

public static String toPath(String spaceName,
 String partitionId)

toId

public static String toId(String instanceId,
 String uid)