(t *testing.T)
| 263 | } |
| 264 | |
| 265 | func TestTruncateLogRestoreTableIDsBlocklistFiles(t *testing.T) { |
| 266 | ctx := context.Background() |
| 267 | base := t.TempDir() |
| 268 | stg, err := storage.NewLocalStorage(base) |
| 269 | require.NoError(t, err) |
| 270 | writeBlocklistFile(ctx, t, stg, 100, 10, 50, []int64{100, 101, 102}, []int64{103}) |
| 271 | writeBlocklistFile(ctx, t, stg, 200, 20, 60, []int64{200, 201, 202}, []int64{203}) |
| 272 | writeBlocklistFile(ctx, t, stg, 300, 30, 70, []int64{300, 301, 302}, []int64{303}) |
| 273 | |
| 274 | err = restore.TruncateLogRestoreTableIDsBlocklistFiles(ctx, stg, 50) |
| 275 | require.NoError(t, err) |
| 276 | require.Equal(t, 3, filesCount(ctx, stg)) |
| 277 | |
| 278 | err = restore.TruncateLogRestoreTableIDsBlocklistFiles(ctx, stg, 250) |
| 279 | require.NoError(t, err) |
| 280 | require.Equal(t, 1, filesCount(ctx, stg)) |
| 281 | |
| 282 | err = restore.TruncateLogRestoreTableIDsBlocklistFiles(ctx, stg, 350) |
| 283 | require.NoError(t, err) |
| 284 | require.Equal(t, 0, filesCount(ctx, stg)) |
| 285 | } |
| 286 | |
| 287 | type fakeMetaClient struct { |
| 288 | split.SplitClient |
nothing calls this directly
no test coverage detected