mirror of https://github.com/milvus-io/milvus.git
Add s3 sriver type in storage
Signed-off-by: shengjh <1572099106@qq.com>pull/4973/head^2
parent
649732c1b0
commit
aa2ff7a971
storage/pkg
types
|
@ -5,6 +5,7 @@ import (
|
||||||
"errors"
|
"errors"
|
||||||
minIODriver "github.com/czs007/suvlim/storage/internal/minio"
|
minIODriver "github.com/czs007/suvlim/storage/internal/minio"
|
||||||
tikvDriver "github.com/czs007/suvlim/storage/internal/tikv"
|
tikvDriver "github.com/czs007/suvlim/storage/internal/tikv"
|
||||||
|
S3Driver "github.com/czs007/suvlim/storage/internal/S3"
|
||||||
"github.com/czs007/suvlim/storage/pkg/types"
|
"github.com/czs007/suvlim/storage/pkg/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -25,6 +26,8 @@ func NewStore(ctx context.Context, driver types.DriverType) (types.Store, error)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return store, nil
|
return store, nil
|
||||||
|
case types.S3DRIVER:
|
||||||
|
store , err = S3Driver.NewS3Driver(ctx)
|
||||||
}
|
}
|
||||||
return nil, errors.New("unsupported driver")
|
return nil, errors.New("unsupported driver")
|
||||||
}
|
}
|
|
@ -14,6 +14,7 @@ type SegmentDL = []byte
|
||||||
const (
|
const (
|
||||||
MinIODriver DriverType = "MinIO"
|
MinIODriver DriverType = "MinIO"
|
||||||
TIKVDriver DriverType = "TIKV"
|
TIKVDriver DriverType = "TIKV"
|
||||||
|
S3DRIVER DriverType = "S3"
|
||||||
)
|
)
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|
Loading…
Reference in New Issue