Skip to content

Commit 1a60591

Browse files
committed
FEATURE: Add CompletableFuture BTree insert/get API
1 parent ed6bc4e commit 1a60591

File tree

10 files changed

+1968
-9
lines changed

10 files changed

+1968
-9
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -194,12 +194,12 @@ public class ArcusClient extends FrontCacheMemcachedClient implements ArcusClien
194194

195195
private final Transcoder<Object> collectionTranscoder;
196196

197-
private static final int BOPGET_BULK_CHUNK_SIZE = 200;
198-
private static final int SMGET_CHUNK_SIZE = 500;
197+
public static final int BOPGET_BULK_CHUNK_SIZE = 200;
198+
public static final int SMGET_CHUNK_SIZE = 500;
199199
private static final int NON_PIPED_BULK_INSERT_CHUNK_SIZE = 500;
200200

201-
private static final int MAX_GETBULK_ELEMENT_COUNT = 50;
202-
private static final int MAX_SMGET_COUNT = 1000; // server configuration is 2000.
201+
public static final int MAX_GETBULK_ELEMENT_COUNT = 50;
202+
public static final int MAX_SMGET_COUNT = 1000; // server configuration is 2000.
203203

204204
private static final int SHUTDOWN_TIMEOUT_MILLISECONDS = 2000;
205205
private static final AtomicInteger CLIENT_ID = new AtomicInteger(1);
@@ -3178,7 +3178,7 @@ public void complete() {
31783178
return rv;
31793179
}
31803180

3181-
private void checkDupKey(Collection<String> keyList) {
3181+
public void checkDupKey(Collection<String> keyList) {
31823182
/*
31833183
* Dup Check -> insure elements sequentially added to keyList
31843184
* */

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public BTreeSMGetWithByteTypeBkey(MemcachedNode node, List<String> keyList,
3131
eFlagFilter, count, unique);
3232
}
3333

34-
private BTreeSMGetWithByteTypeBkey(MemcachedNode node, List<String> keyList,
34+
public BTreeSMGetWithByteTypeBkey(MemcachedNode node, List<String> keyList,
3535
String range,
3636
ElementFlagFilter eFlagFilter,
3737
int count, boolean unique) {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public BTreeSMGetWithLongTypeBkey(MemcachedNode node, List<String> keyList,
2929
super(node, keyList, from + ".." + to, eFlagFilter, count, unique);
3030
}
3131

32-
private BTreeSMGetWithLongTypeBkey(MemcachedNode node, List<String> keyList,
32+
public BTreeSMGetWithLongTypeBkey(MemcachedNode node, List<String> keyList,
3333
String range,
3434
ElementFlagFilter eFlagFilter,
3535
int count, boolean unique) {

0 commit comments

Comments
 (0)