Added hidden options for upcoming cloud DRL (#55)

These are currently meant for testing only.

Author: connelly38

driver/src/main/java/oracle/nosql/driver/ops/Request.java

@@ -73,6 +73,8 @@ public abstract class Request {
      */
     private RateLimiter writeRateLimiter;
     private int rateLimitDelayedMs;
+    private boolean preferThrottling;
+    private boolean drlOptIn;
 
     /**
      * @hidden
@@ -493,6 +495,43 @@ public boolean getIsRefresh() {
      */
     public abstract String getTypeName();
 
+    /**
+     * @hidden
+     * Cloud only
+     * If using DRL, return immediate throttling error if the
+     * table is currently over its configured throughput limit.
+     * Otherwise, allow DRL to delay request processing to match
+     * table limits (default).
+     */
+    public void setPreferThrottling(boolean preferThrottling) {
+        this.preferThrottling = preferThrottling;
+    }
+
+    /**
+     * @hidden
+     */
+    public boolean getPreferThrottling() {
+        return preferThrottling;
+    }
+
+    /**
+     * @hidden
+     * Cloud only
+     * Opt-in to using Distributed Rate Limiting (DRL). This setting
+     * will eventually be deprecated, as all requests will eventually
+     * use DRL unconditionally in the cloud.
+     */
+    public void setDRLOptIn(boolean drlOptIn) {
+        this.drlOptIn = drlOptIn;
+    }
+
+    /**
+     * @hidden
+     */
+    public boolean getDRLOptIn() {
+        return drlOptIn;
+    }
+
     /**
      * @hidden
      * Copy internal fields to another Request object.
@@ -509,5 +548,7 @@ public void copyTo(Request other) {
         other.setReadRateLimiter(this.readRateLimiter);
         other.setWriteRateLimiter(this.writeRateLimiter);
         other.setRateLimitDelayedMs(this.rateLimitDelayedMs);
+        other.setPreferThrottling(this.preferThrottling);
+        other.setDRLOptIn(this.drlOptIn);
     }
 }

driver/src/main/java/oracle/nosql/driver/ops/serde/nson/NsonProtocol.java

@@ -30,6 +30,7 @@ public class NsonProtocol {
     public static String CONTINUATION_KEY = "ck";
     public static String DATA = "d";
     public static String DEFINED_TAGS = "dt";
+    public static String DRL_OPTIN = "dro";
     public static String DURABILITY = "du";
     public static String END = "en";
     public static String ETAG = "et";
@@ -65,6 +66,7 @@ public class NsonProtocol {
     public static String OP_CODE = "o";
     public static String PATH = "pt";
     public static String PAYLOAD = "p";
+    public static String PREFER_THROTTLING = "pg";
     public static String PREPARE = "pp";
     public static String PREPARED_QUERY = "pq";
     public static String PREPARED_STATEMENT = "ps";
@@ -165,6 +167,7 @@ public class NsonProtocol {
         {CONTINUATION_KEY,"CONTINUATION_KEY"},
         {DATA,"DATA"},
         {DEFINED_TAGS,"DEFINED_TAGS"},
+        {DRL_OPTIN,"DRL_OPTIN"},
         {DURABILITY,"DURABILITY"},
         {END,"END"},
         {ETAG,"ETAG"},
@@ -200,6 +203,7 @@ public class NsonProtocol {
         {OP_CODE,"OP_CODE"},
         {PATH,"PATH"},
         {PAYLOAD,"PAYLOAD"},
+        {PREFER_THROTTLING,"PREFER_THROTTLING"},
         {PREPARE,"PREPARE"},
         {PREPARED_QUERY,"PREPARED_QUERY"},
         {PREPARED_STATEMENT,"PREPARED_STATEMENT"},

driver/src/main/java/oracle/nosql/driver/ops/serde/nson/NsonSerializerFactory.java

@@ -1792,6 +1792,12 @@ protected static void writeHeader(NsonSerializer ns, int op, Request rq)
             }
             writeMapField(ns, OP_CODE, op);
             writeMapField(ns, TIMEOUT, rq.getTimeoutInternal());
+            if (rq.getPreferThrottling()) {
+                writeMapField(ns, PREFER_THROTTLING, true);
+            }
+            if (rq.getDRLOptIn()) {
+                writeMapField(ns, DRL_OPTIN, true);
+            }
         }
 
         /**