server: add fields to migrate from 3.5 to 3.4

Signed-off-by: Bogdan Kanivets <[email protected]>

etcdutl/etcdutl/migrate_command.go

@@ -87,8 +87,8 @@ func (o *migrateOptions) Config() (*migrateConfig, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to parse target version: %v", err)
 	}
-	if c.targetVersion.LessThan(version.V3_5) {
-		return nil, fmt.Errorf(`target version %q not supported. Minimal "3.5"`, storageVersionToString(c.targetVersion))
+	if c.targetVersion.LessThan(version.V3_4) {
+		return nil, fmt.Errorf(`target version %q not supported. Minimal "3.4"`, storageVersionToString(c.targetVersion))
 	}
 
 	dbPath := datadir.ToBackendFileName(o.dataDir)

server/storage/schema/schema.go

@@ -131,8 +131,19 @@ var (
 		version.V3_6: {
 			addNewField(Meta, MetaStorageVersionName, emptyStorageVersion),
 		},
+		version.V3_5: {
+			// 'migrate' command from v3.4 to v3.5 isn't supported and will fail with `missing confstate information`
+			// these fields are added for v3.5 -> v3.4 downgrade only
+			//
+			// note about emptyValue:
+			// even if these fields are used for upgrade, it's safe to set emptyValue
+			// UnsafeReadConsistentIndex and UnsafeConfStateFromBackend checks for zero-length values
+			addNewField(Meta, MetaTermKeyName, emptyValue),
+			addNewField(Meta, MetaConfStateName, emptyValue),
+		},
 	}
 	// emptyStorageVersion is used for v3.6 Step for the first time, in all other version StoragetVersion should be set by migrator.
 	// Adding a addNewField for StorageVersion we can reuse logic to remove it when downgrading to v3.5
 	emptyStorageVersion = []byte("")
+	emptyValue          = []byte("")
 )

tests/e2e/utl_migrate_test.go

@@ -34,6 +34,11 @@ import (
 	"go.etcd.io/etcd/tests/v3/framework/e2e"
 )
 
+type bucketKey struct {
+	bucket backend.Bucket
+	key    []byte
+}
+
 func TestEtctlutlMigrate(t *testing.T) {
 	lastReleaseBinary := e2e.BinPath.EtcdLastRelease
 
@@ -45,6 +50,8 @@ func TestEtctlutlMigrate(t *testing.T) {
 
 		expectLogsSubString  string
 		expectStorageVersion *semver.Version
+
+		expectNonFoundKeys []bucketKey
 	}{
 		{
 			name:                 "Invalid target version string",
@@ -70,6 +77,16 @@ func TestEtctlutlMigrate(t *testing.T) {
 			expectLogsSubString:  `Error: wrong target version format, expected "X.Y", got "3.6.0"`,
 			expectStorageVersion: &version.V3_6,
 		},
+		{
+			name:                "Downgrade v3.5 to v3.4 should work",
+			clusterVersion:      e2e.LastVersion,
+			targetVersion:       "3.4",
+			expectLogsSubString: "updated storage version\t" + `{"new-storage-version": "3.4.0"}`,
+			expectNonFoundKeys: []bucketKey{
+				{bucket: schema.Meta, key: schema.MetaTermKeyName},
+				{bucket: schema.Meta, key: schema.MetaConfStateName},
+			},
+		},
 		{
 			name:                "Migrate v3.5 to v3.5 is no-op",
 			clusterVersion:      e2e.LastVersion,
@@ -170,6 +187,12 @@ func TestEtctlutlMigrate(t *testing.T) {
 
 			ver := schema.ReadStorageVersion(be.ReadTx())
 			assert.Equal(t, tc.expectStorageVersion, ver)
+
+			for _, bk := range tc.expectNonFoundKeys {
+				_, vs := be.ReadTx().UnsafeRange(bk.bucket, bk.key, nil, 0)
+				assert.Zero(t, len(vs))
+			}
+
 		})
 	}
 }