Function TestVerifyHashKVAfterCompact

tests/e2e/hashkv_test.go:32–101

(t *testing.T)

)

func TestVerifyHashKVAfterCompact(t *testing.T) {
	scenarios := []struct {
		clusterVersion e2e.ClusterVersion
		keys           []string // used for data generators
	}{
		{
			clusterVersion: e2e.CurrentVersion,
			keys:           []string{"key0"},
		},
		{
			clusterVersion: e2e.CurrentVersion,
			keys:           []string{"key0", "key1"},
		},
		{
			clusterVersion: e2e.QuorumLastVersion,
			keys:           []string{"key0"},
		},
		{
			clusterVersion: e2e.QuorumLastVersion,
			keys:           []string{"key0", "key1"},
		},
	}

	for _, compactedOnTombstoneRev := range []bool{false, true} {
		for _, scenario := range scenarios {
			t.Run(fmt.Sprintf("compactedOnTombstone=%v - %s - Keys=%v", compactedOnTombstoneRev, scenario.clusterVersion, scenario.keys), func(t *testing.T) {
				e2e.BeforeTest(t)

				if scenario.clusterVersion != e2e.CurrentVersion {
					if !fileutil.Exist(e2e.BinPath.EtcdLastRelease) {
						t.Skipf("%q does not exist", e2e.BinPath.EtcdLastRelease)
					}
				}

				ctx := context.Background()

				cfg := e2e.NewConfigClientTLS()
				clus, err := e2e.NewEtcdProcessCluster(ctx, t,
					e2e.WithConfig(cfg),
					e2e.WithClusterSize(3),
					e2e.WithVersion(scenario.clusterVersion))
				require.NoError(t, err)

				t.Cleanup(func() { clus.Close() })

				tombstoneRevs, lastestRev := populateDataForHashKV(t, clus, cfg.Client, scenario.keys)

				compactedOnRev := tombstoneRevs[0]

				// If compaction revision isn't a tombstone, select a revision in the middle of two tombstones.
				if !compactedOnTombstoneRev {
					compactedOnRev = (tombstoneRevs[0] + tombstoneRevs[1]) / 2
					require.Greater(t, compactedOnRev, tombstoneRevs[0])
					require.Greater(t, tombstoneRevs[1], compactedOnRev)
				}

				cli, err := e2e.NewEtcdctl(cfg.Client, clus.EndpointsGRPC())
				require.NoError(t, err)