Added the ArrayLimit run optarg

dancannon · dancannon · commit 641c69e2210d · 2014-08-31T18:29:51.000+01:00
diff --git a/query.go b/query.go
@@ -113,6 +113,7 @@ type RunOpts struct {
 	Profile      interface{} `gorethink:"profile,omitempty"`
 	UseOutdated  interface{} `gorethink:"use_outdated,omitempty"`
 	NoReply      interface{} `gorethink:"noreply,omitempty"`
+	ArrayLimit   interface{} `gorethink:"array_limit,omitempty"`
 	TimeFormat   interface{} `gorethink:"time_format,omitempty"`
 	GroupFormat  interface{} `gorethink:"group_format,omitempty"`
 	BinaryFormat interface{} `gorethink:"binary_format,omitempty"`
diff --git a/query_aggregation.go b/query_aggregation.go
@@ -27,7 +27,7 @@ func (t Term) Distinct(optArgs ...DistinctOpts) Term {
 	if len(optArgs) >= 1 {
 		opts = optArgs[0].toMap()
 	}
-	return constructMethodTerm(t, "Distinct", p.Term_DISTINCT, []interface{}, opts)
+	return constructMethodTerm(t, "Distinct", p.Term_DISTINCT, []interface{}{}, opts)
 }
 
 // Takes a stream and partitions it into multiple groups based on the

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@ func (t Term) Distinct(optArgs ...DistinctOpts) Term {`
`27`	`27`	`if len(optArgs) >= 1 {`
`28`	`28`	`opts = optArgs[0].toMap()`
`29`	`29`	`}`
`30`		`- return constructMethodTerm(t, "Distinct", p.Term_DISTINCT, []interface{}, opts)`
	`30`	`+ return constructMethodTerm(t, "Distinct", p.Term_DISTINCT, []interface{}{}, opts)`
`31`	`31`	`}`
`32`	`32`
`33`	`33`	`// Takes a stream and partitions it into multiple groups based on the`