Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

lib

package

Go to main page

Versions in this module

v1

v1.7.1

Jan 13, 2021

Changes in this version

+ const AdvanceSeconds

+ const AkServiceSection

+ const BucketCnameSection

+ const BucketEndpointSection

+ const CREDSection

+ const ChannelBuf

+ const CheckpointDir

+ const CheckpointSep

+ const ChineseLanguage

+ const DefaultBigFileThreshold

+ const DefaultConfigFile

+ const DefaultEndpoint

+ const DefaultHashType

+ const DefaultLimitedNum

+ const DefaultMethod

+ const DefaultNonePattern

+ const DefaultOutputDir

+ const DefaultPartSize

+ const DefaultStorageClass

+ const DefaultTimeout

+ const EnglishLanguage

+ const ExcludePrompt

+ const FormatTAB

+ const GroupTypeAdditionalCommand

+ const GroupTypeDeprecatedCommand

+ const GroupTypeNormalCommand

+ const HashCRC64

+ const HashContentMD5

+ const HashMD5

+ const IncludePrompt

+ const ItemEcsAk

+ const LogFilePrefix

+ const MD5HashType

+ const MaxAppendObjectSize

+ const MaxBatchCount

+ const MaxBigFileThreshold

+ const MaxCommandNameLen

+ const MaxIdealPartNum

+ const MaxIdealPartSize

+ const MaxInt

+ const MaxInt64

+ const MaxParallel

+ const MaxPartNum

+ const MaxPartSize

+ const MaxRetryTimes

+ const MaxRoutines

+ const MaxTimeout

+ const MaxUint

+ const MaxUint64

+ const MinBigFileThreshold

+ const MinIdealPartNum

+ const MinIdealPartSize

+ const MinLimitedNum

+ const MinParallel

+ const MinPartSize

+ const MinRetryTimes

+ const MinRoutines

+ const MinTimeout

+ const OptionACL

+ const OptionAccessKeyID

+ const OptionAccessKeySecret

+ const OptionAcrHeaders

+ const OptionAcrMethod

+ const OptionAddr

+ const OptionAllType

+ const OptionAllversions

+ const OptionBackupDir

+ const OptionBigFileThreshold

+ const OptionBucket

+ const OptionBucketName

+ const OptionCheckpointDir

+ const OptionConfigFile

+ const OptionContinue

+ const OptionDelete

+ const OptionDirectory

+ const OptionDisableAllSymlink

+ const OptionDisableCRC64

+ const OptionDisableDirObject

+ const OptionDisableEmptyReferer

+ const OptionDisableEncodeSlash

+ const OptionDisableIgnoreError

+ const OptionDownload

+ const OptionEnableSymlinkDir

+ const OptionEncodingType

+ const OptionEndTime

+ const OptionEndpoint

+ const OptionExclude

+ const OptionForce

+ const OptionHashType

+ const OptionInclude

+ const OptionKMSDataEncryption

+ const OptionKMSMasterKeyID

+ const OptionLanguage

+ const OptionLimitedNum

+ const OptionLocalHost

+ const OptionLogLevel

+ const OptionMarker

+ const OptionMaxUpSpeed

+ const OptionMeta

+ const OptionMethod

+ const OptionMultipart

+ const OptionObject

+ const OptionOnlyCurrentDir

+ const OptionOrigin

+ const OptionOutputDir

+ const OptionParallel

+ const OptionPartSize

+ const OptionPartitionDownload

+ const OptionProbeItem

+ const OptionProxyHost

+ const OptionProxyPwd

+ const OptionProxyUser

+ const OptionRange

+ const OptionRecursion

+ const OptionRedundancyType

+ const OptionRequestPayer

+ const OptionRetryTimes

+ const OptionRoutines

+ const OptionSSEAlgorithm

+ const OptionSTSToken

+ const OptionShortFormat

+ const OptionSnapshotPath

+ const OptionStartTime

+ const OptionStorageClass

+ const OptionTagging

+ const OptionTimeout

+ const OptionTrafficLimit

+ const OptionTypeAlternative

+ const OptionTypeFlagTrue

+ const OptionTypeInt64

