sync

Documentation

Index

• Variables
• type InstanceItem
• type SyncClient
  • func NewS3Client(c *client.Client, instanceName string, region string) (SyncClient, error)

Variables

var Cmd = &cobra.Command{
	Use:   "sync",
	Short: "Sync images between IBM COS buckets",
	Long: `Sync images between IBM COS buckets
pvsadm image sync --help for information

# Set the API key or feed the --api-key commandline argument
export IBMCLOUD_API_KEY=<IBM_CLOUD_API_KEY>

Examples:

# using spec yaml file
pvsadm image sync --spec-file spec.yaml

Sample spec.yaml file:
---
- source:
    bucket: bucket-fqsdgh
    cos: cos-test-buphij
    object: ".txt"
    storageClass: smart
    region: jp-tok
  target:
  - bucket: bucket-ielfqq
    storageClass: smart
    region: jp-tok
  - bucket: bucket-kkoyrg
    storageClass: smart
    region: jp-tok
- source:
    bucket: bucket-embocx
    cos: cos-test-icrbul
    object: ""
    storageClass: smart
    region: us-east
  target:
  - bucket: bucket-xgskog
    storageClass: standard
    region: jp-tok
  - bucket: bucket-nomoer
    storageClass: cold
    region: jp-tok

`,
	RunE: func(cmd *cobra.Command, args []string) error {

		var apikey string = pkg.Options.APIKey
		opt := pkg.ImageCMDOptions
		start := time.Now()

		bxCli, err := client.NewClientWithEnv(apikey, pkg.Options.Environment, pkg.Options.Debug)
		if err != nil {
			return err
		}

		spec, err := getSpec(opt.SpecYAML)
		if err != nil {
			return err
		}

		instanceList, err := createInstanceList(spec, bxCli)
		if err != nil {
			return err
		}

		err = syncObjects(spec, instanceList)
		if err != nil {
			return err
		}

		duration := time.Since(start)
		klog.Infof("Total elapsed time: %v", duration)
		return nil
	},
}

Types

type InstanceItem

type InstanceItem struct {
	Source SyncClient
	Target []SyncClient
}

instance item for source and target instances

type SyncClient

type SyncClient interface {
	// S3Client methods
	CopyObjectToBucket(srcBucketName string, destBucketName string, objectName string) error
	CheckBucketLocationConstraint(bucketName string, bucketLocationConstraint string) (bool, error)
	SelectObjects(bucketName string, regex string) ([]string, error)
}

sync client interface

func NewS3Client

func NewS3Client(c *client.Client, instanceName string, region string) (SyncClient, error)