Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
cluster: major upgrade procedure (#51)
Current patch version upgrade procedure is ran when cluster is being upgraded to next patch version. New major upgrade procedure handles all others upgrades. Procedure: * Check if the cluster has schema agreement (using API call) * Take `system` and `system_schema` tables snapshot on all nodes in parallel. For each node: * Drain node * Backup the data - snapshot of all data keyspaces * Update Scylla image by restarting Pod * Validate if node is up and version is updated via API call * Clear data snapshot After last node: * Delete `system` and `system_schema` table snapshots on all nodes in parallel Fixes #51
- Loading branch information
Showing
17 changed files
with
1,714 additions
and
151 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,5 @@ | ||
| // Copyright (C) 2017 ScyllaDB | ||
|
|
||
| package actions | ||
|
|
||
| type CQLSession = cqlSession |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| // +build integration | ||
|
|
||
| // Copyright (C) 2017 ScyllaDB | ||
|
|
||
| package actions_test | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "os" | ||
| "testing" | ||
| "time" | ||
|
|
||
| "github.com/go-logr/zapr" | ||
| . "github.com/onsi/ginkgo" | ||
| . "github.com/onsi/gomega" | ||
| "github.com/pkg/errors" | ||
| "github.com/scylladb/go-log" | ||
| "github.com/scylladb/scylla-operator/pkg/cmd/options" | ||
| "github.com/scylladb/scylla-operator/pkg/controllers/cluster" | ||
| "github.com/scylladb/scylla-operator/pkg/test/integration" | ||
| "go.uber.org/zap" | ||
| "go.uber.org/zap/zapcore" | ||
| "k8s.io/klog" | ||
| ctrl "sigs.k8s.io/controller-runtime" | ||
| "sigs.k8s.io/controller-runtime/pkg/envtest/printer" | ||
| ) | ||
|
|
||
| var ( | ||
| testEnv *integration.TestEnvironment | ||
| ctx = context.Background() | ||
| ) | ||
|
|
||
| const ( | ||
| retryInterval = 200 * time.Millisecond | ||
| timeout = 30 * time.Second | ||
| ) | ||
|
|
||
| func TestMain(m *testing.M) { | ||
| ctx := log.WithNewTraceID(context.Background()) | ||
| atom := zap.NewAtomicLevelAt(zapcore.DebugLevel) | ||
| logger, _ := log.NewProduction(log.Config{ | ||
| Level: atom, | ||
| }) | ||
| zlogger, _ := zap.NewDevelopment() | ||
| ctrl.SetLogger(zapr.NewLogger(zlogger)) | ||
| klog.InitFlags(nil) | ||
| klog.SetOutput(os.Stdout) | ||
|
|
||
| logger.Info(ctx, "Creating test environment") | ||
| var err error | ||
| testEnv, err = integration.NewTestEnvironment(logger.Named("env"), | ||
| integration.WithPollRetryInterval(retryInterval), | ||
| integration.WithPollTimeout(timeout), | ||
| ) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| logger.Info(ctx, "Starting test manager") | ||
| go func() { | ||
| if err := testEnv.StartManager(ctx); err != nil { | ||
| panic(fmt.Sprintf("Failed to start the envtest manager: %v", err)) | ||
| } | ||
| }() | ||
|
|
||
| options.GetOperatorOptions().Image = "scylladb/scylla-operator" | ||
| defer func() { | ||
| options.GetOperatorOptions().Image = "" | ||
| }() | ||
|
|
||
| reconciler, err := cluster.New(ctx, testEnv.Manager, logger) | ||
| if err != nil { | ||
| panic(errors.Wrap(err, "create cluster reconciler")) | ||
| } | ||
| logger.Info(ctx, "Reconciler setup") | ||
| if err := reconciler.SetupWithManager(testEnv.Manager); err != nil { | ||
| panic(errors.Wrap(err, "setup cluster reconciler")) | ||
| } | ||
|
|
||
| logger.Info(ctx, "Starting tests") | ||
| // Run tests | ||
| code := m.Run() | ||
| logger.Info(ctx, "Tests done") | ||
| // Tearing down the test environment | ||
| if err := testEnv.Stop(); err != nil { | ||
| panic(fmt.Sprintf("Failed to stop the envtest: %v", err)) | ||
| } | ||
|
|
||
| os.Exit(code) | ||
| } | ||
|
|
||
| func TestAPIs(t *testing.T) { | ||
| RegisterFailHandler(Fail) | ||
|
|
||
| RunSpecsWithDefaultAndCustomReporters(t, | ||
| "Controller Suite", | ||
| []Reporter{printer.NewlineReporter{}}) | ||
| } |
Oops, something went wrong.