feat: influxd upgrade command

cmd/influxd/main.go

@@ -10,7 +10,6 @@ import (
 	"github.com/influxdata/influxdb/v2"
 	"github.com/influxdata/influxdb/v2/cmd/influxd/launcher"
 	"github.com/influxdata/influxdb/v2/cmd/influxd/upgrade"
-	_ "github.com/influxdata/influxdb/v2/query/builtin"
 	_ "github.com/influxdata/influxdb/v2/tsdb/engine/tsm1"
 	_ "github.com/influxdata/influxdb/v2/tsdb/index/tsi1"
 	"github.com/spf13/cobra"
@@ -33,7 +32,6 @@ func main() {
 		// FIXME
 		//generate.Command,
 		//restore.Command,
-		upgrade.Command,
 		&cobra.Command{
 			Use:   "version",
 			Short: "Print the influxd server version",
@@ -43,6 +41,9 @@ func main() {
 		},
 	)
 
+	// upgrade binds options to env variables, so it must be added after rootCmd is initialized
+	rootCmd.AddCommand(upgrade.NewCommand())
+
 	if err := rootCmd.Execute(); err != nil {
 		os.Exit(1)
 	}

cmd/influxd/upgrade/database.go

@@ -0,0 +1,17 @@
+package upgrade
+
+import (
+	"context"
+	"github.com/influxdata/influxdb/v2"
+	"github.com/influxdata/influxdb/v2/kit/errors"
+	"go.uber.org/zap"
+)
+
+func setupAdmin(ctx context.Context, v2 *influxDBv2) (*influxdb.OnboardingResults, error) {
+	return nil, errors.New("not implemented")
+}
+
+// upgradeDatabases creates databases, buckets, retention policies and shard info according to 1.x meta and copies data
+func upgradeDatabases(ctx context.Context, v1 *influxDBv1, v2 *influxDBv2, orgID influxdb.ID, log *zap.Logger) (map[string][]string, error) {
+	return nil, errors.New("not implemented")
+}

cmd/influxd/upgrade/generate_security_script.go

@@ -0,0 +1,11 @@
+package upgrade
+
+import (
+	"errors"
+	"go.uber.org/zap"
+)
+
+// Generates security upgrade script.
+func generateSecurityScript(v1 *influxDBv1, dbBuckets map[string][]string, log *zap.Logger) error {
+	return errors.New("not implemented")
+}