routing: start writing and reading from namespaced MC

and invoke the associated mission control migration.
This commit is contained in:
Elle Mouton committed 2024-10-01 13:50:50 +02:00
1 parent bfe4a08341
commit 6b449a6633
4 files changed
+53 -13

No files matched your search

+3 -3
View File
@@ -63,7 +63,7 @@ func newMCStoreTestHarness(t testing.TB, maxRecords int,
})
store, err := newMissionControlStore(
newNamespacedDB(db), maxRecords, flushInterval,
newDefaultNamespacedStore(db), maxRecords, flushInterval,
)
require.NoError(t, err)
@@ -118,7 +118,7 @@ func TestMissionControlStore(t *testing.T) {
// Recreate store to test pruning.
store, err = newMissionControlStore(
newNamespacedDB(db), testMaxRecords, time.Second,
newDefaultNamespacedStore(db), testMaxRecords, time.Second,
)
require.NoError(t, err)
@@ -218,7 +218,7 @@ func TestMissionControlStoreFlushing(t *testing.T) {
// Recreate store.
store, err := newMissionControlStore(
newNamespacedDB(db), testMaxRecords, flushInterval,
newDefaultNamespacedStore(db), testMaxRecords, flushInterval,
)
require.NoError(t, err)
store.run()