+ const OptionTypeString

+ const OptionUpMode

+ const OptionUpdate

+ const OptionUpload

+ const OptionUploadIDMarker

+ const OptionUrl

+ const OptionVersion

+ const OptionVersionId

+ const OptionVersionIdMarker

+ const Package

+ const ReportPrefix

+ const ReportSuffix

+ const RetryTimes

+ const Routines

+ const Scheme

+ const SchemePrefix

+ const SnapshotConnector

+ const SnapshotSep

+ const StatACL

+ const StatCRC64

+ const StatContentMD5

+ const StatCreationDate

+ const StatExtranetEndpoint

+ const StatIntranetEndpoint

+ const StatKMSDataEncryption

+ const StatKMSMasterKeyID

+ const StatLastModified

+ const StatLocation

+ const StatName

+ const StatOwner

+ const StatRedundancyType

+ const StatSSEAlgorithm

+ const StatStorageClass

+ const StorageArchive

+ const StorageColdArchive

+ const StorageIA

+ const StorageStandard

+ const URLEncodingType

+ const UsageTextChinese

+ const UsageTextEnglish

+ const Version

+ var CommandGroups = []string

+ var CredOptionList = []string

+ var CredOptionMap = map[string]configOption

+ var DefaultLanguage = getOsLang()

+ var LEnglishLanguage = strings.ToLower(EnglishLanguage)

+ var MaxSyncNumbers int = 1000000

+ var OptionMap = map[string]Option

+ func CloudURLToString(bucket string, object string) string

+ func DecideConfigFile(configFile string) string

+ func FindPos(elem string, elemArray []string) int

+ func FindPosCaseInsen(elem string, elemArray []string) int

+ func GetAllCommands() []interface

+ func GetBool(name string, options OptionMapType) (bool, error)

+ func GetInt(name string, options OptionMapType) (int64, error)

+ func GetString(name string, options OptionMapType) (string, error)

+ func InitLogger(level int, name string)

+ func LogDebug(format string, a ...interface{})

+ func LogEnd(startT time.Time)

+ func LogError(format string, a ...interface{})

+ func LogInfo(format string, a ...interface{})

+ func LogWarn(format string, a ...interface{})

+ func Output(str string)

+ func ParseAndRunCommand() error

+ func RunCommand(args []string, options OptionMapType) (bool, error)

+ func UnInitLogger()

+ type AllPartSizeCommand struct

+ func (apc *AllPartSizeCommand) GetAllStatInfo() error

+ func (apc *AllPartSizeCommand) GetObjectPartsSize(bucket *oss.Bucket, statInfo StatPartInfo) (int64, int64, error)

+ func (apc *AllPartSizeCommand) Init(args []string, options OptionMapType) error

+ func (apc *AllPartSizeCommand) RunCommand() error

+ type AppendFileCommand struct

+ func (afc *AppendFileCommand) AppendFromFile(bucket *oss.Bucket, position int64) error

+ func (afc *AppendFileCommand) Init(args []string, options OptionMapType) error

+ func (afc *AppendFileCommand) RunCommand() error

+ type AppendProgressListener struct

+ func (l *AppendProgressListener) ProgressChanged(event *oss.ProgressEvent)

+ type AverageInfo struct

+ AveSpeed float64

+ Parallel int

+ type BucketEncryptionCommand struct

+ func (bec *BucketEncryptionCommand) DeleteBucketEncryption() error

+ func (bec *BucketEncryptionCommand) GetBucketEncryption() error

+ func (bec *BucketEncryptionCommand) Init(args []string, options OptionMapType) error

+ func (bec *BucketEncryptionCommand) PutBucketEncryption() error

+ func (bec *BucketEncryptionCommand) RunCommand() error

+ type BucketError struct

+ func (e BucketError) Error() string

+ type BucketInventoryCommand struct

+ func (bic *BucketInventoryCommand) DeleteBucketInventory() error

+ func (bic *BucketInventoryCommand) GetBucketInventory() error

+ func (bic *BucketInventoryCommand) Init(args []string, options OptionMapType) error

+ func (bic *BucketInventoryCommand) ListBucketInventory() error

