mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2025-12-21 11:59:41 -06:00
Code Issues Packages Projects Releases 114 Wiki Activity

Interface changes in tests

Browse Source
This commit is contained in:
Neil Macneale IV
2025-11-17 13:14:35 -08:00
parent 8692ab290b
commit ff1c70163c
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
go/store/nbs/journal_test.go
View File

@@ -40,7 +40,7 @@ func makeTestChunkJournal(t *testing.T) *ChunkJournal {
q := NewUnlimitedMemQuotaProvider()
p := newFSTablePersister(dir, q, false)
nbf := types.Format_Default.VersionString()
j, err := newChunkJournal(ctx, nbf, dir, m, p.(*fsTablePersister))
j, err := newChunkJournal(ctx, nbf, dir, m, p.(*fsTablePersister), nil)
require.NoError(t, err)
t.Cleanup(func() { j.Close() })
return j
@@ -52,7 +52,7 @@ func openTestChunkJournal(t *testing.T, dir string) *ChunkJournal {
q := NewUnlimitedMemQuotaProvider()
p := newFSTablePersister(dir, q, false)
nbf := types.Format_Default.VersionString()
j, err := newChunkJournal(t.Context(), nbf, dir, m, p.(*fsTablePersister))
j, err := newChunkJournal(t.Context(), nbf, dir, m, p.(*fsTablePersister), nil)
require.NoError(t, err)
t.Cleanup(func() { j.Close() })
return j
@@ -63,7 +63,7 @@ func TestChunkJournalBlockStoreSuite(t *testing.T) {
fn := func(ctx context.Context, dir string) (*NomsBlockStore, error) {
q := NewUnlimitedMemQuotaProvider()
nbf := types.Format_Default.VersionString()
return NewLocalJournalingStore(ctx, nbf, dir, q, false)
return NewLocalJournalingStore(ctx, nbf, dir, q, false, nil)
}
suite.Run(t, &BlockStoreSuite{
factory: fn,

8
go/store/nbs/journal_writer_test.go
View File

@@ -185,7 +185,7 @@ func newTestJournalWriter(t *testing.T, path string) *journalWriter {
j, err := createJournalWriter(ctx, path)
require.NoError(t, err)
require.NotNil(t, j)
_, err = j.bootstrapJournal(ctx, nil)
_, err = j.bootstrapJournal(ctx, nil, nil)
require.NoError(t, err)
return j
}
@@ -220,7 +220,7 @@ func TestJournalWriterBootstrap(t *testing.T) {
j, _, err := openJournalWriter(ctx, path)
require.NoError(t, err)
reflogBuffer := newReflogRingBuffer(10)
last, err = j.bootstrapJournal(ctx, reflogBuffer)
last, err = j.bootstrapJournal(ctx, reflogBuffer, nil)
require.NoError(t, err)
assertExpectedIterationOrder(t, reflogBuffer, []string{last.String()})
@@ -363,7 +363,7 @@ func TestJournalIndexBootstrap(t *testing.T) {
require.NoError(t, err)
require.True(t, ok)
// bootstrap journal and validate chunk records
last, err := journal.bootstrapJournal(ctx, nil)
last, err := journal.bootstrapJournal(ctx, nil, nil)
assert.NoError(t, err)
for _, e := range expected {
var act CompressedChunk
@@ -398,7 +398,7 @@ func TestJournalIndexBootstrap(t *testing.T) {
jnl, ok, err := openJournalWriter(ctx, idxPath)
require.NoError(t, err)
require.True(t, ok)
_, err = jnl.bootstrapJournal(ctx, nil)
_, err = jnl.bootstrapJournal(ctx, nil, nil)
assert.Error(t, err)
})
}