mirror/kopia
1
0
Fork 0
mirror of https://github.com/kopia/kopia.git synced 2026-03-13 11:46:55 -04:00
Code Issues Packages Projects Releases Wiki Activity

blob: check that GCS/S3 bucket is present when the storage is opened

Browse Source
This commit is contained in:
Jarek Kowalski
2020-02-15 12:38:24 -08:00
parent a9670762fd
commit 0163a2da97
2 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
repo/blob/gcs/gcs_storage.go
View File

@@ -267,6 +267,11 @@ func New(ctx context.Context, opt *Options) (blob.Storage, error) {
return nil, errors.New("bucket name must be specified")
}
// make sure the bucket exists
if _, err := cli.Bucket(opt.BucketName).Attrs(ctx); err != nil {
return nil, errors.Wrap(err, "unable to read bucket")
}
return &gcsStorage{
Options: *opt,
ctx: ctx,

9
repo/blob/s3/s3_storage.go
View File

@@ -233,6 +233,15 @@ func New(ctx context.Context, opt *Options) (blob.Storage, error) {
downloadThrottler := iothrottler.NewIOThrottlerPool(toBandwidth(opt.MaxDownloadSpeedBytesPerSecond))
uploadThrottler := iothrottler.NewIOThrottlerPool(toBandwidth(opt.MaxUploadSpeedBytesPerSecond))
ok, err := cli.BucketExistsWithContext(ctx, opt.BucketName)
if err != nil {
return nil, errors.Wrapf(err, "unable to determine if bucket %q exists", opt.BucketName)
}
if !ok {
return nil, errors.Errorf("bucket %q does not exist", opt.BucketName)
}
return &s3Storage{
Options: *opt,
ctx: ctx,