Add ConsistentRead to Scan query

underarmour · Aug 7, 2017 · 8c3974e · 8c3974e
1 parent e3946db
commit 8c3974e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/functional_test.go b/functional_test.go
@@ -347,7 +347,7 @@ func TestQueryPagination(t *testing.T) {
 func TestScanBasic(t *testing.T) {
 	assert, client := funcTest.setUp(t)
 	assert.NoError(batchAddPosts(client, 50, 100, 120))
-	scan := client.Scan("Posts").Limit(20)
+	scan := client.Scan("Posts").ConsistentRead(true).Limit(20)
 	result, err := scan.Execute()
 	assert.NoError(err)
 	assert.NotEqual(0, len(result.Items))

diff --git a/request_scan.go b/request_scan.go
@@ -16,6 +16,12 @@ func newScan(c *Client, table string) *Scan {
 	return &Scan{c, req}
 }
 
+// ConsistentRead does a strongly consistent scan if strong is true. (defaults to false)
+func (s Scan) ConsistentRead(strong bool) *Scan {
+	s.req.ConsistentRead = &strong
+	return &s
+}
+
 /*
 ExclusiveStartKey sets the start key (effectively the offset cursor).
 */