datastore

package

v0.0.0-...-3925406 Latest Latest Go to latest Published: Jan 8, 2018 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ObjectStorage struct {
	// contains filtered or unexported fields
}

ObjectStorage stores s3 objects

func NewObjectStorage(s3DataFolder string) *ObjectStorage

NewObjectStorage returns new ObjectStorage

func (o *ObjectStorage) DeleteObject(bucket, objectKey string) error

DeleteObject deletes an object

func (o *ObjectStorage) GetObjectFilePath(bucket, objectKey string) string

GetObjectFilePath returns absolute path to a object. Will return empty string if file not found or is not a file

func (o *ObjectStorage) MergeParts(bucket, objectKey, uploadID string, partStorage *PartStorage) error

MergeParts merges upload parts to create a new object

func (o *ObjectStorage) PutObject(bucket, objectKey string, source io.Reader) error

PutObject stores an object

type PartStorage struct {
	// contains filtered or unexported fields
}

PartStorage stores multipart upload parts

func NewPartStorage(s3DataFolder string) *PartStorage

NewPartStorage returns new PartStorage

func (ps *PartStorage) MergeParts(uploadID string, sink io.Writer) error

MergeParts merges all parts of an upload and write to a sink

func (ps *PartStorage) StorePart(uploadID string, partNumber int, source io.Reader) error

StorePart stores a part to the storage