Adds dynamic type to _source field

CHANGELOG.md

@@ -23,6 +23,8 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 - Adds markdown linter ([#261](https://github.com/opensearch-project/opensearch-go/pull/261))
 - Adds testcases to check upsert functionality ([#207](https://github.com/opensearch-project/opensearch-go/issues/207))
 - Added @Jakob3xD to co-maintainers ([#270](https://github.com/opensearch-project/opensearch-go/pull/270))
+- Adds dynamic type to \_source field ([#158](https://github.com/opensearch-project/opensearch-go/issues/158))
+- Adds testcases for Document API ([#280](https://github.com/opensearch-project/opensearch-go/issues/280))
 
 ### Changed
 

opensearchapi/api.bulk.go

@@ -55,15 +55,15 @@ type Bulk func(body io.Reader, o ...func(*BulkRequest)) (*Response, error)
 // BulkRequest configures the Bulk API request.
 //
 type BulkRequest struct {
-	Index        string
+	Index string
 
 	Body io.Reader
 
 	Pipeline            string
 	Refresh             string
 	RequireAlias        *bool
 	Routing             string
-	Source              []string
+	Source              interface{}
 	SourceExcludes      []string
 	SourceIncludes      []string
 	Timeout             time.Duration
@@ -116,8 +116,12 @@ func (r BulkRequest) Do(ctx context.Context, transport Transport) (*Response, er
 		params["routing"] = r.Routing
 	}
 
-	if len(r.Source) > 0 {
-		params["_source"] = strings.Join(r.Source, ",")
+	if source, ok := r.Source.(bool); ok {
+		params["_source"] = strconv.FormatBool(source)
+	} else if source, ok := r.Source.(string); ok && source != "" {
+		params["_source"] = source
+	} else if sources, ok := r.Source.([]string); ok && len(sources) > 0 {
+		params["_source"] = strings.Join(sources, ",")
 	}
 
 	if len(r.SourceExcludes) > 0 {
@@ -249,7 +253,7 @@ func (f Bulk) WithRouting(v string) func(*BulkRequest) {
 
 // WithSource - true or false to return the _source field or not, or default list of fields to return, can be overridden on each sub-request.
 //
-func (f Bulk) WithSource(v ...string) func(*BulkRequest) {
+func (f Bulk) WithSource(v interface{}) func(*BulkRequest) {
 	return func(r *BulkRequest) {
 		r.Source = v
 	}

opensearchapi/api.delete_by_query.go

@@ -56,7 +56,7 @@ type DeleteByQuery func(index []string, body io.Reader, o ...func(*DeleteByQuery
 // DeleteByQueryRequest configures the Delete By Query API request.
 //
 type DeleteByQueryRequest struct {
-	Index        []string
+	Index []string
 
 	Body io.Reader
 
@@ -84,7 +84,7 @@ type DeleteByQueryRequest struct {
 	Size                *int
 	Slices              interface{}
 	Sort                []string
-	Source              []string
+	Source              interface{}
 	SourceExcludes      []string
 	SourceIncludes      []string
 	Stats               []string
@@ -219,8 +219,12 @@ func (r DeleteByQueryRequest) Do(ctx context.Context, transport Transport) (*Res
 		params["sort"] = strings.Join(r.Sort, ",")
 	}
 
-	if len(r.Source) > 0 {
-		params["_source"] = strings.Join(r.Source, ",")
+	if source, ok := r.Source.(bool); ok {
+		params["_source"] = strconv.FormatBool(source)
+	} else if source, ok := r.Source.(string); ok && source != "" {
+		params["_source"] = source
+	} else if sources, ok := r.Source.([]string); ok && len(sources) > 0 {
+		params["_source"] = strings.Join(sources, ",")
 	}
 
 	if len(r.SourceExcludes) > 0 {
@@ -520,7 +524,7 @@ func (f DeleteByQuery) WithSort(v ...string) func(*DeleteByQueryRequest) {
 
 // WithSource - true or false to return the _source field or not, or a list of fields to return.
 //
-func (f DeleteByQuery) WithSource(v ...string) func(*DeleteByQueryRequest) {
+func (f DeleteByQuery) WithSource(v interface{}) func(*DeleteByQueryRequest) {
 	return func(r *DeleteByQueryRequest) {
 		r.Source = v
 	}