storage

package

Go to main page

Versions in this module

v7

v7.21.0

May 20, 2024

Changes in this version

type BucketManagerOptions

+ AfterBackoff func(*http.Request, *retrier.RetrierOptions, time.Duration)

+ AfterResolve func(*http.Request, []net.IP)

+ AfterResponse func(*http.Response, *retrier.RetrierOptions, error)

+ AfterSign func(*http.Request)

+ Backoff backoff.Backoff

+ BeforeBackoff func(*http.Request, *retrier.RetrierOptions, time.Duration)

+ BeforeRequest func(*http.Request, *retrier.RetrierOptions)

+ BeforeResolve func(*http.Request)

+ BeforeSign func(*http.Request)

+ Chooser chooser.Chooser

+ ResolveError func(*http.Request, error)

+ Resolver resolver.Resolver

+ Retrier retrier.Retrier

+ SignError func(*http.Request, error)

type Config

+ func NewConfig() *Config

type UCApiOptions

+ AfterBackoff func(*http.Request, *retrier.RetrierOptions, time.Duration)

+ AfterResolve func(*http.Request, []net.IP)

+ AfterResponse func(*http.Response, *retrier.RetrierOptions, error)

+ AfterSign func(*http.Request)

+ Backoff backoff.Backoff

+ BeforeBackoff func(*http.Request, *retrier.RetrierOptions, time.Duration)

+ BeforeRequest func(*http.Request, *retrier.RetrierOptions)

+ BeforeResolve func(*http.Request)

+ BeforeSign func(*http.Request)

+ Chooser chooser.Chooser

+ ResolveError func(*http.Request, error)

+ Resolver resolver.Resolver

+ Retrier retrier.Retrier

+ SignError func(*http.Request, error)

type UploadConfig

+ func NewUploadConfig() *UploadConfig

v7.20.2

May 17, 2024

v7.20.1

Apr 26, 2024

Changes in this version

type ListInputOption

+ func ListInputOptionsNeedParts(needParts bool) ListInputOption

type ListItem

+ Parts []uint

type UCApiOptions

+ Client *client.Client

+ Hosts []string

v7.20.0

Apr 16, 2024

Changes in this version

type Region

+ func (r *Region) GetRegions(ctx context.Context) ([]*region_v2.Region, error)

v7.19.1

Mar 12, 2024

Changes in this version

type PutPolicy

+ Transform string

+ TransformFallbackKey string

+ TransformFallbackMode string

v7.19.0

Dec 27, 2023

Changes in this version

type BucketLifeCycleRule

+ ToArchiveIRAfterDays int

type FileInfo

+ TransitionToArchiveIR int64

v7.18.2

Oct 19, 2023

v7.18.1

Oct 17, 2023

v7.18.0

Oct 13, 2023

Changes in this version

+ func MakePublicURLv2WithQueryString(domain, key, query string) string

+ func URIChangeMeta(bucket, key string, changeMetas map[string]string) string

+ func URIChangeMimeAndMeta(bucket, key, newMime string, metas map[string]string) string

type BucketManager

+ func (m *BucketManager) ChangeMeta(bucket, key string, metas map[string]string) (err error)

+ func (m *BucketManager) ChangeMimeAndMeta(bucket, key, newMime string, metas map[string]string) (err error)

+ func (m *BucketManager) Get(bucket, key string, options *GetObjectInput) (*GetObjectOutput, error)

type FileInfo

+ MetaData map[string]string

+ type GetObjectInput struct

+ Context context.Context

+ DownloadDomains []string

+ PresignUrl bool

+ Range string

+ TrafficLimit uint64

+ type GetObjectOutput struct

+ Body io.ReadCloser

+ ContentLength int64

+ ContentType string

+ ETag string

+ LastModified time.Time

+ Metadata map[string]string

+ func (g *GetObjectOutput) Close() error

+ func (g *GetObjectOutput) Read(p []byte) (n int, err error)

type PutPolicy

+ TrafficLimit uint64

v7.17.1

Aug 23, 2023

v7.17.0

Jun 29, 2023

Changes in this version

+ func SetUcHosts(hosts ...string)

type BucketManager

+ func NewBucketManagerExWithOptions(mac *auth.Credentials, cfg *Config, clt *clientv1.Client, ...) *BucketManager

+ type BucketManagerOptions struct

+ HostFreezeDuration time.Duration

