public interface IReplicationInformerBase<T>
extends java.io.Closeable
Modifier and Type | Method and Description |
---|---|
void |
addFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event) |
void |
clearReplicationInformationLocalCache(T client)
Clears the replication information local cache.
|
<S> S |
executeWithReplication(HttpMethods method,
java.lang.String primaryUrl,
OperationCredentials primaryCredentials,
int currentRequest,
int currentReadStripingBase,
Function1<OperationMetadata,S> operation) |
void |
forceCheck(java.lang.String primaryUrl,
boolean shouldForceCheck) |
int |
getDelayTimeInMiliSec() |
java.util.concurrent.atomic.AtomicLong |
getFailureCount(java.lang.String operationUrl)
Get the current failure count for the url
|
java.util.Date |
getFailureLastCheck(java.lang.String operationUrl)
Get failure last check time for the url
|
int |
getReadStripingBase() |
java.util.List<OperationMetadata> |
getReplicationDestinations() |
java.util.List<OperationMetadata> |
getReplicationDestinationsUrls() |
boolean |
isHttpStatus(java.lang.Exception e,
int... httpStatusCode) |
boolean |
isServerDown(java.lang.Exception e,
Reference<java.lang.Boolean> timeout) |
void |
refreshReplicationInformation(T client)
Refreshes the replication information.
|
void |
removeFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event) |
void |
setDelayTimeInMiliSec(int value) |
void addFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event)
void removeFailoverStatusChanged(EventHandler<ReplicationInformer.FailoverStatusChangedEventArgs> event)
int getDelayTimeInMiliSec()
void setDelayTimeInMiliSec(int value)
java.util.List<OperationMetadata> getReplicationDestinations()
java.util.List<OperationMetadata> getReplicationDestinationsUrls()
void refreshReplicationInformation(T client)
client
- void clearReplicationInformationLocalCache(T client)
client
- java.util.concurrent.atomic.AtomicLong getFailureCount(java.lang.String operationUrl)
operationUrl
- java.util.Date getFailureLastCheck(java.lang.String operationUrl)
operationUrl
- int getReadStripingBase()
<S> S executeWithReplication(HttpMethods method, java.lang.String primaryUrl, OperationCredentials primaryCredentials, int currentRequest, int currentReadStripingBase, Function1<OperationMetadata,S> operation) throws ServerClientException
ServerClientException
void forceCheck(java.lang.String primaryUrl, boolean shouldForceCheck)
boolean isServerDown(java.lang.Exception e, Reference<java.lang.Boolean> timeout)
boolean isHttpStatus(java.lang.Exception e, int... httpStatusCode)
Copyright © 2014. All Rights Reserved.