提交 71bb4337 编写于 作者: U utsavoza

Add tail flag in destConfig

上级 2df11ae3
...@@ -5,16 +5,17 @@ package main ...@@ -5,16 +5,17 @@ package main
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"github.com/appbaseio/abc/appbase/app"
"github.com/appbaseio/abc/appbase/common"
"github.com/appbaseio/abc/imports/adaptor"
"github.com/appbaseio/abc/log"
"github.com/joho/godotenv"
"io/ioutil" "io/ioutil"
"os" "os"
"strconv" "strconv"
"strings" "strings"
"time" "time"
"github.com/appbaseio/abc/appbase/app"
"github.com/appbaseio/abc/appbase/common"
"github.com/appbaseio/abc/imports/adaptor"
"github.com/appbaseio/abc/log"
"github.com/joho/godotenv"
) )
// GLOBALS // GLOBALS
...@@ -100,10 +101,11 @@ func runImport(args []string) error { ...@@ -100,10 +101,11 @@ func runImport(args []string) error {
} }
var destConfig = map[string]interface{}{ var destConfig = map[string]interface{}{
"uri": destURL, "uri": destURL,
"_name_": "elasticsearch", "_name_": "elasticsearch",
"request_size": *requestSize, "request_size": *requestSize,
"bulk_requests": *bulkRequests, "bulk_requests": *bulkRequests,
"tail": *tail,
} }
// write config file // write config file
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册