+ RetryMax int

type Region

+ func GetRegionWithOptions(ak, bucket string, options UCApiOptions) (*Region, error)

type RegionInfo

+ func GetRegionsInfoWithOptions(mac *auth.Credentials, options UCApiOptions) ([]RegionInfo, error)

+ type UCApiOptions struct

+ HostFreezeDuration time.Duration

+ RetryMax int

+ UseHttps bool

+ func DefaultUCApiOptions() UCApiOptions

v7.16.0

Jun 7, 2023

Changes in this version

type BucketInfo

+ Ctime time.Time

+ Remark string

type BucketManager

+ func (m *BucketManager) BucketsV4(input *BucketV4Input) (output BucketsV4Output, err error)

+ func (m *BucketManager) SetRemark(bucketName, remark string) (err error)

+ type BucketV4Input struct

+ Limit uint64

+ Marker string

+ Region string

+ type BucketV4Output struct

+ Ctime time.Time

+ Name string

+ Private bool

+ Region string

+ type BucketsV4Output struct

+ Buckets []BucketV4Output

+ IsTruncated bool

+ NextMarker string

v7.15.0

Apr 23, 2023

Changes in this version

type BucketManager

+ func (m *BucketManager) BatchWithContext(ctx context.Context, bucket string, operations []string) ([]BatchOpRet, error)

+ func (m *BucketManager) ListFilesWithContext(ctx context.Context, bucket string, options ...ListInputOption) (ret *ListFilesRet, hasNext bool, err error)

+ type ListFilesRet struct

+ CommonPrefixes []string

+ Items []ListItem

+ Marker string

+ type ListInputOption func(options *listInputOptions)

+ func ListInputOptionsDelimiter(delimiter string) ListInputOption

+ func ListInputOptionsLimit(limit int) ListInputOption

+ func ListInputOptionsMarker(marker string) ListInputOption

+ func ListInputOptionsPrefix(prefix string) ListInputOption

type ListItem

+ Md5 string

+ Status int

type Region

+ IoSrcHost string

type UcQueryRet

+ IoSrcInfo map[string]UcQueryIo

v7.14.0

Oct 25, 2022

Changes in this version

+ const RIDApNortheast1

+ var ZoneHuadongZheJiang2 = GetRegionByID(RIDHuadongZheJiang2)

+ var ZoneShouEr1 = GetRegionByID(RIDApNortheast1)

type Base64PutExtra

+ HostFreezeDuration time.Duration

+ TryTimes int

type InitPartsRet

+ ExpireAt int64

type PutExtra

+ HostFreezeDuration time.Duration

+ TryTimes int

+ type RegionGroup struct

+ func NewRegionGroup(region ...*Region) *RegionGroup

+ func (g *RegionGroup) CouldSwitchRegion() bool

+ func (g *RegionGroup) GetRegion() *Region

+ func (g *RegionGroup) SwitchRegion() bool

type RputExtra

+ HostFreezeDuration time.Duration

type RputV2Extra

+ HostFreezeDuration time.Duration

type UcQueryRet

+ ApiInfo map[string]UcQueryServerInfo

+ RsInfo map[string]UcQueryServerInfo

+ RsfInfo map[string]UcQueryServerInfo

+ type UcQueryServerInfo struct

+ Backup []string

+ Info string

+ Main []string

+ type UploadConfig struct

+ Regions *RegionGroup

+ UseCdnDomains bool

+ UseHTTPS bool

+ type UploadExtra struct

+ HostFreezeDuration time.Duration

+ MimeType string

+ OnProgress func(fileSize, uploaded int64)

+ Params map[string]string

+ PartSize int64

+ Recorder Recorder

+ TryTimes int

+ UploadResumeVersion UploadResumeVersion

+ UploadThreshold int64

+ type UploadManager struct

+ func NewUploadManager(cfg *UploadConfig) *UploadManager

+ func NewUploadManagerEx(cfg *UploadConfig, c *client.Client) *UploadManager

+ func (manager *UploadManager) Put(ctx context.Context, ret interface{}, upToken string, key *string, ...) error

+ type UploadResumeVersion = int

+ const UploadResumeV1

+ const UploadResumeV2

+ type UploadRet struct

+ Hash string

+ Key string

+ type UploadSource interface

+ Rewind func() error

+ Rewindable func() bool

+ Size func() int64

+ func NewUploadSourceFile(filePath string) (UploadSource, error)

+ func NewUploadSourceReader(reader io.Reader, size int64) (UploadSource, error)

+ func NewUploadSourceReaderAt(reader io.ReaderAt, size int64) (UploadSource, error)

v7.13.0

Jun 8, 2022

v7.12.1

Apr 25, 2022

Changes in this version

type FileInfo

+ EndUser string

+ Expiration int64

+ Md5 string

+ RestoreStatus int

+ TransitionToArchive int64

+ TransitionToDeepArchive int64

+ TransitionToIA int64

v7.12.0

Apr 15, 2022

Changes in this version

+ const RIDHuadongZheJiang2

type BucketLifeCycleRule

+ ToArchiveAfterDays int

+ ToDeepArchiveAfterDays int

v7.11.1

Jan 24, 2022

Changes in this version

+ const RIDHuadongZheJiang

v7.11.0

Oct 26, 2021

v7.10.1

Oct 20, 2021

v7.10.0

Sep 18, 2021

Changes in this version

type BucketManager

+ func (m *BucketManager) StatWithOpts(bucket, key string, opt *StatOpts) (info FileInfo, err error)

type FileInfo

+ Parts []int64

type ResumeUploader

+ func (p *ResumeUploader) PutWithoutKeyAndSize(ctx context.Context, ret interface{}, upToken string, f io.Reader, ...) error

+ type StatOpts struct

+ NeedParts bool

+ type UcQueryIo struct

+ Backup []string

+ Info string

+ Main []string

type UcQueryRet

+ IoInfo map[string]UcQueryIo

+ func (uc *UcQueryRet) UnmarshalJSON(data []byte) error

v7.9.8

Jul 29, 2021

Changes in this version

type FileInfo

+ Status int

v7.9.7

Jun 29, 2021

v7.9.6

May 31, 2021

Changes in this version

+ func SetUcHost(host string, useHttps bool)

v7.9.5

Apr 22, 2021

Changes in this version

+ func MakePrivateURLv2(mac *auth.Credentials, domain, key string, deadline int64) (privateURL string)

+ func MakePrivateURLv2WithQuery(mac *auth.Credentials, domain, key string, query url.Values, deadline int64) (privateURL string)

+ func MakePrivateURLv2WithQueryString(mac *auth.Credentials, domain, key, query string, deadline int64) (privateURL string)

+ func MakePublicURLv2(domain, key string) string

+ func MakePublicURLv2WithQuery(domain, key string, query url.Values) string

v7.9.4

Apr 19, 2021

v7.9.3

Apr 14, 2021

v7.9.2

Mar 15, 2021

Changes in this version

type RputV2Extra

+ Progresses []UploadPartInfo

+ type UploadPartInfo struct

+ Etag string

+ PartNumber int64

v7.9.1

Feb 24, 2021

v7.9.0

Feb 1, 2021

Changes in this version

+ const DefaultAPIHost

+ const DefaultPubHost

+ const DefaultRsHost

+ const DefaultRsfHost

+ const ErrChunkUpCanceled

+ const ErrMaxUpRetry

+ const ErrNextReader

+ const ErrUploadChunkFailed

+ const InvalidCtx

+ const RIDFogCnEast1

+ const RIDHuabei

+ const RIDHuadong

+ const RIDHuanan

+ const RIDNorthAmerica

+ const RIDSingapore

+ const UcHost

+ var CallRet = client.CallRet

+ var DefaultClient = client.DefaultClient

+ var ErrBadToken = errors.New("invalid token")

+ var ErrBucketNotExist = errors.New("bucket not exist")

+ var ErrInvalidPutProgress = errors.New("invalid put progress")

+ var ErrNoSuchFile = errors.New("No such file or directory")

+ var ErrPutFailed = errors.New("resumable put failed")

+ var ErrUnmatchedChecksum = errors.New("unmatched checksum")

+ var ResponseError = client.ResponseError

+ var UserAgent = client.UserAgent

+ var ZoneBeimei = GetRegionByID(RIDNorthAmerica)

+ var ZoneFogCnEast1 = GetRegionByID(RIDFogCnEast1)

+ var ZoneHuabei = GetRegionByID(RIDHuabei)

+ var ZoneHuadong = GetRegionByID(RIDHuadong)

+ var ZoneHuanan = GetRegionByID(RIDHuanan)

+ var ZoneXinjiapo = GetRegionByID(RIDSingapore)

+ var Zone_as0 = ZoneXinjiapo

+ var Zone_fog_cn_east_1 = ZoneFogCnEast1

+ var Zone_na0 = ZoneBeimei

+ var Zone_z0 = ZoneHuadong

+ var Zone_z1 = ZoneHuabei

+ var Zone_z2 = ZoneHuanan

+ func BlockCount(fsize int64) int

+ func EncodedEntry(bucket, key string) string

+ func EncodedEntryWithoutKey(bucket string) string

+ func IsContextExpired(blkPut BlkputRet) bool

+ func MakePrivateURL(mac *auth.Credentials, domain, key string, deadline int64) (privateURL string)

+ func MakePublicURL(domain, key string) (finalUrl string)

+ func ParsePutTime(putTime int64) (t time.Time)

+ func SetAppName(userApp string) error

+ func SetRegionCachePath(newPath string)

+ func SetSettings(v *Settings)

+ func URIChangeMime(bucket, key, newMime string) string

+ func URIChangeType(bucket, key string, fileType int) string

+ func URICopy(srcBucket, srcKey, destBucket, destKey string, force bool) string

+ func URIDelete(bucket, key string) string

+ func URIDeleteAfterDays(bucket, key string, days int) string

+ func URIMove(srcBucket, srcKey, destBucket, destKey string, force bool) string

+ func URIRestoreAr(bucket, key string, afterDay int) string

+ func URIStat(bucket, key string) string

+ type AsyncFetchParam struct

+ Bucket string

+ CallbackBody string

+ CallbackBodyType string

+ CallbackURL string

+ Etag string

+ FileType int

+ Host string

+ Key string

+ Md5 string

+ Url string

+ type AsyncFetchRet struct

+ Id string

+ Wait int

+ type Base64PutExtra struct

+ MimeType string

+ Params map[string]string

+ type Base64Uploader struct

+ func NewBase64Uploader(cfg *Config) *Base64Uploader

+ func NewBase64UploaderEx(cfg *Config, clt *client.Client) *Base64Uploader

+ func (p *Base64Uploader) Put(ctx context.Context, ret interface{}, uptoken, key string, base64Data []byte, ...) (err error)

+ func (p *Base64Uploader) PutWithoutKey(ctx context.Context, ret interface{}, uptoken string, base64Data []byte, ...) (err error)

+ type BatchOpRet struct

+ Code int

+ Data struct{ ... }

+ type BlkputRet struct

+ Checksum string

+ Crc32 uint32

+ Ctx string

+ ExpiredAt int64

+ Host string

+ Offset uint32

+ type BucketEventRule struct

+ AccessKey string

+ CallbackURL []string

+ Event []string

+ Host string

+ Name string

+ Prefix string

+ Suffix string

+ func (r *BucketEventRule) Params(bucket string) map[string][]string

+ type BucketInfo struct

+ AntiLeechMode int

+ EnableSource bool

+ Expires int

+ Host string

+ MacKey string

+ MacKey2 string

+ MaxAge int

+ NoIndexPage int

+ NoRefer bool

+ Private int

+ Protected int

+ ReferBl []string

+ ReferWl []string

+ Region string

+ Separator string

+ Source string

+ Styles map[string]string

+ TokenAntiLeechMode int

+ Zone string

+ func (b *BucketInfo) BlackListSet() bool

+ func (b *BucketInfo) ImageSources() (srcs []string)

+ func (b *BucketInfo) IndexPageOn() bool

+ func (b *BucketInfo) IsPrivate() bool

+ func (b *BucketInfo) ProtectedOn() bool

+ func (b *BucketInfo) Separators() (ret []rune)

+ func (b *BucketInfo) TokenAntiLeechModeOn() bool

+ func (b *BucketInfo) WhiteListSet() bool

+ type BucketLifeCycleRule struct

+ DeleteAfterDays int

+ Name string

+ Prefix string

+ ToLineAfterDays int

+ type BucketManager struct

+ Cfg *Config

+ Client *client.Client

+ Mac *auth.Credentials

+ func NewBucketManager(mac *auth.Credentials, cfg *Config) *BucketManager

+ func NewBucketManagerEx(mac *auth.Credentials, cfg *Config, clt *client.Client) *BucketManager

+ func (m *BucketManager) AddBucketEvent(bucket string, rule *BucketEventRule) (err error)

+ func (m *BucketManager) AddBucketLifeCycleRule(bucketName string, lifeCycleRule *BucketLifeCycleRule) (err error)

+ func (m *BucketManager) AddCorsRules(bucket string, corsRules []CorsRule) (err error)

+ func (m *BucketManager) ApiHost(bucket string) (apiHost string, err error)

+ func (m *BucketManager) ApiReqHost(bucket string) (reqHost string, err error)

+ func (m *BucketManager) AsyncFetch(param AsyncFetchParam) (ret AsyncFetchRet, err error)

+ func (m *BucketManager) Batch(operations []string) (batchOpRet []BatchOpRet, err error)

+ func (m *BucketManager) BucketInfosInRegion(region RegionID, statistics bool) (bucketInfos []BucketSummary, err error)

+ func (m *BucketManager) Buckets(shared bool) (buckets []string, err error)

+ func (m *BucketManager) ChangeMime(bucket, key, newMime string) (err error)

+ func (m *BucketManager) ChangeType(bucket, key string, fileType int) (err error)

+ func (m *BucketManager) ClearTagging(bucket string) error

+ func (m *BucketManager) Copy(srcBucket, srcKey, destBucket, destKey string, force bool) (err error)

+ func (m *BucketManager) CreateBucket(bucketName string, regionID RegionID) error

+ func (m *BucketManager) DelBucketEvent(bucket, ruleName string) (err error)

+ func (m *BucketManager) DelBucketLifeCycleRule(bucketName, ruleName string) (err error)

+ func (m *BucketManager) Delete(bucket, key string) (err error)

+ func (m *BucketManager) DeleteAfterDays(bucket, key string, days int) (err error)

+ func (m *BucketManager) DropBucket(bucketName string) (err error)

+ func (m *BucketManager) Fetch(resURL, bucket, key string) (fetchRet FetchRet, err error)

+ func (m *BucketManager) FetchWithoutKey(resURL, bucket string) (fetchRet FetchRet, err error)

+ func (m *BucketManager) GetBucketEvent(bucket string) (rule []BucketEventRule, err error)

+ func (m *BucketManager) GetBucketInfo(bucketName string) (bucketInfo BucketInfo, err error)

+ func (m *BucketManager) GetBucketLifeCycleRule(bucketName string) (rules []BucketLifeCycleRule, err error)

+ func (m *BucketManager) GetBucketQuota(bucket string) (quota BucketQuota, err error)

+ func (m *BucketManager) GetCorsRules(bucket string) (corsRules []CorsRule, err error)

+ func (m *BucketManager) GetTagging(bucket string) (tags map[string]string, err error)

+ func (m *BucketManager) IoReqHost(bucket string) (reqHost string, err error)

+ func (m *BucketManager) IovipHost(bucket string) (iovipHost string, err error)

+ func (m *BucketManager) ListBucket(bucket, prefix, delimiter, marker string) (retCh chan listFilesRet2, err error)

+ func (m *BucketManager) ListBucketContext(ctx context.Context, bucket, prefix, delimiter, marker string) (retCh chan listFilesRet2, err error)

+ func (m *BucketManager) ListBucketDomains(bucket string) (info []DomainInfo, err error)

+ func (m *BucketManager) ListFiles(bucket, prefix, delimiter, marker string, limit int) (entries []ListItem, commonPrefixes []string, nextMarker string, hasNext bool, ...)

+ func (m *BucketManager) MakeBucketPrivate(bucket string) error

+ func (m *BucketManager) MakeBucketPublic(bucket string) error

+ func (m *BucketManager) Move(srcBucket, srcKey, destBucket, destKey string, force bool) (err error)

+ func (m *BucketManager) Prefetch(bucket, key string) (err error)

+ func (m *BucketManager) RestoreAr(bucket, key string, freezeAfterDays int) (err error)

+ func (m *BucketManager) RsHost(bucket string) (rsHost string, err error)

+ func (m *BucketManager) RsReqHost(bucket string) (reqHost string, err error)

+ func (m *BucketManager) RsfHost(bucket string) (rsfHost string, err error)

+ func (m *BucketManager) RsfReqHost(bucket string) (reqHost string, err error)

+ func (m *BucketManager) SetBucketAccessMode(bucket string, mode int) error

+ func (m *BucketManager) SetBucketAccessStyle(bucket string, mode int) error

+ func (m *BucketManager) SetBucketMaxAge(bucket string, maxAge int64) error

+ func (m *BucketManager) SetBucketQuota(bucket string, size, count int64) (err error)

+ func (m *BucketManager) SetImage(siteURL, bucket string) (err error)

+ func (m *BucketManager) SetImageWithHost(siteURL, bucket, host string) (err error)

+ func (m *BucketManager) SetReferAntiLeechMode(bucketName string, refererAntiLeechConfig *ReferAntiLeechConfig) (err error)

+ func (m *BucketManager) SetTagging(bucket string, tags map[string]string) error

+ func (m *BucketManager) Stat(bucket, key string) (info FileInfo, err error)

+ func (m *BucketManager) TurnOffBucketProtected(bucket string) error

+ func (m *BucketManager) TurnOffIndexPage(bucket string) error

+ func (m *BucketManager) TurnOnBucketProtected(bucket string) error

+ func (m *BucketManager) TurnOnIndexPage(bucket string) error

+ func (m *BucketManager) UnsetImage(bucket string) (err error)

+ func (m *BucketManager) UpdateBucketEnvent(bucket string, rule *BucketEventRule) (err error)

+ func (m *BucketManager) UpdateBucketLifeCycleRule(bucketName string, rule *BucketLifeCycleRule) (err error)

+ func (m *BucketManager) UpdateObjectStatus(bucketName string, key string, enable bool) error

+ func (m *BucketManager) Zone(bucket string) (z *Zone, err error)

+ type BucketQuota struct

+ Count int64

+ Size int64

+ type BucketSummary struct

+ Info BucketInfo

+ Name string

+ type BucketTag struct

+ Key string

+ Value string

+ type BucketTagging struct

+ Tags []BucketTag

+ type Chunk struct

+ BlkSize int

+ Body io.ReadSeeker

+ Created bool

+ Err error

+ Index int

+ Ret *BlkputRet

+ func (b *Chunk) ChunkLength() (int, error)

+ func (b *Chunk) Reset() error

+ func (b *Chunk) ResetBody() error

+ func (b *Chunk) ShouldRetry() bool

+ type ChunkPutRetryer interface

+ Retry func(ck *Chunk)

+ type Client = client.Client

+ type Config struct

+ ApiHost string

+ CentralRsHost string

+ IoHost string

+ Region *Region

+ RsHost string

+ RsfHost string

+ UpHost string

+ UseCdnDomains bool

+ UseHTTPS bool

+ Zone *Region

+ func (c *Config) ApiReqHost() string

+ func (c *Config) GetRegion() *Region

+ func (c *Config) RsReqHost() string

+ func (c *Config) RsfReqHost() string

+ type CorsRule struct

+ AllowedHeader []string

+ AllowedMethod []string

+ AllowedOrigin []string

+ ExposedHeader []string

+ MaxAge int64

+ type DomainInfo struct

+ Ctime int

+ Domain string

+ Owner int

+ Refresh bool

+ Tbl string

+ Utime int

+ type ErrorInfo = client.ErrorInfo

+ type FetchRet struct

+ Fsize int64

+ Hash string

+ Key string

+ MimeType string

+ func (r *FetchRet) String() string

+ type FileInfo struct

+ Fsize int64

+ Hash string

+ MimeType string

+ PutTime int64

+ Type int

+ func (f *FileInfo) String() string

+ type FileRecorder struct

+ func NewFileRecorder(directoryPath string) (fileRecorder *FileRecorder, err error)

+ func (fileRecorder *FileRecorder) Delete(key string) error

+ func (fileRecorder *FileRecorder) GenerateRecorderKey(keyInfos []string, sourceFileInfo os.FileInfo) string

+ func (fileRecorder *FileRecorder) Get(key string) ([]byte, error)

+ func (fileRecorder *FileRecorder) Set(key string, data []byte) error

+ type FopResult struct

+ Cmd string

+ Code int

+ Desc string

+ Error string

+ Hash string

+ Key string

+ Keys []string

+ type FormUploader struct

+ Cfg *Config

+ Client *client.Client

+ func NewFormUploader(cfg *Config) *FormUploader

+ func NewFormUploaderEx(cfg *Config, clt *client.Client) *FormUploader

+ func (p *FormUploader) Put(ctx context.Context, ret interface{}, uptoken, key string, data io.Reader, ...) (err error)

+ func (p *FormUploader) PutFile(ctx context.Context, ret interface{}, uptoken, key, localFile string, ...) (err error)

+ func (p *FormUploader) PutFileWithoutKey(ctx context.Context, ret interface{}, uptoken, localFile string, ...) (err error)

+ func (p *FormUploader) PutWithoutKey(ctx context.Context, ret interface{}, uptoken string, data io.Reader, ...) (err error)

+ func (p *FormUploader) UpHost(ak, bucket string) (upHost string, err error)

+ type InitPartsRet struct

+ UploadID string

+ type ListItem struct

+ EndUser string

+ Fsize int64

+ Hash string

+ Key string

+ MimeType string

+ PutTime int64

+ Type int

+ func (l *ListItem) IsEmpty() (empty bool)

+ func (l *ListItem) String() string

+ type OperationManager struct

+ Cfg *Config

+ Client *client.Client

+ Mac *auth.Credentials

+ func NewOperationManager(mac *auth.Credentials, cfg *Config) *OperationManager

+ func NewOperationManagerEx(mac *auth.Credentials, cfg *Config, clt *client.Client) *OperationManager

+ func (m *OperationManager) ApiHost(bucket string) (apiHost string, err error)

+ func (m *OperationManager) Pfop(bucket, key, fops, pipeline, notifyURL string, force bool) (persistentID string, err error)

+ func (m *OperationManager) Prefop(persistentID string) (ret PrefopRet, err error)

+ func (m *OperationManager) PrefopApiHost(persistentID string) (apiHost string)

+ type PfopRet struct

+ PersistentID string

+ type PrefopRet struct

+ Code int

+ Desc string

+ ID string

+ InputBucket string

+ InputKey string

+ Items []FopResult

+ Pipeline string

+ Reqid string

+ func (r *PrefopRet) String() string

+ type PutExtra struct

+ MimeType string

+ OnProgress func(fsize, uploaded int64)

+ Params map[string]string

+ UpHost string

+ type PutPolicy struct

+ CallbackBody string

+ CallbackBodyType string

+ CallbackFetchKey uint8

+ CallbackHost string

+ CallbackURL string

+ DeleteAfterDays int

+ DetectMime uint8

+ EndUser string

+ Expires uint64

+ FileType int

+ ForceSaveKey bool

+ FsizeLimit int64

+ FsizeMin int64

+ InsertOnly uint16

+ IsPrefixalScope int

+ MimeLimit string

+ PersistentNotifyURL string

+ PersistentOps string

+ PersistentPipeline string

+ ReturnBody string

+ ReturnURL string

+ SaveKey string

+ Scope string

+ func (p *PutPolicy) UploadToken(cred *auth.Credentials) (token string)

+ type PutRet struct

+ Hash string

+ Key string

+ PersistentID string

+ type Recorder interface

+ Delete func(key string) error

+ GenerateRecorderKey func(keyInfos []string, sourceFileInfo os.FileInfo) string

+ Get func(key string) ([]byte, error)

+ Set func(key string, data []byte) error

+ type ReferAntiLeechConfig struct

+ AllowEmptyReferer bool

+ EnableSource bool

+ Mode int

+ Pattern string

+ func (r *ReferAntiLeechConfig) AddDomainPattern(pattern string) *ReferAntiLeechConfig

+ func (r *ReferAntiLeechConfig) AsQueryString() string

+ func (r *ReferAntiLeechConfig) SetEmptyReferer(enable bool) *ReferAntiLeechConfig

+ func (r *ReferAntiLeechConfig) SetEnableSource(enable bool) *ReferAntiLeechConfig

+ func (r *ReferAntiLeechConfig) SetMode(mode int) *ReferAntiLeechConfig

+ func (r *ReferAntiLeechConfig) SetPattern(pattern string) *ReferAntiLeechConfig

+ type Region struct

+ ApiHost string

+ CdnUpHosts []string

+ IovipHost string

+ RsHost string

+ RsfHost string

+ SrcUpHosts []string

+ func GetRegion(ak, bucket string) (*Region, error)

+ func GetRegionByID(regionID RegionID) (Region, bool)

+ func (r *Region) GetApiHost(useHttps bool) string

+ func (r *Region) GetIoHost(useHttps bool) string

+ func (r *Region) GetRsHost(useHttps bool) string

+ func (r *Region) GetRsfHost(useHttps bool) string

