qshell

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 27, 2015 License: MIT Imports: 36 Imported by: 0

Documentation

Index

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 = 10 * 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 GetBuckets added in v1.4.6 

func GetBuckets(mac *digest.Mac) (buckets []string, err error)

func GetDomainsOfBucket added in v1.4.6 

func GetDomainsOfBucket(mac *digest.Mac, bucket string) (domains []string, err error)

func GetEtag added in v1.3.7 

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

func M3u8FileList added in v1.4.1 

func M3u8FileList(mac *digest.Mac, bucket string, m3u8Key string, isPrivate bool) (slicesToDelete []rs.EntryPath, 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 int64) string

func QiniuDownload 

func QiniuDownload(threadCount int, downloadConfigFile string)

func QiniuUpload 

func QiniuUpload(threadCount int, uploadConfigFile string)

func Saveas added in v1.3.9 

func Saveas(mac *digest.Mac, publicUrl string, saveBucket string, saveKey string) (string, error)

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 BatchItemRet added in v1.3.9 

type BatchItemRet struct {
	Code int              `json:"code"`
	Data BatchItemRetData `json:"data"`
}

func BatchChgm added in v1.3.9 

func BatchChgm(client rs.Client, entries []ChgmEntryPath) (ret []BatchItemRet, err error)

func BatchCopy added in v1.4.1 

func BatchCopy(client rs.Client, entries []CopyEntryPath) (ret []BatchItemRet, err error)

func BatchDelete added in v1.3.9 

func BatchDelete(client rs.Client, entries []rs.EntryPath) (ret []BatchItemRet, err error)

func BatchMove added in v1.3.9 

func BatchMove(client rs.Client, entries []MoveEntryPath) (ret []BatchItemRet, err error)

func BatchRename added in v1.3.9 

func BatchRename(client rs.Client, entries []RenameEntryPath) (ret []BatchItemRet, err error)

func BatchStat added in v1.4.4 

func BatchStat(client rs.Client, entries []rs.EntryPath) (ret []BatchItemRet, err error)

type BatchItemRetData added in v1.3.9 

type BatchItemRetData struct {
	Fsize    int    `json:"fsize,omitempty"`
	Hash     string `json:"hash,omitempty"`
	MimeType string `json:"mimeType,omitempty"`
	PutTime  int64  `json:"putTime,omitempty"`
	Error    string `json:"error,omitempty"`
}

type BucketDomain added in v1.4.1 

type BucketDomain []string

type ChgmEntryPath added in v1.3.9 

type ChgmEntryPath struct {
	Bucket   string
	Key      string
	MimeType string
}

type CopyEntryPath added in v1.4.1 

type CopyEntryPath struct {
	SrcBucket  string
	DestBucket string
	SrcKey     string
	DestKey    string
}

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"`
	Suffix    string `json:"suffix,omitempty"`
}

type FetchResult added in v1.3.9 

type FetchResult struct {
	Key  string `json:"key"`
	Hash string `json:"hash"`
}

func Fetch 

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

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 MoveEntryPath added in v1.3.9 

type MoveEntryPath struct {
	SrcBucket  string
	DestBucket string
	SrcKey     string
	DestKey    string
}

type RSFop 

type RSFop struct {
	Account
}

func (*RSFop) Prefop 

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

type RenameEntryPath added in v1.3.9 

type RenameEntryPath struct {
	Bucket string
	OldKey string
	NewKey string
}

type UploadConfig 

type UploadConfig struct {
	SrcDir       string `json:"src_dir"`
	AccessKey    string `json:"access_key"`
	SecretKey    string `json:"secret_key"`
	Bucket       string `json:"bucket"`
	UpHost       string `json:"up_host,omitempty"`
	KeyPrefix    string `json:"key_prefix,omitempty"`
	IgnoreDir    bool   `json:"ignore_dir,omitempty"`
	Overwrite    bool   `json:"overwrite,omitempty"`
	CheckExists  bool   `json:"check_exists,omitempty"`
	SkipPrefixes string `json:"skip_prefixes,omitempty"`
	SkipSuffixes string `json:"skip_suffixes,omitempty"`
}

Source Files

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.