blobstore

Aug 3, 2018

Changes in this version

+ type SwiftParams struct

+ AuthURL string

+ Bucket string

+ EndpointURL string

+ Region string

+ Secret string

+ Tenant string

+ Username string

May 16, 2018

Changes in this version

+ var ErrBadParams = errgo.New("bad parameters")

+ var ErrNotFound = errgo.New("blob not found")

+ func NewHash() hash.Hash

+ type Backend interface

+ Get func(name string) (r ReadSeekCloser, size int64, err error)

+ Put func(name string, r io.Reader, size int64, hash string) error

+ Remove func(name string) error

+ func NewMongoBackend(db *mgo.Database, prefix string) Backend

+ func NewSwiftBackend(cred *identity.Credentials, authmode identity.AuthMode, container string) Backend

+ type Part struct

+ Hash string

+ type PartInfo struct

+ Complete bool

+ Hash string

+ Offset int64

+ Size int64

+ type ReadSeekCloser interface

+ type Refs struct

+ func NewRefs(n int) *Refs

+ func (r *Refs) Add(hash string)

+ type Store struct

+ MaxPartSize int64

+ MaxParts int

+ MinPartSize int64

+ func New(db *mgo.Database, prefix string, backend Backend) *Store

+ func (s *Store) FinishUpload(uploadId string, parts []Part) (idx *mongodoc.MultipartIndex, hash string, err error)

+ func (s *Store) GC(refs *Refs, before time.Time) (monitoring.BlobStats, error)

+ func (s *Store) NewUpload(expires time.Time) (uploadId string, err error)

+ func (s *Store) Open(hash string, index *mongodoc.MultipartIndex) (ReadSeekCloser, int64, error)

+ func (s *Store) Put(r io.Reader, hash string, size int64) error

+ func (s *Store) PutAtTime(r io.Reader, hash string, size int64, now time.Time) error

+ func (s *Store) PutPart(uploadId string, part int, r io.Reader, size, offset int64, hash string) error

+ func (s *Store) RemoveExpiredUploads() error

+ func (s *Store) RemoveUpload(uploadId string) error

+ func (s *Store) SetOwner(uploadId, owner string, expires time.Time) error

+ func (s *Store) UploadInfo(uploadId string) (UploadInfo, error)

+ type UploadInfo struct

+ Expires time.Time

+ Hash string

+ Parts []*PartInfo

+ func (info *UploadInfo) Index() (*mongodoc.MultipartIndex, bool)