public class ReplicationInformer extends ReplicationInformerBase<ServerClient> implements IDocumentStoreReplicationInformer
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationInformer.FailoverStatusChangedEventArgs |
ReplicationInformerBase.FailureCounter, ReplicationInformerBase.OperationResult<T>
conventions, failoverStatusChanged, failureCounts, firstTime, lastReplicationUpdate, log, readStripingBase, refreshReplicationInformationTask, replicationDestinations, replicationLock
Constructor and Description |
---|
ReplicationInformer(Convention conventions,
HttpJsonRequestFactory jsonRequestFactory) |
Modifier and Type | Method and Description |
---|---|
void |
clearReplicationInformationLocalCache(ServerClient client)
Clears the replication information local cache.
|
void |
close() |
ReplicationDestination[] |
getFailoverServers() |
protected String |
getServerCheckUrl(String baseUrl) |
void |
refreshReplicationInformation(ServerClient commands)
Refreshes the replication information.
|
void |
setFailoverServers(ReplicationDestination[] failoverServers) |
void |
updateReplicationInformationIfNeeded(ServerClient serverClient)
Updates replication information if needed
|
addFailoverStatusChanged, dispose, executeWithReplication, forceCheck, getDelayTimeInMiliSec, getFailureCount, getFailureLastCheck, getHolder, getReadStripingBase, getReplicationDestinations, getReplicationDestinationsUrls, isHttpStatus, isInvalidDestinationsDocument, isServerDown, removeFailoverStatusChanged, resetFailureCount, setDelayTimeInMiliSec, shouldExecuteUsing, tryOperation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addFailoverStatusChanged, executeWithReplication, forceCheck, getDelayTimeInMiliSec, getFailureCount, getFailureLastCheck, getReadStripingBase, getReplicationDestinations, getReplicationDestinationsUrls, isHttpStatus, isServerDown, removeFailoverStatusChanged, setDelayTimeInMiliSec
public ReplicationInformer(Convention conventions, HttpJsonRequestFactory jsonRequestFactory)
public void setFailoverServers(ReplicationDestination[] failoverServers)
setFailoverServers
in interface IDocumentStoreReplicationInformer
public void clearReplicationInformationLocalCache(ServerClient client)
IReplicationInformerBase
clearReplicationInformationLocalCache
in interface IReplicationInformerBase<ServerClient>
clearReplicationInformationLocalCache
in class ReplicationInformerBase<ServerClient>
public ReplicationDestination[] getFailoverServers()
getFailoverServers
in interface IDocumentStoreReplicationInformer
public void updateReplicationInformationIfNeeded(ServerClient serverClient)
IDocumentStoreReplicationInformer
updateReplicationInformationIfNeeded
in interface IDocumentStoreReplicationInformer
protected String getServerCheckUrl(String baseUrl)
getServerCheckUrl
in class ReplicationInformerBase<ServerClient>
public void refreshReplicationInformation(ServerClient commands)
IReplicationInformerBase
refreshReplicationInformation
in interface IReplicationInformerBase<ServerClient>
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
Copyright © 2016. All Rights Reserved.