Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions pkg/kv/msg_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (
"github.com/ory/dockertest/v3"
"github.com/stretchr/testify/require"
"github.com/treeverse/lakefs/pkg/kv"
_ "github.com/treeverse/lakefs/pkg/kv/dynamodb"
"github.com/treeverse/lakefs/pkg/kv/kvparams"
"github.com/treeverse/lakefs/pkg/kv/kvtest"
_ "github.com/treeverse/lakefs/pkg/kv/mem"
Expand Down
9 changes: 0 additions & 9 deletions pkg/kv/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -167,15 +167,6 @@ func Register(name string, driver Driver) {
drivers[name] = driver
}

// UnregisterAllDrivers remove all loaded drivers, used for test code.
func UnregisterAllDrivers() {
driversMu.Lock()
defer driversMu.Unlock()
for k := range drivers {
delete(drivers, k)
}
}

// Open lookup driver by 'type' and return store based on the configuration.
// Failed with ErrUnknownDriver in case 'name' is not registered
func Open(ctx context.Context, params kvparams.Config) (Store, error) {
Expand Down
6 changes: 5 additions & 1 deletion pkg/kv/store_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ package kv_test
import (
"context"
"errors"
"slices"
"sort"
"testing"

Expand Down Expand Up @@ -108,10 +109,13 @@ func TestRegister(t *testing.T) {
}

func TestDrivers(t *testing.T) {
kv.UnregisterAllDrivers()
preloadedDrivers := kv.Drivers()
kv.Register("driver1", &MockDriver{Name: "driver1"})
kv.Register("driver2", &MockDriver{Name: "driver2"})
all := kv.Drivers()
all = slices.DeleteFunc(all, func(name string) bool {
return slices.Contains(preloadedDrivers, name)
})
sort.Strings(all)
expectedDrivers := []string{"driver1", "driver2"}
if diff := deep.Equal(all, expectedDrivers); diff != nil {
Expand Down
5 changes: 4 additions & 1 deletion pkg/testutil/dynamodb.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,9 +93,12 @@ func GetDynamoDBProd(ctx context.Context, tb testing.TB) kv.Store {
}
tb.Cleanup(func() {
defer store.Close()
if wrappedStore, ok := store.(*kv.StoreMetricsWrapper); ok {
store = wrappedStore.Store
}
err = store.(*dynamodb.Store).DropTable()
if err != nil {
tb.Fatalf("failed to delete table from DB %v %s", table, err)
tb.Fatalf("failed to delete table from DB %v %s", testParams.TableName, err)
}
})
return store
Expand Down
Loading