precheck skip

cmd/eskeeper/main.go

@@ -12,11 +12,6 @@ import (
 	"golang.org/x/crypto/ssh/terminal"
 )
 
-const (
-	TERMINAL = "terminal"
-	PIPE     = "pipe"
-)
-
 var rootCmd = &cobra.Command{
 	Use:   "eskeeper",
 	Short: "eskeeper synchronizes index and alias with configuration files while ensuring idempotency.",
@@ -26,6 +21,7 @@ var rootCmd = &cobra.Command{
 			eskeeper.UserName(viper.GetString("es_user")),
 			eskeeper.Pass(viper.GetString("es_pass")),
 			eskeeper.Verbose(viper.GetBool("verbose")),
+			eskeeper.Verbose(viper.GetBool("skip_precheck")),
 		)
 		if err != nil {
 			fmt.Println(err)
@@ -83,6 +79,7 @@ func init() {
 	pflag.StringP("es_pass", "p", "", "Elasticsearch password")
 	pflag.StringSliceP("es_urls", "e", []string{"http://localhost:9200"}, "Elasticserch endpoint URLs (comma delimited)")
 	pflag.BoolP("verbose", "v", false, "Make the operation more talkative")
+	pflag.BoolP("skip_precheck", "s", false, "Skip pre-check stage")
 
 	viper.BindPFlags(pflag.CommandLine)
 }

eskeeper.go

@@ -11,9 +11,10 @@ type Eskeeper struct {
 	client *esclient
 
 	// options
-	user    string
-	pass    string
-	verbose bool
+	user         string
+	pass         string
+	verbose      bool
+	skipPreCheck bool
 }
 
 // NewOption is optional func for eskeeper.New
@@ -40,6 +41,13 @@ func Verbose(v bool) NewOption {
 	}
 }
 
+// SkipPreCheck is optional func for skipping pre-check-stage..
+func SkipPreCheck(v bool) NewOption {
+	return func(e *Eskeeper) {
+		e.skipPreCheck = v
+	}
+}
+
 // New inits Eskeeper.
 func New(urls []string, opts ...NewOption) (*Eskeeper, error) {
 	eskeeper := &Eskeeper{}
@@ -73,10 +81,12 @@ func (e *Eskeeper) Sync(ctx context.Context, reader io.Reader) error {
 		return err
 	}
 
-	e.log("\n=== pre-check stage ===")
-	err = e.client.preCheck(ctx, conf)
-	if err != nil {
-		return err
+	if !e.skipPreCheck {
+		e.log("\n=== pre-check stage ===")
+		err = e.client.preCheck(ctx, conf)
+		if err != nil {
+			return err
+		}
 	}
 
 	e.log("\n=== sync stage ===")