FEATURE: Add CompletableFuture BTree insert/get API

Author: oliviarla

src/main/java/net/spy/memcached/ArcusClient.java

@@ -195,11 +195,11 @@ public class ArcusClient extends FrontCacheMemcachedClient implements ArcusClien
 
   private final int smgetKeyChunkSize;
 
-  private static final int BOPGET_BULK_CHUNK_SIZE = 200;
+  public static final int BOPGET_BULK_CHUNK_SIZE = 200;
   private static final int NON_PIPED_BULK_INSERT_CHUNK_SIZE = 500;
 
-  private static final int MAX_GETBULK_ELEMENT_COUNT = 50;
-  private static final int MAX_SMGET_COUNT = 1000; // server configuration is 2000.
+  public static final int MAX_GETBULK_ELEMENT_COUNT = 50;
+  public static final int MAX_SMGET_COUNT = 1000; // server configuration is 2000.
   private static final int MAX_MKEY_LENGTH = 250;
 
   private static final int SHUTDOWN_TIMEOUT_MILLISECONDS = 2000;
@@ -3207,7 +3207,7 @@ public void complete() {
     return rv;
   }
 
-  private void validateKeys(Collection<String> keyList) {
+  public void validateKeys(Collection<String> keyList) {
     if (keyList == null) {
       throw new IllegalArgumentException("Key list is null.");
     } else if (keyList.isEmpty()) {
@@ -3219,7 +3219,7 @@ private void validateKeys(Collection<String> keyList) {
     }
   }
 
-  private void checkDupKey(Collection<String> keyList) {
+  public void checkDupKey(Collection<String> keyList) {
     /*
      * Dup Check -> insure elements sequentially added to keyList
      * */
@@ -3243,6 +3243,10 @@ private CollectionOperationStatus toCollectionOperationStatus(OperationStatus st
     }
   }
 
+  public Transcoder<Object> getCollectionTranscoder() {
+    return collectionTranscoder;
+  }
+
   /**
    * Get the client version.
    *
@@ -3282,4 +3286,8 @@ public static String getVersion() {
     }
     return VERSION;
   }
+
+  public int getSmgetKeyChunkSize() {
+    return this.smgetKeyChunkSize;
+  }
 }

src/main/java/net/spy/memcached/collection/BTreeSMGetWithByteTypeBkey.java

@@ -31,7 +31,7 @@ public BTreeSMGetWithByteTypeBkey(MemcachedNode node, List<String> keyList,
         eFlagFilter, count, unique);
   }
 
-  private BTreeSMGetWithByteTypeBkey(MemcachedNode node, List<String> keyList,
+  public BTreeSMGetWithByteTypeBkey(MemcachedNode node, List<String> keyList,
                                      String range,
                                      ElementFlagFilter eFlagFilter,
                                      int count, boolean unique) {

src/main/java/net/spy/memcached/collection/BTreeSMGetWithLongTypeBkey.java

@@ -29,7 +29,7 @@ public BTreeSMGetWithLongTypeBkey(MemcachedNode node, List<String> keyList,
     super(node, keyList, from + ".." + to, eFlagFilter, count, unique);
   }
 
-  private BTreeSMGetWithLongTypeBkey(MemcachedNode node, List<String> keyList,
+  public BTreeSMGetWithLongTypeBkey(MemcachedNode node, List<String> keyList,
                                      String range,
                                      ElementFlagFilter eFlagFilter,
                                      int count, boolean unique) {