Custom Cluster Test

clusterTest.cs

  public class CustomReplicationInformer : IDocumentStoreReplicationInformer
        {
            private readonly ReplicationInformer _informer;

            public CustomReplicationInformer(DocumentConvention conventions, HttpJsonRequestFactory jsonRequestFactory, Func<string, IRequestTimeMetric> requestTimeMetricGetter)
            {
                _informer = new ReplicationInformer(conventions, jsonRequestFactory, requestTimeMetricGetter);
            }

            public event EventHandler<FailoverStatusChangedEventArgs> FailoverStatusChanged
            {
                add { _informer.FailoverStatusChanged += value; }
                remove { _informer.FailoverStatusChanged -= value; }
            }
            public int DelayTimeInMiliSec
            {
                get { return _informer.DelayTimeInMiliSec; }
                set { _informer.DelayTimeInMiliSec = value; }
            }
            public List<OperationMetadata> ReplicationDestinations
            {
                get { return _informer.ReplicationDestinations; }
            }
            public List<OperationMetadata> ReplicationDestinationsUrls
            {
                get { return _informer.ReplicationDestinationsUrls; }
            }
            public FailureCounters FailureCounters
            {
                get { return _informer.FailureCounters; }
            }
            public int GetReadStripingBase(bool increment)
            {
                return _informer.GetReadStripingBase(increment);
            }

            public ReplicationDestination[] FailoverServers
            {
                get { return _informer.FailoverServers; }
                set { _informer.FailoverServers = value; }
            }
            public Task UpdateReplicationInformationIfNeededAsync(AsyncServerClient serverClient)
            {
                return _informer.UpdateReplicationInformationIfNeededAsync(serverClient);
            }

            public void ClearReplicationInformationLocalCache(ServerClient client)
            {
                _informer.ClearReplicationInformationLocalCache(client);
            }

            public void RefreshReplicationInformation(AsyncServerClient serverClient)
            {
                _informer.RefreshReplicationInformation(serverClient);
            }

            public void RefreshReplicationInformation(ServerClient serverClient)
            {
                _informer.RefreshReplicationInformation(serverClient);
            }

            public void Dispose()
            {
                _informer.Dispose();
            }

            public Task<T> ExecuteWithReplicationAsync<T>(HttpMethod method, string primaryUrl, OperationCredentials primaryCredentials,
                int currentRequest, int currentReadStripingBase, Func<OperationMetadata, IRequestTimeMetric, Task<T>> operation, CancellationToken token = new CancellationToken())
            {
                primaryUrl = method.Method == "GET" ? ReadFromDb : WriteToDb; //This is the only thing I care about
                return _informer.ExecuteWithReplicationAsync(method, primaryUrl, primaryCredentials, currentRequest, currentReadStripingBase, operation, token);
            }

        }