Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.