Skip to content

Commit

Permalink
feat(upgrade): upgrade command basic skeleton
Browse files Browse the repository at this point in the history
  • Loading branch information
vlastahajek committed Sep 24, 2020
1 parent 1a6865a commit a30b148
Show file tree
Hide file tree
Showing 5 changed files with 351 additions and 30 deletions.
5 changes: 3 additions & 2 deletions cmd/influxd/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand All @@ -33,7 +32,6 @@ func main() {
// FIXME
//generate.Command,
//restore.Command,
upgrade.Command,
&cobra.Command{
Use: "version",
Short: "Print the influxd server version",
Expand All @@ -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)
}
Expand Down
17 changes: 17 additions & 0 deletions cmd/influxd/upgrade/database.go
Original file line number Diff line number Diff line change
@@ -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")
}
11 changes: 11 additions & 0 deletions cmd/influxd/upgrade/generate_security_script.go
Original file line number Diff line number Diff line change
@@ -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")
}
Loading

0 comments on commit a30b148

Please sign in to comment.