forked from kopia/kopia
/
command_repository_validate_provider.go
36 lines (27 loc) · 1.31 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
36
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)
cmd.Flag("support-idempotent-creates", "Whether store supports idempotent blob creates").BoolVar(&c.opt.SupportIdempotentCreates)
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")
}