From 2e268539e4d99a7b1e017260882a283b1d1e4019 Mon Sep 17 00:00:00 2001 From: utsavoza Date: Sun, 9 Sep 2018 18:00:46 +0530 Subject: [PATCH] Add flag to support ssl connections --- cmd/abc/appbase_import.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/cmd/abc/appbase_import.go b/cmd/abc/appbase_import.go index 595e0ba..3aa4de2 100644 --- a/cmd/abc/appbase_import.go +++ b/cmd/abc/appbase_import.go @@ -54,6 +54,7 @@ func runImport(args []string) error { test := flagset.Bool("test", false, `if set to true, only pipeline is created and sync is not started. Useful for checking your configuration`) sacPath := flagset.String("sac_path", "./ServiceAccountKey.json", "Path to firebase service account credentials file") + ssl := flagset.Bool("ssl", false, "Enable SSL connection to the source.") requestSize := flagset.Int64("request_size", 2<<19, "Http request size in bytes, specifically for bulk requests to ES.") bulkRequests := flagset.Int("bulk_requests", 1000, "Number of bulk requests to send during a network request to ES.") @@ -93,16 +94,16 @@ func runImport(args []string) error { "tail": *tail, "typeName": *typeName, "replication_slot": *replicationSlot, - // "timeout": *timeout, - "srcRegex": *srcRegex, - "sacPath": *sacPath, - "_transform_": *transformFile, + "srcRegex": *srcRegex, + "sacPath": *sacPath, + "ssl": *ssl, + "_transform_": *transformFile, } var destConfig = map[string]interface{}{ - "uri": destURL, - "_name_": "elasticsearch", - "request_size": *requestSize, + "uri": destURL, + "_name_": "elasticsearch", + "request_size": *requestSize, "bulk_requests": *bulkRequests, } -- GitLab