From 18d7745261e2e380786f3bee4c54cdbf666e33d6 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Thu, 3 Sep 2020 10:02:48 +0800 Subject: [PATCH] Update storage interface Signed-off-by: cai.zhang --- proxy/proxy_test/generate_entity_id.go | 1 + storage/pkg/storage.go | 15 +++++++-------- 2 files changed, 8 insertions(+), 8 deletions(-) create mode 100644 proxy/proxy_test/generate_entity_id.go diff --git a/proxy/proxy_test/generate_entity_id.go b/proxy/proxy_test/generate_entity_id.go new file mode 100644 index 0000000000..7ecefa5be6 --- /dev/null +++ b/proxy/proxy_test/generate_entity_id.go @@ -0,0 +1 @@ +package proxy_test diff --git a/storage/pkg/storage.go b/storage/pkg/storage.go index b6e4ffa042..14c87ba870 100644 --- a/storage/pkg/storage.go +++ b/storage/pkg/storage.go @@ -3,24 +3,23 @@ package storage import ( "context" "errors" - minIODriver "storage/internal/minio" - tikvDriver "storage/internal/tikv" - "storage/pkg/types" + minIODriver "github.com/czs007/suvlim/storage/internal/minio" + tikvDriver "github.com/czs007/suvlim/storage/internal/tikv" + "github.com/czs007/suvlim/storage/pkg/types" ) func NewStore(ctx context.Context, driver types.DriverType) (types.Store, error) { var err error var store types.Store - driverType := types.DriverType(driver) - switch driverType{ - case types.MinIODriver: + switch driver{ + case types.TIKVDriver: store, err = tikvDriver.NewTikvStore(ctx) if err != nil { panic(err.Error()) } return store, nil - case types.TIKVDriver: - store, err = minIODriver.NewMinIOStore(ctx) + case types.MinIODriver: + store, err = minIODriver.NewMinioDriver(ctx) if err != nil { //panic(err.Error()) return nil, err