qshell

Documentation

Index

• Constants
• func CheckQrsync(dirCacheResultFile string, listBucketResultFile string, ignoreLocalDir bool, ...)
• func Fetch(mac *digest.Mac, remoteResUrl, bucket, key string) (err error)
• func Prefetch(mac *digest.Mac, bucket, key string) (err error)
• func QiniuDownload(threadCount int, downloadConfigFile string)
• func QiniuUpload(putThreshold int64, uploadConfigFile string)
• type Account
  • func (this *Account) Get()
  • func (this *Account) Set(accessKey string, secretKey string)
  • func (this *Account) String() string
  • func (this *Account) ToJson() (jsonStr string)
• type AliListBucket
  • func (this *AliListBucket) ListBucket(listResultFile string) (err error)
• type DirCache
  • func (this *DirCache) Cache(cacheRootPath string, cacheResultFile string) (fileCount int)
• type DownloadConfig
• type FopResult
• type FopRet
  • func (this *FopRet) String() string
• type ListBucket
  • func (this *ListBucket) List(bucket string, prefix string, listResultFile string) (retErr error)
• type RSFop
  • func (this *RSFop) Prefop(persistentId string, fopRet *FopRet) (err error)
• type UploadConfig

Constants

const (
	PUT_THRESHOLD int64 = 2 << 30
)

Functions

func CheckQrsync

func CheckQrsync(dirCacheResultFile string, listBucketResultFile string, ignoreLocalDir bool, prefix string)

func Fetch

func Fetch(mac *digest.Mac, remoteResUrl, bucket, key string) (err error)

func Prefetch

func Prefetch(mac *digest.Mac, bucket, key string) (err error)

func QiniuDownload

func QiniuDownload(threadCount int, downloadConfigFile string)

func QiniuUpload

func QiniuUpload(putThreshold int64, uploadConfigFile string)

Types

type Account

type Account struct {
	AccessKey string `json:"access_key"`
	SecretKey string `json:"secret_key"`
}

func (*Account) Get

func (this *Account) Get()

func (*Account) Set

func (this *Account) Set(accessKey string, secretKey string)

func (*Account) String

func (this *Account) String() string

func (*Account) ToJson

func (this *Account) ToJson() (jsonStr string)

type AliListBucket

type AliListBucket struct {
	DataCenter      string
	AccessKeyId     string
	AccessKeySecret string
	Bucket          string
	Prefix          string
}

func (*AliListBucket) ListBucket

func (this *AliListBucket) ListBucket(listResultFile string) (err error)

type DirCache

type DirCache struct {
}

func (*DirCache) Cache

func (this *DirCache) Cache(cacheRootPath string, cacheResultFile string) (fileCount int)

type DownloadConfig

type DownloadConfig struct {
	DestDir   string `json:"dest_dir"`
	Bucket    string `json:"bucket"`
	Domain    string `json:"domain"`
	AccessKey string `json:"access_key"`
	SecretKey string `json:"secret_key"`
	IsPrivate bool   `json:"is_private"`
	Prefix    string `json:"prefix,omitempty"`
}

{
	"dest_dir"		:	"/Users/jemy/Backup",
	"bucket"		:	"test-bucket",
	"domain"		:	"<Your bucket domain>",
	"access_key"	:	"<Your AccessKey>",
	"secret_key"	:	"<Your SecretKey>",
	"is_private"	:	false,
	"prefix"		:	"demo/"
}

type FopResult

type FopResult struct {
	Cmd   string   `json:"cmd"`
	Code  int      `json:"code"`
	Desc  string   `json:"desc"`
	Error string   `json:"error,omitempty"`
	Hash  string   `json:"hash,omitempty"`
	Key   string   `json:"key,omitempty"`
	Keys  []string `json:"keys,omitempty"`
}

type FopRet

type FopRet struct {
	Id          string `json:"id"`
	Code        int    `json:"code"`
	Desc        string `json:"desc"`
	InputBucket string `json:"inputBucket,omitempty"`
	InputKey    string `json:"inputKey,omitempty"`
	Pipeline    string `json:"pipeline,omitempty"`
	Reqid       string `json:"reqid,omitempty"`
	Items       []FopResult
}

func (*FopRet) String

func (this *FopRet) String() string

type ListBucket

type ListBucket struct {
	Account
}

func (*ListBucket) List

func (this *ListBucket) List(bucket string, prefix string, listResultFile string) (retErr error)

type RSFop

type RSFop struct {
	Account
}

func (*RSFop) Prefop

func (this *RSFop) Prefop(persistentId string, fopRet *FopRet) (err error)

type UploadConfig

type UploadConfig struct {
	SrcDir    string `json:"src_dir"`
	AccessKey string `json:"access_key"`
	SecretKey string `json:"secret_key"`
	Bucket    string `json:"bucket"`
	KeyPrefix string `json:"key_prefix,omitempty"`
	IgnoreDir bool   `json:"ignore_dir,omitempty"`
}