( ctx context.Context, t *testing.T, s storage.ExternalStorage, restoreCommitTs, restoreStartTs, rewriteTs uint64, tableIds, dbIds []int64, )
| 185 | } |
| 186 | |
| 187 | func writeBlocklistFile( |
| 188 | ctx context.Context, t *testing.T, s storage.ExternalStorage, |
| 189 | restoreCommitTs, restoreStartTs, rewriteTs uint64, tableIds, dbIds []int64, |
| 190 | ) { |
| 191 | name, data, err := restore.MarshalLogRestoreTableIDsBlocklistFile(restoreCommitTs, restoreStartTs, rewriteTs, tableIds, dbIds) |
| 192 | require.NoError(t, err) |
| 193 | err = s.WriteFile(ctx, name, data) |
| 194 | require.NoError(t, err) |
| 195 | } |
| 196 | |
| 197 | func fakeTrackerID(tableIds []int64) *utils.PiTRIdTracker { |
| 198 | tracker := utils.NewPiTRIdTracker() |
no test coverage detected