-
Notifications
You must be signed in to change notification settings - Fork 349
/
command_repository_validate_provider.go
35 lines (26 loc) · 1.19 KB
/
command_repository_validate_provider.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
package cli
import (
"context"
"github.com/pkg/errors"
"github.com/kopia/kopia/internal/providervalidation"
"github.com/kopia/kopia/repo"
)
type commandRepositoryValidateProvider struct {
opt providervalidation.Options
out textOutput
}
func (c *commandRepositoryValidateProvider) setup(svc advancedAppServices, parent commandParent) {
cmd := parent.Command("validate-provider", "Validates that a repository provider is compatible with Kopia")
c.opt = providervalidation.DefaultOptions
cmd.Flag("concurrency-test-duration", "Duration of concurrency test").DurationVar(&c.opt.ConcurrencyTestDuration)
cmd.Flag("put-blob-workers", "Number of PutBlob workers").IntVar(&c.opt.NumPutBlobWorkers)
cmd.Flag("get-blob-workers", "Number of GetBlob workers").IntVar(&c.opt.NumGetBlobWorkers)
cmd.Flag("get-metadata-workers", "Number of GetMetadata workers").IntVar(&c.opt.NumGetMetadataWorkers)
c.out.setup(svc)
cmd.Action(c.out.svc.directRepositoryWriteAction(c.run))
}
func (c *commandRepositoryValidateProvider) run(ctx context.Context, dr repo.DirectRepositoryWriter) error {
return errors.Wrap(
providervalidation.ValidateProvider(ctx, dr.BlobStorage(), c.opt),
"provider validation error")
}