s3stream

Documentation

Index

• type S3StreamStorage
  • func NewS3StreamStorage(awsNoSign bool, ...) *S3StreamStorage
  • func (st *S3StreamStorage) DeleteObject(obj *storage.Object) error
  • func (st *S3StreamStorage) GetObjectACL(obj *storage.Object) error
  • func (st *S3StreamStorage) GetObjectContent(obj *storage.Object) error
  • func (st *S3StreamStorage) GetObjectMeta(obj *storage.Object) error
  • func (st *S3StreamStorage) List(output chan<- *storage.Object) error
  • func (st *S3StreamStorage) PutObject(obj *storage.Object) error
  • func (st *S3StreamStorage) WithContext(ctx context.Context)
  • func (st *S3StreamStorage) WithRateLimit(limit int) error

Types

type S3StreamStorage

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

S3StreamStorage configuration.

func NewS3StreamStorage

func NewS3StreamStorage(awsNoSign bool, awsAccessKey, awsSecretKey, awsToken, awsRegion, endpoint, bucketName, prefix string, keysPerReq int64, retryCnt uint, retryDelay time.Duration) *S3StreamStorage

NewS3Storage return new configured S3 storage.

You should always create new storage with this constructor.

func (*S3StreamStorage) DeleteObject

func (st *S3StreamStorage) DeleteObject(obj *storage.Object) error

DeleteObject remove object from S3.

func (*S3StreamStorage) GetObjectACL

func (st *S3StreamStorage) GetObjectACL(obj *storage.Object) error

GetObjectACL read object ACL from S3.

func (*S3StreamStorage) GetObjectContent

func (st *S3StreamStorage) GetObjectContent(obj *storage.Object) error

GetObjectContent read object content and metadata from S3.

func (*S3StreamStorage) GetObjectMeta

func (st *S3StreamStorage) GetObjectMeta(obj *storage.Object) error

GetObjectMeta update object metadata from S3.

func (*S3StreamStorage) List

func (st *S3StreamStorage) List(output chan<- *storage.Object) error

List S3 bucket and send founded objects to chan.

func (*S3StreamStorage) PutObject

func (st *S3StreamStorage) PutObject(obj *storage.Object) error

PutObject saves object to S3. PutObject ignore VersionId, it always save object as latest version.

func (*S3StreamStorage) WithContext

func (st *S3StreamStorage) WithContext(ctx context.Context)

WithContext add's context to storage.

func (*S3StreamStorage) WithRateLimit

func (st *S3StreamStorage) WithRateLimit(limit int) error

WithRateLimit set rate limit (bytes/sec) for storage.