Merge pull request #21 from suxiaobai/master

fix build and migrate doc to add '_routing'

.travis.yml

@@ -1,6 +1,10 @@
 language: go
 os:
   - osx
+
+env:
+  global:
+    - TRAVIS_GO_VERSION="1.10"
 go:
   - 1.10
 

README.md

@@ -79,11 +79,10 @@ https://github.com/medcl/elasticsearch-dump/releases
 
 
 ## Compile:
-
 if download version is not fill you environment,you may try to compile it yourself. `go` required.
 
 `make build`
-
+* go version >= 1.7
 
 ## Options
 

bulk.go

@@ -70,6 +70,11 @@ func (c *Migrator) NewBulkWorker(docCount *int, pb *pb.ProgressBar, wg *sync.Wai
 				source: docI["_source"].(map[string]interface{}),
 				Id:     docI["_id"].(string),
 			}
+
+			// add doc "_routing"
+			if _, ok := docI["_routing"]; ok {
+				doc.Routing = docI["_routing"].(string)
+			}
 
 		// if channel is closed flush and gtfo
 			if !open {

domain.go

@@ -25,6 +25,7 @@ type Document struct {
 	Type   string                 `json:"_type"`
 	Id     string                 `json:"_id"`
 	source map[string]interface{} `json:"_source"`
+	Routing string 				  `json:"_routing"`
 }
 
 type Scroll struct {
@@ -88,10 +89,10 @@ type Config struct {
 	BulkSizeInMB      int    `short:"b" long:"bulk_size" description:"bulk size in MB" default:"5"`
 	ScrollTime        string `short:"t" long:"time"    description:"scroll time" default:"1m"`
 	ScrollSliceSize   int    `long:"sliced_scroll_size"    description:"size of sliced scroll, to make it work, the size should be > 1" default:"1"`
-	RecreateIndex     bool      `short:"f" long:"force"   description:"delete destination index before copying" default:"false"`
+	RecreateIndex     bool      `short:"f" long:"force"   description:"delete destination index before copying"`
 	CopyAllIndexes    bool   `short:"a" long:"all"     description:"copy indexes starting with . and _"`
-	CopyIndexSettings bool   `long:"copy_settings"          description:"copy index settings from source" default:"false"`
-	CopyIndexMappings bool   `long:"copy_mappings"          description:"copy index mappings from source" default:"false"`
+	CopyIndexSettings bool   `long:"copy_settings"          description:"copy index settings from source"`
+	CopyIndexMappings bool   `long:"copy_mappings"          description:"copy index mappings from source"`
 	ShardsCount       int    `long:"shards"            description:"set a number of shards on newly created indexes"`
 	SourceIndexNames  string `short:"x" long:"src_indexes" description:"indexes name to copy,support regex and comma separated list" default:"_all"`
 	TargetIndexName   string `short:"y" long:"dest_index" description:"indexes name to save, allow only one indexname, original indexname will be used if not specified" default:""`

http.go

@@ -33,7 +33,7 @@ func Get(url string,auth *Auth,proxy string) (*http.Response, string, []error) {
 		request.SetBasicAuth(auth.User,auth.Pass)
 	}
 
-	request.Header["Content-Type"]= "application/json"
+	request.Header.Set("Content-Type", "application/json")
 
 	if(len(proxy)>0){
 		request.Proxy(proxy)
@@ -50,7 +50,7 @@ func Post(url string,auth *Auth, body string,proxy string)(*http.Response, strin
 		request.SetBasicAuth(auth.User,auth.Pass)
 	}
 
-	request.Header["Content-Type"]= "application/json"
+	request.Header.Set("Content-Type", "application/json")
 
 	if(len(proxy)>0){
 		request.Proxy(proxy)

main.go

@@ -29,6 +29,8 @@ func main() {
 	_, err := goflags.Parse(c)
 	if err != nil {
 		log.Error(err)
+		// if error, print it
+		fmt.Print(err)
 		return
 	}