|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.j_spaces.core.cluster.ReplicationPolicy
public class ReplicationPolicy
Nested Class Summary | |
---|---|
static class |
ReplicationPolicy.MirrorServiceConfig
mirror service configuration |
static class |
ReplicationPolicy.ReplicationPolicyDescription
Replication policy description for every member. |
Constructor Summary | |
---|---|
ReplicationPolicy()
|
Method Summary | |
---|---|
String |
getCommunicationMode()
|
long |
getMaxRedoLogCapacity()
|
ReplicationPolicy.MirrorServiceConfig |
getMirrorServiceConfig()
|
com.gigaspaces.cluster.activeelection.PrimarySpaceSelector |
getPrimarySpaceSelector()
|
List<SpaceURL> |
getPrimaryTargets(List<String> excludeTargets)
Returns a list of URLs or an empty list of primary targets . |
String |
getProtocolAdaptorClass()
Returns protocol adaptor class of this member. |
List<SpaceURL> |
getRecoverableTargets(List<String> excludeTargets)
Finds all the recovery targets in cluster. |
int |
getRecoveryChunkSize()
|
int |
getRecoveryThreadPoolSize()
|
int |
getSpaceMemberPosition(String spaceMemberName)
This method returns the relative position of the specified space member in the replication group, or -1 if the space member is not found. |
List<SpaceURL> |
getSyncTargets(List<String> excludeTargets)
Returns a list of URLs or an empty list of reliable targets to recover from. |
boolean |
isMirrorServiceEnabled()
|
boolean |
isMulticast()
|
boolean |
isOwnerMemberHasSyncReplication()
returns true if this member has sync-replication to at least one target. |
boolean |
isReliableAsyncRepl()
|
boolean |
isReplicateOriginalState()
|
void |
setCommunicationMode(String communicationMode)
|
void |
setMaxRedoLogCapacity(long capacity)
|
void |
setMirrorServiceConfig(ReplicationPolicy.MirrorServiceConfig mirrorServiceConfig)
|
void |
setPermittedOperations(List<ReplicationOperationType> permittedOperations)
|
void |
setPrimarySpaceSelector(com.gigaspaces.cluster.activeelection.PrimarySpaceSelector primarySpaceSelector)
|
void |
setProtocolAdaptorClass(String protocolAdaptorClass)
|
void |
setRecoveryChunkSize(int recoveryChunkSize)
|
void |
setRecoveryThreadPoolSize(int recoveryThreadPoolSize)
|
void |
setReliableAsyncRepl(boolean reliableAsyncRepl)
Sets the async-replication 'reliable' indicator; default false |
void |
setReplicatedOriginalState(boolean isReplOriginalState)
|
boolean |
shouldReplicate(ReplicationOperationType operType)
|
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final String UNICAST_COMMUNICATION_MODE
public static final String MULTICAST_COMMUNICATION_MODE
public static final int UNICAST
public static final int MULTICAST
public static final String ASYNC_REPLICATION_MODE
public static final String SYNC_REPLICATION_MODE
public static final String SYNC_REC_ACK_REPLICATION_MODE
public static final String ASYNC_REC_ACK_REPLICATION_MODE
public static final int FULL_REPLICATION
public static final int PARTIAL_REPLICATION
public static final String DEFAULT_REPL_ORIGINAL_STATE
public static final int DEFAULT_REPL_CHUNK_SIZE
public static final int DEFAULT_REPL_INTERVAL_MILLIS
public static final int DEFAULT_REPL_INTERVAL_OPERS
public static final int DEFAULT_REPL_SPACE_FINDER_TIMEOUT
public static final int DEFAULT_REPL_SPACE_FINDER_REPORT_INTERVAL
public static final int DEFAULT_SYNC_ON_COMMIT_TIMEOUT
public String m_OwnMemberName
public String m_ReplicationGroupName
public List<String> m_ReplicationGroupMembersNames
public List<SpaceURL> m_ReplicationGroupMembersURLs
public boolean m_ReplicateNotifyTemplates
public boolean m_TriggerNotifyTemplates
public boolean m_SyncOnCommit
public String m_ReplicationMode
public int m_PolicyType
public int m_ReplicationChunkSize
public long m_ReplicationIntervalMillis
public int m_ReplicationIntervalOperations
public long m_SpaceFinderTimeout
public long m_SpaceFinderReportInterval
public long m_SyncOnCommitTimeout
public boolean m_Recovery
public Hashtable<String,ReplicationPolicy.ReplicationPolicyDescription> m_ReplMemberPolicyDescTable
public boolean m_IsSyncReplicationEnabled
public com.j_spaces.core.cluster.sync_replication.SyncReplPolicy m_SyncReplPolicy
public String protocolAdaptorClass
public String communicationMode
public String clusterName
public static final String DEFAULT_MIRROR_SERVICE_NAME
public static final String DEFAULT_MIRROR_SERVICE_CONNECTOR_NAME
Constructor Detail |
---|
public ReplicationPolicy()
Method Detail |
---|
public void setMirrorServiceConfig(ReplicationPolicy.MirrorServiceConfig mirrorServiceConfig)
public ReplicationPolicy.MirrorServiceConfig getMirrorServiceConfig()
null
if the mirror-service disabledpublic boolean isMirrorServiceEnabled()
public boolean isReliableAsyncRepl()
public boolean shouldReplicate(ReplicationOperationType operType)
public void setPermittedOperations(List<ReplicationOperationType> permittedOperations)
public void setReliableAsyncRepl(boolean reliableAsyncRepl)
reliableAsyncRepl
- true if reliable-async-replication is enabled; false otherwise.public void setMaxRedoLogCapacity(long capacity)
public long getMaxRedoLogCapacity()
public boolean isOwnerMemberHasSyncReplication()
true
if this member has sync-replication to at least one target.
public void setPrimarySpaceSelector(com.gigaspaces.cluster.activeelection.PrimarySpaceSelector primarySpaceSelector)
public com.gigaspaces.cluster.activeelection.PrimarySpaceSelector getPrimarySpaceSelector()
public List<SpaceURL> getRecoverableTargets(List<String> excludeTargets)
excludeTargets
- targets that should be excluded from search
public List<SpaceURL> getSyncTargets(List<String> excludeTargets)
This differs from #getRecoverableTargets()
in that:
1. all URLs are returned and there is no multicast URL - We need specific
members.
2. The target is chosen only if it sync-replicates to 'this', in contrast
to returning a target which 'this' replicates to.
excludeTargets
- primaryElectionAvailable
- true if primary election is used; false otherwise.
public List<SpaceURL> getPrimaryTargets(List<String> excludeTargets)
excludeTargets
-
public boolean isMulticast()
public String getCommunicationMode()
public void setCommunicationMode(String communicationMode)
communicationMode
- The communicationMode to set.public String getProtocolAdaptorClass()
public void setProtocolAdaptorClass(String protocolAdaptorClass)
protocolAdaptorClass
- The protocolAdaptorClass to set.public int getSpaceMemberPosition(String spaceMemberName)
public final int getRecoveryChunkSize()
public void setRecoveryChunkSize(int recoveryChunkSize)
public final boolean isReplicateOriginalState()
public void setReplicatedOriginalState(boolean isReplOriginalState)
public String toString()
toString
in class Object
public int getRecoveryThreadPoolSize()
public void setRecoveryThreadPoolSize(int recoveryThreadPoolSize)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |