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

storage

package

Go to main page

Versions in this module

v7

v7.8.2

Feb 1, 2021

v7.8.1

Jan 7, 2021

Changes in this version

+ const RIDFogCnEast1

+ var ZoneFogCnEast1 = GetRegionByID(RIDFogCnEast1)

+ var Zone_fog_cn_east_1 = ZoneFogCnEast1

+ func SetRegionCachePath(newPath string)

v7.8.0

Dec 7, 2020

Changes in this version

+ 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 InitPartsRet struct

+ UploadID 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 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

+ Recorder Recorder

+ 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

+ PartSize int64

+ type UploadPartsRet struct

+ Etag string

+ MD5 string

v7.7.0

Nov 27, 2020

v7.6.0

Sep 4, 2020

v7.5.0

May 8, 2020

v7.4.2

Apr 26, 2020

Changes in this version

+ const DefaultAPIHost

+ const DefaultPubHost

+ const DefaultRsHost

+ const DefaultRsfHost

+ const ErrChunkUpCanceled

+ const ErrMaxUpRetry

+ const ErrNextReader

+ const ErrUploadChunkFailed

+ const InvalidCtx

+ 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 ZoneHuabei = GetRegionByID(RIDHuabei)

+ var ZoneHuadong = GetRegionByID(RIDHuadong)

+ var ZoneHuanan = GetRegionByID(RIDHuanan)

+ var ZoneXinjiapo = GetRegionByID(RIDSingapore)

+ var Zone_as0 = ZoneXinjiapo

+ 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 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 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 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 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 *Region, err 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, ...) (err error)

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

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

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

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

+ func (p *ResumeUploader) UpHost(ak, bucket string) (upHost string, err 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

+ TryTimes int

+ UpHost string

+ type Settings struct

+ ChunkSize int

+ 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 Zone = Region

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

v7.4.1

Dec 9, 2019

v7.4.0

Oct 30, 2019

Other modules containing this package

github.com/qiniu/api.v7