search: Guarantee search-after-write consistency (#109972)
This commit is contained in:
@@ -217,7 +217,7 @@ func runSearchBackendBenchmarkWriteThroughput(ctx context.Context, backend resou
|
||||
size := int64(10000) // force the index to be on disk
|
||||
index, err := backend.BuildIndex(ctx, nr, size, 0, nil, "benchmark", func(index resource.ResourceIndex) (int64, error) {
|
||||
return 0, nil
|
||||
})
|
||||
}, nil)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("failed to initialize backend: %w", err)
|
||||
}
|
||||
|
||||
@@ -86,7 +86,7 @@ func runTestSearchBackendBuildIndex(t *testing.T, backend resource.SearchBackend
|
||||
return 0, err
|
||||
}
|
||||
return 1, nil
|
||||
})
|
||||
}, nil)
|
||||
require.NoError(t, err)
|
||||
require.NotNil(t, index)
|
||||
|
||||
@@ -152,7 +152,7 @@ func runTestResourceIndex(t *testing.T, backend resource.SearchBackend, nsPrefix
|
||||
})
|
||||
require.NoError(t, err)
|
||||
return int64(2), nil
|
||||
})
|
||||
}, nil)
|
||||
require.NoError(t, err)
|
||||
require.NotNil(t, index)
|
||||
|
||||
@@ -294,7 +294,7 @@ func runTestResourceIndex(t *testing.T, backend resource.SearchBackend, nsPrefix
|
||||
})
|
||||
require.NoError(t, err)
|
||||
return int64(3), nil
|
||||
})
|
||||
}, nil)
|
||||
require.NoError(t, err)
|
||||
require.NotNil(t, index)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user