adjust tests to account for changelog changes

Author: erikdw

pkg/changelog/changelog_writer_test.go

@@ -32,5 +32,5 @@ func TestWriteChange(t *testing.T) {
 	})
 	require.NoError(t, err)
 	require.EqualValues(t, 1, len(mock.Lines))
-	require.Equal(t, `{"seq":42,"family":"family1","table":"table1","key":[18014398509481984,"foo"]}`, mock.Lines[0])
+	require.Equal(t, `{"seq":42,"ledgerSeq":0,"tx":false,"family":"family1","table":"table1","key":[18014398509481984,"foo"]}`, mock.Lines[0])
 }

pkg/event/changelog_test.go

@@ -135,7 +135,7 @@ func TestChangelog(t *testing.T) {
 			numEvents:        10000,
 			rotateAfterBytes: 1024 * 128,
 			writeDelay:       100 * time.Microsecond,
-			mustRotateN:      8,
+			mustRotateN:      9,
 		},
 	} {
 		t.Run(test.name, func(t *testing.T) {

pkg/reflector/reflector_test.go

@@ -208,7 +208,7 @@ func TestReflector(t *testing.T) {
 	clBytes, err := ioutil.ReadFile(changelogPath)
 	require.NoError(t, err)
 
-	expectChangelog := "{\"seq\":1,\"family\":\"family1\",\"table\":\"table1234\",\"key\":[{\"name\":\"field1\",\"type\":\"INTEGER\",\"value\":1234}]}\n"
+	expectChangelog := "{\"seq\":1,\"ledgerSeq\":2,\"tx\":false,\"family\":\"family1\",\"table\":\"table1234\",\"key\":[{\"name\":\"field1\",\"type\":\"INTEGER\",\"value\":1234}]}\n"
 	if diff := cmp.Diff(expectChangelog, string(clBytes)); diff != "" {
 		t.Errorf("Changelog contents differ\n%s", diff)
 	}