Added the Index optarg to Distinct

Author: dancannon

query_aggregation.go

@@ -13,9 +13,21 @@ func (t Term) Reduce(args ...interface{}) Term {
 	return constructMethodTerm(t, "Reduce", p.Term_REDUCE, funcWrapArgs(args), map[string]interface{}{})
 }
 
+type DistinctOpts struct {
+	Index interface{} `gorethink:"index,omitempty"`
+}
+
+func (o *DistinctOpts) toMap() map[string]interface{} {
+	return optArgsToMap(o)
+}
+
 // Remove duplicate elements from the sequence.
-func (t Term) Distinct(args ...interface{}) Term {
-	return constructMethodTerm(t, "Distinct", p.Term_DISTINCT, args, map[string]interface{}{})
+func (t Term) Distinct(optArgs ...DistinctOpts) Term {
+	opts := map[string]interface{}{}
+	if len(optArgs) >= 1 {
+		opts = optArgs[0].toMap()
+	}
+	return constructMethodTerm(t, "Distinct", p.Term_DISTINCT, []interface{}, opts)
 }
 
 // Takes a stream and partitions it into multiple groups based on the

query_table.go

@@ -102,7 +102,11 @@ func (o *IndexRenameOpts) toMap() map[string]interface{} {
 // new name will be deleted and the index will be renamed. If overwrite is False
 // (the default) an error will be raised if the new index name already exists.
 func (t Term) IndexRename(oldName, newName interface{}, optArgs ...IndexRenameOpts) Term {
-	return constructMethodTerm(t, "IndexRename", p.Term_INDEX_RENAME, []interface{}{oldName, newName}, map[string]interface{}{})
+	opts := map[string]interface{}{}
+	if len(optArgs) >= 1 {
+		opts = optArgs[0].toMap()
+	}
+	return constructMethodTerm(t, "IndexRename", p.Term_INDEX_RENAME, []interface{}{oldName, newName}, opts)
 }
 
 // Get the status of the specified indexes on this table, or the status of all