com.gigaspaces.internal.cluster

Class SpaceClusterInfo

java.lang.Object

com.gigaspaces.internal.cluster.SpaceClusterInfo

All Implemented Interfaces:

SmartExternalizable, Externalizable, Serializable

public class SpaceClusterInfo
extends Object
implements SmartExternalizable

Since:

9.0.0

Author:

Niv Ingberg

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SpaceClusterInfo() Required for Externalizable
SpaceClusterInfo(JSpaceAttributes spaceAttributes, String defaultMemberName)
SpaceClusterInfo(SpaceClusterInfo clusterInfo)

Method Summary

Modifier and Type	Method and Description
SpaceClusterInfo	cloneAndUpdate(ClusterTopology newChunksMap)
String	getClusterName()
String	getClusterSchema()
<T> T	getCustomComponent(String key)
Map<String,SpaceCustomComponent>	getCustomComponents()
SpaceProxyLoadBalancerType	getLoadBalancerType()
List<String>	getMembersNames()
MirrorServiceConfig	getMirrorServiceConfig()
int	getNumberOfBackups()
int	getNumberOfPartitions()
int	getPartitionId(int routingValue)
int	getPartitionId(long routingValue)
List<String>	getPartitionMembersNames(int partitionId)
int	getPartitionOfMember(String memberName)
ClusterTopology	getTopology()
boolean	hasReplicationTargets()
boolean	isActiveActive()
boolean	isBroadcastDisabled()
boolean	isChunksRouting()
boolean	isClustered()
boolean	isMirrorServiceEnabled()
boolean	isPartitioned()
boolean	isPrimaryElectionAvailable()
boolean	isReplicated()
boolean	isSyncReplicationEnabled()
boolean	isTieredStorage()
void	readExternal(ObjectInput in)
void	setCustomComponent(SpaceCustomComponent component)
void	setNumOfPartitions(int numOfPartitions)
void	setTopology(ClusterTopology topology)
Map<String,TieredStorageTableConfig>	tieredStorageConfigString()
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Detail

SpaceClusterInfo

public SpaceClusterInfo()

Required for Externalizable

SpaceClusterInfo

public SpaceClusterInfo(JSpaceAttributes spaceAttributes,
                        String defaultMemberName)

SpaceClusterInfo

public SpaceClusterInfo(SpaceClusterInfo clusterInfo)

Method Detail

isClustered

public boolean isClustered()

getMembersNames

public List<String> getMembersNames()

isBroadcastDisabled

public boolean isBroadcastDisabled()

cloneAndUpdate

public SpaceClusterInfo cloneAndUpdate(ClusterTopology newChunksMap)

isPartitioned

public boolean isPartitioned()

Returns:

Gets whether the cluster is partitioned. True for "partitioned_sync2backup" topologies.

getNumberOfPartitions

public int getNumberOfPartitions()

Returns:

Gets the number of partitions in a partitioned topology, otherwise returns 0.

getTopology

public ClusterTopology getTopology()

getNumberOfBackups

public int getNumberOfBackups()

getLoadBalancerType

public SpaceProxyLoadBalancerType getLoadBalancerType()

getPartitionMembersNames

public List<String> getPartitionMembersNames(int partitionId)

Returns:

Gets a group members list for the provided partition id - relevant only for partitioned clusters.

getPartitionOfMember

public int getPartitionOfMember(String memberName)

isReplicated

public boolean isReplicated()

isActiveActive

public boolean isActiveActive()

getCustomComponent

public <T> T getCustomComponent(String key)

getCustomComponents

public Map<String,SpaceCustomComponent> getCustomComponents()

setCustomComponent

public void setCustomComponent(SpaceCustomComponent component)

setNumOfPartitions

public void setNumOfPartitions(int numOfPartitions)

isSyncReplicationEnabled

public boolean isSyncReplicationEnabled()

isMirrorServiceEnabled

public boolean isMirrorServiceEnabled()

getMirrorServiceConfig

public MirrorServiceConfig getMirrorServiceConfig()

hasReplicationTargets

public boolean hasReplicationTargets()

isPrimaryElectionAvailable

public boolean isPrimaryElectionAvailable()

getClusterName

public String getClusterName()

getClusterSchema

public String getClusterSchema()

setTopology

public void setTopology(ClusterTopology topology)

isTieredStorage

public boolean isTieredStorage()

tieredStorageConfigString

public Map<String,TieredStorageTableConfig> tieredStorageConfigString()

toString

public String toString()

Overrides:

toString in class Object

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

isChunksRouting

public boolean isChunksRouting()

getPartitionId

public int getPartitionId(int routingValue)

getPartitionId

public int getPartitionId(long routingValue)