GODRIVER-354: Add Optioners for Index Commands

Author: igorKryvenko

core/command/create_indexes.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/mongodb/mongo-go-driver/bson"
 	"github.com/mongodb/mongo-go-driver/core/description"
+	"github.com/mongodb/mongo-go-driver/core/options"
 	"github.com/mongodb/mongo-go-driver/core/result"
 	"github.com/mongodb/mongo-go-driver/core/wiremessage"
 )
@@ -21,9 +22,9 @@ import (
 type CreateIndexes struct {
 	NS      Namespace
 	Indexes *bson.Array
-
-	result result.CreateIndexes
-	err    error
+	Opts    []options.CreateIndexesOptioner
+	result  result.CreateIndexes
+	err     error
 }
 
 // Encode will encode this command into a wire message for the given server description.
@@ -33,6 +34,16 @@ func (ci *CreateIndexes) Encode(desc description.SelectedServer) (wiremessage.Wi
 		bson.EC.Array("indexes", ci.Indexes),
 	)
 
+	for _, opt := range ci.Opts {
+		if opt == nil {
+			continue
+		}
+		err := opt.Option(cmd)
+		if err != nil {
+			return nil, err
+		}
+	}
+
 	return (&Command{DB: ci.NS.DB, Command: cmd, isWrite: true}).Encode(desc)
 }
 

core/command/drop_indexes.go

@@ -11,16 +11,17 @@ import (
 
 	"github.com/mongodb/mongo-go-driver/bson"
 	"github.com/mongodb/mongo-go-driver/core/description"
+	"github.com/mongodb/mongo-go-driver/core/options"
 	"github.com/mongodb/mongo-go-driver/core/wiremessage"
 )
 
 // DropIndexes represents the dropIndexes command.
 //
 // The dropIndexes command drops indexes for a namespace.
 type DropIndexes struct {
-	NS    Namespace
-	Index string
-
+	NS     Namespace
+	Index  string
+	Opts   []options.DropIndexesOptioner
 	result bson.Reader
 	err    error
 }
@@ -32,6 +33,16 @@ func (di *DropIndexes) Encode(desc description.SelectedServer) (wiremessage.Wire
 		bson.EC.String("index", di.Index),
 	)
 
+	for _, opt := range di.Opts {
+		if opt == nil {
+			continue
+		}
+		err := opt.Option(cmd)
+		if err != nil {
+			return nil, err
+		}
+	}
+
 	return (&Command{DB: di.NS.DB, Command: cmd, isWrite: true}).Encode(desc)
 }
 

core/command/list_indexes.go

@@ -19,9 +19,8 @@ import (
 //
 // The listIndexes command lists the indexes for a namespace.
 type ListIndexes struct {
-	NS   Namespace
-	Opts []options.ListIndexesOptioner
-
+	NS     Namespace
+	Opts   []options.ListIndexesOptioner
 	result Cursor
 	err    error
 }

core/options/options.go

@@ -137,18 +137,32 @@ type ListDatabasesOptioner interface {
 	listDatabasesOption()
 }
 
-// ListIndexesOptioner is the interface implemented by types that can be used as
-// Options for ListIndexes operations.
+// CursorOptioner is the interface implemented by types that can be used as
+// Options for Cursor operations.
+type CursorOptioner interface {
+	Optioner
+	cursorOption()
+}
+
+//ListIndexesOptioner is the interface implemented by types that can be used as
+// Options for list_indexes operations.
 type ListIndexesOptioner interface {
 	Optioner
 	listIndexesOption()
 }
 
-// CursorOptioner is the interface implemented by types that can be used as
-// Options for Cursor operations.
-type CursorOptioner interface {
+//CreateIndexesOptioner is the interface implemented by types that can be used as
+// Options for create_indexes operations.
+type CreateIndexesOptioner interface {
 	Optioner
-	cursorOption()
+	createIndexesOption()
+}
+
+//DropIndexesOptioner is the interface implemented by types that can be used as
+// Options for drop_indexes operations.
+type DropIndexesOptioner interface {
+	Optioner
+	dropIndexesOption()
 }
 
 var (
@@ -480,6 +494,9 @@ func (OptMaxTime) findOneOption()           {}
 func (OptMaxTime) findOneAndDeleteOption()  {}
 func (OptMaxTime) findOneAndReplaceOption() {}
 func (OptMaxTime) findOneAndUpdateOption()  {}
+func (OptMaxTime) listIndexesOption()       {}
+func (OptMaxTime) dropIndexesOption()       {}
+func (OptMaxTime) createIndexesOption()     {}
 
 // OptMin is for internal use.
 type OptMin struct{ Min *bson.Document }
@@ -705,6 +722,8 @@ func (OptWriteConcern) insertManyOption()        {}
 func (OptWriteConcern) insertOneOption()         {}
 func (OptWriteConcern) replaceOption()           {}
 func (OptWriteConcern) updateOption()            {}
+func (OptWriteConcern) createIndexesOption()     {}
+func (OptWriteConcern) dropIndexesOption()       {}
 
 // OptNameOnly is for internal use.
 type OptNameOnly bool