+ func (bic *BucketInventoryCommand) PutBucketInventory() error

+ func (bic *BucketInventoryCommand) RunCommand() error

+ type BucketInventoryOptionType struct

+ type BucketLifeCycleCommand struct

+ func (blc *BucketLifeCycleCommand) DeleteBucketLifecycle() error

+ func (blc *BucketLifeCycleCommand) GetBucketLifecycle() error

+ func (blc *BucketLifeCycleCommand) Init(args []string, options OptionMapType) error

+ func (blc *BucketLifeCycleCommand) PutBucketLifecycle() error

+ func (blc *BucketLifeCycleCommand) RunCommand() error

+ type BucketLogCommand struct

+ func (blc *BucketLogCommand) DeleteBucketLog() error

+ func (blc *BucketLogCommand) GetBucketLog() error

+ func (blc *BucketLogCommand) Init(args []string, options OptionMapType) error

+ func (blc *BucketLogCommand) PutBucketLog() error

+ func (blc *BucketLogCommand) RunCommand() error

+ type BucketPolicyCommand struct

+ func (bpc *BucketPolicyCommand) DeleteBucketPolicy() error

+ func (bpc *BucketPolicyCommand) GetBucketPolicy() error

+ func (bpc *BucketPolicyCommand) Init(args []string, options OptionMapType) error

+ func (bpc *BucketPolicyCommand) PutBucketPolicy() error

+ func (bpc *BucketPolicyCommand) RunCommand() error

+ type BucketQosCommand struct

+ func (bqc *BucketQosCommand) DeleteBucketQos() error

+ func (bqc *BucketQosCommand) GetBucketQos() error

+ func (bqc *BucketQosCommand) Init(args []string, options OptionMapType) error

+ func (bqc *BucketQosCommand) PutBucketQos() error

+ func (bqc *BucketQosCommand) RunCommand() error

+ type BucketRefererCommand struct

+ func (brc *BucketRefererCommand) DeleteBucketRefer() error

+ func (brc *BucketRefererCommand) GetBucketRefer() error

+ func (brc *BucketRefererCommand) Init(args []string, options OptionMapType) error

+ func (brc *BucketRefererCommand) PutBucketRefer() error

+ func (brc *BucketRefererCommand) RunCommand() error

+ type BucketTagCommand struct

+ func (btc *BucketTagCommand) DeleteBucketTag() error

+ func (btc *BucketTagCommand) GetBucketTag() error

+ func (btc *BucketTagCommand) Init(args []string, options OptionMapType) error

+ func (btc *BucketTagCommand) PutBucketTag() error

+ func (btc *BucketTagCommand) RunCommand() error

+ type BucketVersioningCommand struct

+ func (bvc *BucketVersioningCommand) GetBucketVersioning() error

+ func (bvc *BucketVersioningCommand) Init(args []string, options OptionMapType) error

+ func (bvc *BucketVersioningCommand) PutBucketVersioning() error

+ func (bvc *BucketVersioningCommand) RunCommand() error

+ type BucketWebSiteCommand struct

+ func (bwc *BucketWebSiteCommand) DeleteBucketWebsite() error

+ func (bwc *BucketWebSiteCommand) GetBucketWebsite() error

+ func (bwc *BucketWebSiteCommand) Init(args []string, options OptionMapType) error

+ func (bwc *BucketWebSiteCommand) PutBucketWebsite() error

+ func (bwc *BucketWebSiteCommand) RunCommand() error

+ type CPMonitor struct

+ type CPMonitorSnap struct

+ type CatCommand struct

+ func (catc *CatCommand) Init(args []string, options OptionMapType) error

+ func (catc *CatCommand) RunCommand() error

+ type CloudURL struct

+ func CloudURLFromString(urlStr, encodingType string) (CloudURL, error)

+ func GetCloudUrl(strlUrl, encodingType string) (*CloudURL, error)

+ func ObjectURLFromString(urlStr, encodingType string) (CloudURL, error)

+ func (cu *CloudURL) Init(urlStr, encodingType string) error

+ func (cu CloudURL) IsCloudURL() bool

+ func (cu CloudURL) IsFileURL() bool

