qshell

package

v1.3.7 Latest Latest Go to latest Published: Mar 29, 2015 License: MIT Imports: 33 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitproxy.zycloud.tk/qiniu/qshell

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BlockCount(fsize int64) int
func CalSha1(b []byte, r io.Reader) ([]byte, error)
func CheckQrsync(dirCacheResultFile string, listBucketResultFile string, ignoreLocalDir bool, ...)
func Fetch(mac *digest.Mac, remoteResUrl, bucket, key string) (err error)
func GetEtag(filename string) (etag string, err error)
func Prefetch(mac *digest.Mac, bucket, key string) (err error)
func PrivateUrl(mac *digest.Mac, publicUrl string, deadline int) string
func QiniuDownload(threadCount int, downloadConfigFile string)
func QiniuUpload(threadCount int, uploadConfigFile string)
func Unzip(zipFilePath string, unzipPath string) (err error)
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 ¶

View Source

const (
	MIN_DOWNLOAD_THREAD_COUNT = 1
	MAX_DOWNLOAD_THREAD_COUNT = 100
)

View Source

const (
	BLOCK_BITS = 22 // Indicate that the blocksize is 4M
	BLOCK_SIZE = 1 << BLOCK_BITS
)

View Source

const (
	PUT_THRESHOLD           int64 = 100 * 1 << 20
	MIN_UPLOAD_THREAD_COUNT int64 = 1
	MAX_UPLOAD_THREAD_COUNT int64 = 100
)

Variables ¶

This section is empty.

Functions ¶

func BlockCount ¶ added in v1.3.7

func BlockCount(fsize int64) int

func CalSha1 ¶ added in v1.3.7

func CalSha1(b []byte, r io.Reader) ([]byte, error)

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 GetEtag ¶ added in v1.3.7

func GetEtag(filename string) (etag string, err error)

func Prefetch ¶

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

func PrivateUrl ¶ added in v1.3.7

func PrivateUrl(mac *digest.Mac, publicUrl string, deadline int) string

func QiniuDownload ¶

func QiniuDownload(threadCount int, downloadConfigFile string)

func QiniuUpload ¶

func QiniuUpload(threadCount int, uploadConfigFile string)

func Unzip ¶ added in v1.3.7

func Unzip(zipFilePath string, unzipPath string) (err error)

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"`
}

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"`
	Overwrite bool   `json:"overwrite,omitempty"`
}

Source Files ¶

account.go
alioss_list_bucket.go
dir_cache.go
list_bucket.go
qdownload.go
qetag.go
qrsync.go
qupload.go
rs.go
rs_fop.go
unzip.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL