Skip to content

Commit f25da56

Browse files
Merge pull request #111 from appbaseio/ugo/dest-tail-conf/13-09-2018
Update flags read from config file
2 parents 8922e8f + c9b94fe commit f25da56

28 files changed

+7887
-7876
lines changed

cmd/abc/appbase_import.go

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,13 +28,17 @@ var srcParamMap = map[string]string{
2828
"replication_slot": "replication_slot",
2929
"typename": "typeName",
3030
"src_filter": "srcRegex",
31+
"sac_path": "sacPath",
3132
// "timeout": "timeout",
3233
"transform_file": "_transform_",
3334
}
3435

3536
var destParamMap = map[string]string{
36-
"dest_uri": "uri",
37-
"dest_type": "_name_",
37+
"dest_uri": "uri",
38+
"dest_type": "_name_",
39+
"tail": "tail",
40+
"request_size": "request_size",
41+
"bulk_requests": "bulk_requests",
3842
}
3943

4044
const basicUsage string = `abc import --src.type {DBType} --src.uri {URI} [-t|--tail] [Uri|Appname]`
@@ -267,6 +271,13 @@ func genPipelineFromEnv(filename string) (string, error) {
267271
for k, v := range destParamMap {
268272
if val, ok := config[k]; ok {
269273
dest[v] = val
274+
if k == "tail" {
275+
if val == "true" {
276+
dest[v] = true
277+
} else {
278+
dest[v] = false
279+
}
280+
}
270281
}
271282
}
272283
// generate file

vendor/github.com/davecgh/go-spew/LICENSE

Lines changed: 15 additions & 15 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

vendor/github.com/davecgh/go-spew/spew/bypass.go

Lines changed: 152 additions & 152 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)