miniogw

Apr 3, 2019

Changes in this version

+ var Error = errs.Class("Storj Gateway error")

+ func Logging(gateway minio.Gateway, log *zap.Logger) minio.Gateway

+ type Gateway struct

+ func NewStorjGateway(metainfo storj.Metainfo, streams streams.Store, pathCipher storj.Cipher, ...) *Gateway

+ func (gateway *Gateway) Name() string

+ func (gateway *Gateway) NewGatewayLayer(creds auth.Credentials) (minio.ObjectLayer, error)

+ func (gateway *Gateway) Production() bool

+ type MinioConfig struct

+ AccessKey string

+ Dir string

+ SecretKey string

+ type MultipartStream struct

+ func NewMultipartStream() *MultipartStream

+ func (stream *MultipartStream) Abort(err error)

+ func (stream *MultipartStream) AddPart(partID int, data *hash.Reader) (*StreamPart, error)

+ func (stream *MultipartStream) Close()

+ func (stream *MultipartStream) Read(data []byte) (n int, err error)

+ type MultipartUpload struct

+ Bucket string

+ Done chan (*MultipartUploadResult)

+ ID string

+ Metadata map[string]string

+ Object string

+ Stream *MultipartStream

+ func NewMultipartUpload(uploadID string, bucket, object string, metadata map[string]string) *MultipartUpload

+ type MultipartUploadResult struct

+ Error error

+ Info minio.ObjectInfo

+ type MultipartUploads struct

+ func NewMultipartUploads() *MultipartUploads

+ func (uploads *MultipartUploads) Create(bucket, object string, metadata map[string]string) (*MultipartUpload, error)

+ func (uploads *MultipartUploads) Get(bucket, object, uploadID string) (*MultipartUpload, error)

+ func (uploads *MultipartUploads) Remove(bucket, object, uploadID string) (*MultipartUpload, error)

+ func (uploads *MultipartUploads) RemoveByID(uploadID string)

+ type ServerConfig struct

+ Address string

+ type StreamPart struct

+ Done chan error

+ ID int

+ Number int

+ Reader *hash.Reader

+ Size int64