func (s *ReindexService) WaitForActiveShards(waitForActiveShards string) *ReindexService {
	s.waitForActiveShards = waitForActiveShards
	return s
}
WaitForActiveShards sets the number of shard copies that must be active before
proceeding with the reindex operation. Defaults to 1, meaning the primary shard only.
Set to `all` for all shard copies, otherwise set to any non-negative value less than or
equal to the total number of copies for the shard (number of replicas + 1).
package elastic
import (
	"context"
	"fmt"
	"net/url"
)
type ReindexService struct {
	client              *Client
	pretty              bool
	refresh             string
	timeout             string
	waitForActiveShards string
	waitForCompletion   *bool
	requestsPerSecond   *int
	body                interface{}
	source              *ReindexSource
	destination         *ReindexDestination
	conflicts           string
	size                *int
	script              *Script
}
func NewReindexService(client *Client) *ReindexService {
	return &ReindexService{
		client: client,
	}
}