Index: impl/memory/datastore.go |
diff --git a/impl/memory/datastore.go b/impl/memory/datastore.go |
index e9d7a66d98008b01657dd5637a1a1d04cae0c5d2..973d59b8d3753beb31511366b91046e04a8cb76e 100644 |
--- a/impl/memory/datastore.go |
+++ b/impl/memory/datastore.go |
@@ -102,7 +102,11 @@ func (d *dsImpl) CatchupIndexes() { |
} |
func (d *dsImpl) SetTransactionRetryCount(count int) { |
- d.data.txnFakeRetry = count |
+ d.data.setTxnRetry(count) |
+} |
+ |
+func (d *dsImpl) Consistent(always bool) { |
+ d.data.setConsistent(always) |
} |
func (d *dsImpl) Testable() ds.Testable { |