+ func (cu CloudURL) ToString() string

+ type CloudURLType string

+ const CloudURLBucket

+ const CloudURLNone

+ const CloudURLObject

+ const CloudURLService

+ type Command struct

+ func (cmd *Command) Init(args []string, options OptionMapType, cmder interface{}) error

+ type CommandError struct

+ func (e CommandError) Error() string

+ type CommandManager struct

+ func (cm *CommandManager) Init()

+ func (cm *CommandManager) RunCommand(commandName string, args []string, options OptionMapType) (bool, error)

+ type Commander interface

+ Init func(args []string, options OptionMapType) error

+ RunCommand func() error

+ type ConfigCommand struct

+ func (cc *ConfigCommand) Init(args []string, options OptionMapType) error

+ func (cc *ConfigCommand) RunCommand() error

+ type CopyCommand struct

+ func (cc *CopyCommand) Init(args []string, options OptionMapType) error

+ func (cc *CopyCommand) RunCommand() error

+ type CopyError struct

+ func (e CopyError) Error() string

+ type CorsCommand struct

+ func (corsc *CorsCommand) DeleteBucketCors() error

+ func (corsc *CorsCommand) GetBucketCors() error

+ func (corsc *CorsCommand) Init(args []string, options OptionMapType) error

+ func (corsc *CorsCommand) PutBucketCors() error

+ func (corsc *CorsCommand) RunCommand() error

+ type CreateSymlinkCommand struct

+ func (cc *CreateSymlinkCommand) Init(args []string, options OptionMapType) error

+ func (cc *CreateSymlinkCommand) RunCommand() error

+ type DuCommand struct

+ func (duc *DuCommand) GetAllPartSize(bucket *oss.Bucket) error

+ func (duc *DuCommand) Init(args []string, options OptionMapType) error

+ func (duc *DuCommand) RunCommand() error

+ type EcsRoleAK struct

+ AccessKeyId string

+ AccessKeySecret string

+ SecurityToken string

+ func (ecsRole *EcsRoleAK) GetAccessKeyID() string

+ func (ecsRole *EcsRoleAK) GetAccessKeySecret() string

+ func (ecsRole *EcsRoleAK) GetSecurityToken() string

+ type EcsRoleAKBuild struct

+ AccessKeyId string

+ AccessKeySecret string

+ Expiration string

+ HasGet bool

+ LastUpDated string

+ SecurityToken string

+ func (roleBuild *EcsRoleAKBuild) GetCredentials() oss.Credentials

+ func (roleBuild *EcsRoleAKBuild) HttpReqAk() (STSAkJson, error)

+ func (roleBuild *EcsRoleAKBuild) IsTimeOut() bool

+ type FileError struct

+ func (e FileError) Error() string

+ type FileURL struct

+ func (fu *FileURL) Init(urlStr, encodingType string) error

+ func (fu FileURL) IsCloudURL() bool

+ func (fu FileURL) IsFileURL() bool

+ func (fu FileURL) ToString() string

+ type FormatHelper interface

+ type HashCommand struct

+ func (hc *HashCommand) Init(args []string, options OptionMapType) error

+ func (hc *HashCommand) RunCommand() error

+ type HelpCommand struct

+ func (hc *HelpCommand) Init(args []string, options OptionMapType) error

+ func (hc *HelpCommand) RunCommand() error

+ type ListCommand struct

+ func (lc *ListCommand) Init(args []string, options OptionMapType) error

+ func (lc *ListCommand) RunCommand() error

+ type ListPartCommand struct

+ func (lpc *ListPartCommand) Init(args []string, options OptionMapType) error

+ func (lpc *ListPartCommand) ListPart() error

+ func (lpc *ListPartCommand) RunCommand() error

+ type MakeBucketCommand struct

+ func (mc *MakeBucketCommand) Init(args []string, options OptionMapType) error

+ func (mc *MakeBucketCommand) RunCommand() error

+ type MkdirCommand struct

+ func (mkc *MkdirCommand) Init(args []string, options OptionMapType) error

+ func (mkc *MkdirCommand) MkBucketDir(dirUrl CloudURL) error

