Skip to content

Commit a9dc006

Browse files
committed
FEATURE: Add CompletableFuture BTree insert/get API
1 parent fb8b04f commit a9dc006

9 files changed

Lines changed: 2198 additions & 6 deletions

File tree

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -196,12 +196,12 @@ public class ArcusClient extends FrontCacheMemcachedClient implements ArcusClien
196196

197197
private final Transcoder<Object> collectionTranscoder;
198198

199-
private static final int BOPGET_BULK_CHUNK_SIZE = 200;
200-
private static final int SMGET_CHUNK_SIZE = 500;
199+
public static final int BOPGET_BULK_CHUNK_SIZE = 200;
200+
public static final int SMGET_CHUNK_SIZE = 500;
201201
private static final int NON_PIPED_BULK_INSERT_CHUNK_SIZE = 500;
202202

203-
private static final int MAX_GETBULK_ELEMENT_COUNT = 50;
204-
private static final int MAX_SMGET_COUNT = 1000; // server configuration is 2000.
203+
public static final int MAX_GETBULK_ELEMENT_COUNT = 50;
204+
public static final int MAX_SMGET_COUNT = 1000; // server configuration is 2000.
205205

206206
private static final int SHUTDOWN_TIMEOUT_MILLISECONDS = 2000;
207207
private static final AtomicInteger CLIENT_ID = new AtomicInteger(1);

0 commit comments

Comments
 (0)