Added find allowDiskUse options.

dalmdl/coremongo/coremongo.go

@@ -152,7 +152,7 @@ func InitNewSession(hostDetails MongoHost) error {
 	return nil
 }
 
-//GetMongoConnection method
+// GetMongoConnection method
 func GetMongoConnection(hostName string) (*mongo.Client, error) {
 	mutex.Lock()
 	defer mutex.Unlock()
@@ -359,7 +359,7 @@ func (mg *MongoDAO) DeleteAll(selector map[string]interface{}) error {
 	return deleteError
 }
 
-//Set Find Options
+// Set Find Options
 func (mg *MongoDAO) SetFindOps(findOps map[string]interface{}) {
 	mg.MetaData.Findops = findOps
 }
@@ -405,6 +405,9 @@ func (mg *MongoDAO) GetProjectedData(selector map[string]interface{}, projector
 			})
 			ops.SetSort(sort)
 		}
+		if obj.Get("allowDiskUse").Value() != nil {
+			ops.SetAllowDiskUse(obj.Get("allowDiskUse").Bool())
+		}
 	}
 	ops.Projection = projector
 	cur, err := collection.Find(context.Background(), selector, ops)
@@ -551,7 +554,7 @@ func (mg *MongoDAO) PushData(selector map[string]interface{}, data interface{})
 	return nil
 }
 
-//set update option for custom update
+// set update option for custom update
 func (mg *MongoDAO) SetUpdateOps(updateOps map[string]interface{}) {
 	mg.MetaData.UpdateOps = updateOps
 }