+ func (mkc *MkdirCommand) RunCommand() error

+ type Monitor struct

+ type MonitorSnap struct

+ type Monitorer interface

+ type MultiPartObject struct

+ type ObjectError struct

+ func (e ObjectError) Error() string

+ type ObjectTagCommand struct

+ func (otc *ObjectTagCommand) BatchObjectTagging(bucket *oss.Bucket, cloudURL CloudURL) error

+ func (otc *ObjectTagCommand) Init(args []string, options OptionMapType) error

+ func (otc *ObjectTagCommand) RunCommand() error

+ func (otc *ObjectTagCommand) SingleObjectTagging(bucket *oss.Bucket, objectName string) error

+ type Option struct

+ type OptionMapType map[string]interface

+ func LoadConfig(configFile string) (OptionMapType, error)

+ func ParseArgOptions() ([]string, OptionMapType, error)

+ type OptionsCommand struct

+ func (opsc *OptionsCommand) Init(args []string, options OptionMapType) error

+ func (opsc *OptionsCommand) RunCommand() error

+ type OssProgressListener struct

+ func (l *OssProgressListener) ProgressChanged(event *oss.ProgressEvent)

+ type OssResumeProgressListener struct

+ func (l *OssResumeProgressListener) ProgressChanged(event *oss.ProgressEvent)

+ type ProbeCommand struct

+ func (pc *ProbeCommand) CheckCycleSymlinkWithDeepTravel() error

+ func (pc *ProbeCommand) DetectBandWidth() error

+ func (pc *ProbeCommand) GetObject(bucket *oss.Bucket, objectName string, st *StatBandWidth)

+ func (pc *ProbeCommand) Init(args []string, options OptionMapType) error

+ func (pc *ProbeCommand) PutObject(bucket *oss.Bucket, st *StatBandWidth, reader io.Reader)

+ func (pc *ProbeCommand) RunCommand() error

+ type RMMonitor struct

+ type RMMonitorSnap struct

+ type ReadSymlinkCommand struct

+ func (rc *ReadSymlinkCommand) Init(args []string, options OptionMapType) error

+ func (rc *ReadSymlinkCommand) RunCommand() error

+ type RemoveCommand struct

+ func (rc *RemoveCommand) Init(args []string, options OptionMapType) error

+ func (rc *RemoveCommand) RunCommand() error

+ type Reporter struct

+ func GetReporter(need bool, outputDir, comment string) (*Reporter, error)

+ func (re *Reporter) Clear()

+ func (re *Reporter) Comment()

+ func (re *Reporter) HasPrompt() bool

+ func (re *Reporter) Init(outputDir, comment string) error

+ func (re *Reporter) Prompt(err error)

+ func (re *Reporter) ReportError(msg string)

+ type RequestPaymentCommand struct

+ func (reqpc *RequestPaymentCommand) GetRequestPayment() error

+ func (reqpc *RequestPaymentCommand) Init(args []string, options OptionMapType) error

+ func (reqpc *RequestPaymentCommand) PutRequestPayment() error

+ func (reqpc *RequestPaymentCommand) RunCommand() error

+ type RestoreCommand struct

+ func (rc *RestoreCommand) Init(args []string, options OptionMapType) error

+ func (rc *RestoreCommand) RunCommand() error

+ type RevertCommand struct

+ func (revert *RevertCommand) Init(args []string, options OptionMapType) error

+ func (revert *RevertCommand) RunCommand() error

+ type RewriteAssembleOptioner interface

+ type RewriteLoadConfiger interface

+ type STSAkJson struct

+ AccessKeyId string

+ AccessKeySecret string

+ Code string

+ Expiration string

+ LastUpDated string

+ SecurityToken string

+ func (stsJson *STSAkJson) String() string

+ type SetACLCommand struct

+ func (sc *SetACLCommand) Init(args []string, options OptionMapType) error

+ func (sc *SetACLCommand) RunCommand() error

+ type SetMetaCommand struct

+ func (sc *SetMetaCommand) Init(args []string, options OptionMapType) error

+ func (sc *SetMetaCommand) RunCommand() error

