[taoensso#92] scan now support consistent reads

Author: ricardojmendez

Diff for: src/taoensso/faraday.clj

@@ -1152,7 +1152,7 @@
   [table
    & [{:keys [attr-conds last-prim-kvs return limit total-segments
               proj-expr expr-attr-names filter-expr expr-attr-vals
-              index segment return-cc?] :as opts}]]
+              consistent? index segment return-cc?] :as opts}]]
   (doto-cond [g (ScanRequest.)]
     :always (.setTableName (name table))
     attr-conds      (.setScanFilter        (query|scan-conditions g))
@@ -1166,6 +1166,7 @@
     proj-expr       (.setProjectionExpression g)
     total-segments  (.setTotalSegments     (int g))
     segment         (.setSegment           (int g))
+    consistent?     (.setConsistentRead consistent?)
     (coll?* return) (.setAttributesToGet (mapv name return))
     return-cc? (.setReturnConsumedCapacity (utils/enum :total))
     (and return (not (coll?* return)))
@@ -1188,6 +1189,7 @@
                              [<attr> ...]}.
     :total-segments  - Total number of parallel scan segments.
     :segment         - Calling worker's segment number (>=0, <=total-segments).
+    :consistent?     - If the scan should use consistent reads
 
   comparison-operators e/o #{:eq :le :lt :ge :gt :begins-with :between :ne
                              :not-null :null :contains :not-contains :in}.

Diff for: test/taoensso/faraday/tests/requests.clj

@@ -437,3 +437,16 @@
   (expect "age, #t" (.getProjectionExpression req))
   (expect {"#t" "year"} (.getExpressionAttributeNames req))
   )
+
+(let [req ^ScanRequest (scan-request
+                         :scan
+                         {:filter-expr "age < 25"
+                          :index       "age-index"
+                          :limit       5
+                          :consistent? true})]
+  (expect "scan" (.getTableName req))
+  (expect 5 (.getLimit req))
+  (expect "age < 25" (.getFilterExpression req))
+  (expect "age-index" (.getIndexName req))
+  (expect (.getConsistentRead req))
+  )