storage

Apr 22, 2016

Changes in this version

+ const MaxConcurrentRequests

+ var UnknownBucket = errors.New("storage: URL missing bucket name")

+ var UnknownScheme = errors.New("storage: URL missing gs:// scheme")

+ func FixPrefix(p string) string

+ func NextPrefix(name string) string

+ func SortObjects(objs []*storage.Object)

+ func Sync(ctx context.Context, src, dst *Bucket) error

+ type Bucket struct

+ func NewBucket(client *http.Client, bucketURL string) (*Bucket, error)

+ func (b *Bucket) Copy(ctx context.Context, src *storage.Object, dstName string) error

+ func (b *Bucket) Delete(ctx context.Context, objName string) error

+ func (b *Bucket) Fetch(ctx context.Context) error

+ func (b *Bucket) FetchPrefix(ctx context.Context, prefix string, recursive bool) error

+ func (b *Bucket) Len() int

+ func (b *Bucket) Name() string

+ func (b *Bucket) Object(objName string) *storage.Object

+ func (b *Bucket) Objects() []*storage.Object

+ func (b *Bucket) Prefix() string

+ func (b *Bucket) Prefixes() []string

+ func (b *Bucket) URL() *url.URL

+ func (b *Bucket) Upload(ctx context.Context, obj *storage.Object, media io.ReadSeeker) error

+ func (b *Bucket) WriteAlways(always bool)

+ func (b *Bucket) WriteDryRun(dryrun bool)

+ type Error struct

+ Err error

+ Op string

+ URL string

+ func (e *Error) Error() string

+ type Filter func(*gs.Object) bool

+ type ObjectSlice []*storage.Object

+ func (objs ObjectSlice) Len() int

+ func (objs ObjectSlice) Less(i, j int) bool

+ func (objs ObjectSlice) Swap(i, j int)

+ type SyncJob struct

+ Destination *Bucket

+ Source *Bucket

+ func (sj *SyncJob) Delete(enable bool)

+ func (sj *SyncJob) DeleteFilter(f Filter)

+ func (sj *SyncJob) DestinationPrefix(p string)

+ func (sj *SyncJob) Do(ctx context.Context) error

+ func (sj *SyncJob) Recursive(enable bool)

+ func (sj *SyncJob) SourceFilter(f Filter)

+ func (sj *SyncJob) SourcePrefix(p string)