+ type SignurlCommand struct

+ func (sc *SignurlCommand) Init(args []string, options OptionMapType) error

+ func (sc *SignurlCommand) RunCommand() error

+ type SpecText struct

+ type StatBandWidth struct

+ MaxSpeed float64

+ Mu sync.Mutex

+ Parallel int

+ StartTick int64

+ TotalBytes int64

+ func (s *StatBandWidth) AddBytes(bc int64)

+ func (s *StatBandWidth) GetStat() *StatBandWidth

+ func (s *StatBandWidth) ProgressChanged(event *oss.ProgressEvent)

+ func (s *StatBandWidth) Reset(pc int)

+ func (s *StatBandWidth) SetMaxSpeed(ms float64)

+ type StatCommand struct

+ func (sc *StatCommand) Init(args []string, options OptionMapType) error

+ func (sc *StatCommand) RunCommand() error

+ type StatPartInfo struct

+ type StorageURLer interface

+ IsCloudURL func() bool

+ IsFileURL func() bool

+ ToString func() string

+ func StorageURLFromString(urlStr, encodingType string) (StorageURLer, error)

+ type SyncCommand struct

+ func (sc *SyncCommand) BatchRmObjects(bucket *oss.Bucket, objects []string, options []oss.Option) error

+ func (sc *SyncCommand) CheckDestBackupDir(sUrl StorageURLer) error

+ func (sc *SyncCommand) DeleteExtraObjects(keys map[string]string, sUrl StorageURLer) error

+ func (sc *SyncCommand) GetAbsPath(strPath string) (string, error)

+ func (sc *SyncCommand) GetFileList(strPath string, chFiles chan<- fileInfoType, chFinish chan<- error)

+ func (sc *SyncCommand) GetLocalFileKeys(sUrl StorageURLer, keys map[string]string) error

+ func (sc *SyncCommand) GetOssKeyList(bucket *oss.Bucket, sURL StorageURLer, chObjects chan<- objectInfoType, ...)

+ func (sc *SyncCommand) GetOssKeys(sUrl StorageURLer, keys map[string]string) error

+ func (sc *SyncCommand) Init(args []string, options OptionMapType) error

+ func (sc *SyncCommand) ReadLocalFileKeys(chFiles <-chan fileInfoType, chFinish chan<- error, keys map[string]string)

+ func (sc *SyncCommand) ReadOssKeys(keys map[string]string, sURL StorageURLer, chObjects <-chan objectInfoType, ...)

+ func (sc *SyncCommand) RemoveExtraFiles(keys map[string]string, sUrl StorageURLer) error

+ func (sc *SyncCommand) RunCommand() error

+ type TestAppendReader struct

+ RandText []byte

+ func (r *TestAppendReader) Close()

+ func (r *TestAppendReader) Read(p []byte) (n int, err error)

+ type UpdateCommand struct

+ func (uc *UpdateCommand) Init(args []string, options OptionMapType) error

+ func (uc *UpdateCommand) RunCommand() error

+ type UserQosCommand struct

+ func (uqc *UserQosCommand) GetUserQos() error

+ func (uqc *UserQosCommand) Init(args []string, options OptionMapType) error

+ func (uqc *UserQosCommand) RunCommand() error

+ type WormCommand struct

+ func (wormc *WormCommand) AbortBucketWorm() error

+ func (wormc *WormCommand) CompleteBucketWorm() error

+ func (wormc *WormCommand) ExtendBucketWorm() error

+ func (wormc *WormCommand) GetBucketWorm() error

+ func (wormc *WormCommand) Init(args []string, options OptionMapType) error

+ func (wormc *WormCommand) InitiateBucketWorm() error

+ func (wormc *WormCommand) RunCommand() error

v1.6.9

Nov 14, 2019

v1.6.7

Sep 17, 2019

v1.6.6

Aug 9, 2019

v1.6.5

Jul 17, 2019

v1.6.4

Jul 12, 2019

v1.6.3

Jun 19, 2019

v1.6.2

Jun 6, 2019

v1.6.1

May 29, 2019

v1.6.0

Apr 23, 2019

v1.5.3

Apr 21, 2019