public class ReplicatedEnvironmentFacade extends Object implements EnvironmentFacade, com.sleepycat.je.rep.StateChangeListener
Modifier and Type | Class and Description |
---|---|
static class |
ReplicatedEnvironmentFacade.ReplicationNodeImpl |
static class |
ReplicatedEnvironmentFacade.State |
Modifier and Type | Field and Description |
---|---|
static String |
DB_PING_SOCKET_TIMEOUT_PROPERTY_NAME |
static String |
ENVIRONMENT_RESTART_RETRY_LIMIT_PROPERTY_NAME |
static String |
EXECUTOR_SHUTDOWN_TIMEOUT_PROPERTY_NAME |
static String |
MASTER_TRANSFER_TIMEOUT_PROPERTY_NAME |
static String |
PERMITTED_NODE_LIST |
static String |
REMOTE_NODE_MONITOR_INTERVAL_PROPERTY_NAME |
static String |
REMOTE_NODE_MONITOR_TIMEOUT_PROPERTY_NAME |
static com.sleepycat.je.Durability.ReplicaAckPolicy |
REPLICA_REPLICA_ACKNOWLEDGMENT_POLICY |
CACHE_MODE_DEFAULT, CACHE_MODE_PROPERTY_NAME, DEFAULT_LOG_HANDLER_CLEANER_PROTECTED_FILES_LIMIT, ENVCONFIG_DEFAULTS, LOG_HANDLER_CLEANER_PROTECTED_FILES_LIMIT_PROPERTY_NAME
Constructor and Description |
---|
ReplicatedEnvironmentFacade(ReplicatedEnvironmentConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
com.sleepycat.je.Transaction |
beginTransaction(com.sleepycat.je.TransactionConfig transactionConfig) |
void |
checkpoint(boolean force) |
int |
cleanLog() |
com.sleepycat.je.Database |
clearDatabase(String name,
com.sleepycat.je.DatabaseConfig databaseConfig) |
void |
close() |
void |
closeDatabase(String databaseName) |
void |
commit(com.sleepycat.je.Transaction tx,
boolean syncCommit) |
<X> com.google.common.util.concurrent.ListenableFuture<X> |
commitAsync(com.sleepycat.je.Transaction tx,
X val) |
static Collection<String> |
connectToHelperNodeAndCheckPermittedHosts(String nodeName,
String hostPort,
String groupName,
String helperNodeName,
String helperHostPort,
int dbPingSocketTimeout) |
static Set<String> |
convertApplicationStateBytesToPermittedNodeList(byte[] applicationState) |
void |
flushLog() |
void |
flushLogFailed(RuntimeException e) |
Map<String,Object> |
getDatabaseStatistics(String database,
boolean reset) |
Map<String,Map<String,Object>> |
getEnvironmentStatistics(boolean reset) |
ReplicatedEnvironmentFacade.State |
getFacadeState() |
String |
getGroupName() |
String |
getHelperHostPort() |
String |
getHostPort() |
long |
getJoinTime() |
long |
getLastKnownReplicationTransactionId() |
com.sleepycat.je.Durability |
getMessageStoreDurability() |
String |
getNodeName() |
Set<com.sleepycat.je.rep.ReplicationNode> |
getNodes() |
String |
getNodeState() |
int |
getNumberOfElectableGroupMembers() |
long |
getTotalLogSize() |
Map<String,Object> |
getTransactionStatistics(boolean reset) |
RuntimeException |
handleDatabaseException(String contextMessage,
RuntimeException dbe) |
boolean |
isCoalescingSync() |
boolean |
isDesignatedPrimary() |
boolean |
isMaster() |
com.sleepycat.je.Database |
openDatabase(String name,
com.sleepycat.je.DatabaseConfig databaseConfig) |
com.sleepycat.je.Sequence |
openSequence(com.sleepycat.je.Database database,
com.sleepycat.je.DatabaseEntry sequenceKey,
com.sleepycat.je.SequenceConfig sequenceConfig) |
void |
reduceSizeOnDisk() |
boolean |
removeNodeFromGroup(String nodeName) |
void |
setCacheSize(long cacheSize) |
Future<Void> |
setDesignatedPrimary(boolean isPrimary) |
Future<Void> |
setElectableGroupSizeOverride(int electableGroupOverride) |
void |
setMessageStoreDurability(com.sleepycat.je.Durability.SyncPolicy localTransactionSynchronizationPolicy,
com.sleepycat.je.Durability.SyncPolicy remoteTransactionSynchronizationPolicy,
com.sleepycat.je.Durability.ReplicaAckPolicy replicaAcknowledgmentPolicy)
This method should only be invoked from configuration thread on virtual host activation.
|
void |
setPermittedNodes(Collection<String> permittedNodes) |
Future<Void> |
setPriority(int priority) |
void |
setReplicationGroupListener(ReplicationGroupListener replicationGroupListener) |
void |
setStateChangeListener(com.sleepycat.je.rep.StateChangeListener stateChangeListener) |
void |
stateChange(com.sleepycat.je.rep.StateChangeEvent stateChangeEvent) |
Future<Void> |
transferMasterAsynchronously(String nodeName) |
Future<Void> |
transferMasterToSelfAsynchronously() |
void |
updateMutableConfig(ConfiguredObject<?> object) |
void |
upgradeIfNecessary(ConfiguredObject<?> parent) |
public static final String MASTER_TRANSFER_TIMEOUT_PROPERTY_NAME
public static final String DB_PING_SOCKET_TIMEOUT_PROPERTY_NAME
public static final String REMOTE_NODE_MONITOR_INTERVAL_PROPERTY_NAME
public static final String REMOTE_NODE_MONITOR_TIMEOUT_PROPERTY_NAME
public static final String ENVIRONMENT_RESTART_RETRY_LIMIT_PROPERTY_NAME
public static final String EXECUTOR_SHUTDOWN_TIMEOUT_PROPERTY_NAME
public static final com.sleepycat.je.Durability.ReplicaAckPolicy REPLICA_REPLICA_ACKNOWLEDGMENT_POLICY
public static final String PERMITTED_NODE_LIST
public ReplicatedEnvironmentFacade(ReplicatedEnvironmentConfiguration configuration)
public com.sleepycat.je.Transaction beginTransaction(com.sleepycat.je.TransactionConfig transactionConfig)
beginTransaction
in interface EnvironmentFacade
public void commit(com.sleepycat.je.Transaction tx, boolean syncCommit)
commit
in interface EnvironmentFacade
public <X> com.google.common.util.concurrent.ListenableFuture<X> commitAsync(com.sleepycat.je.Transaction tx, X val)
commitAsync
in interface EnvironmentFacade
public void close()
close
in interface EnvironmentFacade
public RuntimeException handleDatabaseException(String contextMessage, RuntimeException dbe)
handleDatabaseException
in interface EnvironmentFacade
public com.sleepycat.je.Database openDatabase(String name, com.sleepycat.je.DatabaseConfig databaseConfig)
openDatabase
in interface EnvironmentFacade
public com.sleepycat.je.Database clearDatabase(String name, com.sleepycat.je.DatabaseConfig databaseConfig)
clearDatabase
in interface EnvironmentFacade
public void closeDatabase(String databaseName)
closeDatabase
in interface EnvironmentFacade
public com.sleepycat.je.Sequence openSequence(com.sleepycat.je.Database database, com.sleepycat.je.DatabaseEntry sequenceKey, com.sleepycat.je.SequenceConfig sequenceConfig)
openSequence
in interface EnvironmentFacade
public void stateChange(com.sleepycat.je.rep.StateChangeEvent stateChangeEvent)
stateChange
in interface com.sleepycat.je.rep.StateChangeListener
public long getTotalLogSize()
getTotalLogSize
in interface EnvironmentFacade
public void reduceSizeOnDisk()
reduceSizeOnDisk
in interface EnvironmentFacade
public void flushLog()
flushLog
in interface EnvironmentFacade
public void setCacheSize(long cacheSize)
setCacheSize
in interface EnvironmentFacade
public void updateMutableConfig(ConfiguredObject<?> object)
updateMutableConfig
in interface EnvironmentFacade
public int cleanLog()
cleanLog
in interface EnvironmentFacade
public void checkpoint(boolean force)
checkpoint
in interface EnvironmentFacade
public Map<String,Map<String,Object>> getEnvironmentStatistics(boolean reset)
getEnvironmentStatistics
in interface EnvironmentFacade
public Map<String,Object> getTransactionStatistics(boolean reset)
getTransactionStatistics
in interface EnvironmentFacade
public Map<String,Object> getDatabaseStatistics(String database, boolean reset)
getDatabaseStatistics
in interface EnvironmentFacade
public void flushLogFailed(RuntimeException e)
flushLogFailed
in interface EnvironmentFacade
public Set<com.sleepycat.je.rep.ReplicationNode> getNodes()
public String getGroupName()
public String getNodeName()
public String getHostPort()
public String getHelperHostPort()
public com.sleepycat.je.Durability getMessageStoreDurability()
public boolean isCoalescingSync()
public String getNodeState()
public boolean isDesignatedPrimary()
public Future<Void> setElectableGroupSizeOverride(int electableGroupOverride)
public boolean removeNodeFromGroup(String nodeName)
public long getJoinTime()
public long getLastKnownReplicationTransactionId()
public void upgradeIfNecessary(ConfiguredObject<?> parent)
upgradeIfNecessary
in interface EnvironmentFacade
public ReplicatedEnvironmentFacade.State getFacadeState()
public void setStateChangeListener(com.sleepycat.je.rep.StateChangeListener stateChangeListener)
public int getNumberOfElectableGroupMembers()
public boolean isMaster()
public void setReplicationGroupListener(ReplicationGroupListener replicationGroupListener)
public void setMessageStoreDurability(com.sleepycat.je.Durability.SyncPolicy localTransactionSynchronizationPolicy, com.sleepycat.je.Durability.SyncPolicy remoteTransactionSynchronizationPolicy, com.sleepycat.je.Durability.ReplicaAckPolicy replicaAcknowledgmentPolicy)
public void setPermittedNodes(Collection<String> permittedNodes)
public static Set<String> convertApplicationStateBytesToPermittedNodeList(byte[] applicationState)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.