+ func (r *Region) String() string

+ type RegionID string

+ type RegionInfo struct

+ Description string

+ ID string

+ func GetRegionsInfo(mac *auth.Credentials) ([]RegionInfo, error)

+ type ResumeUploader struct

+ Cfg *Config

+ Client *client.Client

+ func NewResumeUploader(cfg *Config) *ResumeUploader

+ func NewResumeUploaderEx(cfg *Config, clt *client.Client) *ResumeUploader

+ func (p *ResumeUploader) Bput(ctx context.Context, upToken string, ret *BlkputRet, body io.Reader, size int) error

+ func (p *ResumeUploader) Mkblk(ctx context.Context, upToken string, upHost string, ret *BlkputRet, ...) error

+ func (p *ResumeUploader) Mkfile(ctx context.Context, upToken string, upHost string, ret interface{}, ...) (err error)

+ func (p *ResumeUploader) Put(ctx context.Context, ret interface{}, upToken string, key string, ...) error

+ func (p *ResumeUploader) PutFile(ctx context.Context, ret interface{}, upToken, key, localFile string, ...) error

+ func (p *ResumeUploader) PutFileWithoutKey(ctx context.Context, ret interface{}, upToken, localFile string, ...) error

+ func (p *ResumeUploader) PutWithoutKey(ctx context.Context, ret interface{}, upToken string, f io.ReaderAt, ...) error

+ func (p *ResumeUploader) PutWithoutSize(ctx context.Context, ret interface{}, upToken, key string, r io.Reader, ...) error

+ func (p *ResumeUploader) UpHost(ak, bucket string) (upHost string, err error)

+ type ResumeUploaderV2 struct

+ Cfg *Config

+ Client *client.Client

+ func NewResumeUploaderV2(cfg *Config) *ResumeUploaderV2

+ func NewResumeUploaderV2Ex(cfg *Config, clt *client.Client) *ResumeUploaderV2

+ func (p *ResumeUploaderV2) CompleteParts(ctx context.Context, upToken, upHost string, ret interface{}, ...) (err error)

+ func (p *ResumeUploaderV2) InitParts(ctx context.Context, upToken, upHost, bucket, key string, hasKey bool, ...) error

+ func (p *ResumeUploaderV2) Put(ctx context.Context, ret interface{}, upToken string, key string, ...) error

+ func (p *ResumeUploaderV2) PutFile(ctx context.Context, ret interface{}, upToken, key, localFile string, ...) error

+ func (p *ResumeUploaderV2) PutFileWithoutKey(ctx context.Context, ret interface{}, upToken, localFile string, ...) error

+ func (p *ResumeUploaderV2) PutWithoutKey(ctx context.Context, ret interface{}, upToken string, f io.ReaderAt, ...) error

+ func (p *ResumeUploaderV2) PutWithoutSize(ctx context.Context, ret interface{}, upToken, key string, r io.Reader, ...) error

+ func (p *ResumeUploaderV2) UpHost(ak, bucket string) (upHost string, err error)

+ func (p *ResumeUploaderV2) UploadParts(ctx context.Context, upToken, upHost, bucket, key string, hasKey bool, ...) error

+ type RputExtra struct

+ ChunkSize int

+ MimeType string

+ Notify func(blkIdx int, blkSize int, ret *BlkputRet)

+ NotifyErr func(blkIdx int, blkSize int, err error)

+ Params map[string]string

+ Progresses []BlkputRet

+ Recorder Recorder

+ TryTimes int

+ UpHost string

+ type RputV2Extra struct

+ CustomVars map[string]string

+ Metadata map[string]string

+ MimeType string

+ Notify func(partNumber int64, ret *UploadPartsRet)

+ NotifyErr func(partNumber int64, err error)

+ PartSize int64

+ Recorder Recorder

+ TryTimes int

+ UpHost string

+ type Settings struct

+ ChunkSize int

+ PartSize int64

+ TaskQsize int

+ TryTimes int

+ Workers int

+ type UcQueryRet struct

+ Io map[string]map[string][]string

+ TTL int

+ Up map[string]UcQueryUp

+ type UcQueryUp struct

+ Backup []string

+ Info string

+ Main []string

+ type UploadPartsRet struct

+ Etag string

+ MD5 string

+ type Zone = Region

+ func GetZone(ak, bucket string) (zone *Zone, err error)

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