Documentation
¶
Index ¶
- Constants
- func AwsIteratorFunc(ac *conf.AppConfig, fol objectify.FileObjList, grp int) (iter provider.Iterator, err error)
- type AwsIterator
- func (ai *AwsIterator) Err() (err error)
- func (ai *AwsIterator) Final() (err error)
- func (ai *AwsIterator) First() (err error)
- func (ai *AwsIterator) MarkFailed(s string)
- func (ai *AwsIterator) MarkIgnore(s string)
- func (ai *AwsIterator) Next() bool
- func (ai *AwsIterator) Prepare() *provider.PutObject
- type AwsOperator
- func (op *AwsOperator) BucketExists() (exists bool, errs provider.Errs)
- func (op *AwsOperator) CreateBucket() (err error)
- func (op *AwsOperator) MultipartAbort() (err error)
- func (op *AwsOperator) MultipartFinalize() (err error)
- func (op *AwsOperator) MultipartParallelize() (err error)
- func (op *AwsOperator) MultipartUpload(i int) (complete bool, output *s3.UploadPartOutput, err error)
- func (op *AwsOperator) ObjectExists(key string) (exists bool, err error)
- func (op *AwsOperator) SupportsMultipartUploads() bool
- func (op *AwsOperator) Upload(po provider.PutObject) (err error)
- func (op *AwsOperator) UploadMultipart(po provider.PutObject) (err error)
- type MultipartControl
Constants ¶
View Source
const ( EmptyString = "" ErrorCouldNotAssertObject = "could not assert object as *s3.PutObjectInput" ErrorNotImplemented = "not implemented" )
Variables ¶
This section is empty.
Functions ¶
func AwsIteratorFunc ¶
Types ¶
type AwsIterator ¶
type AwsIterator struct {
// contains filtered or unexported fields
}
func NewIterator ¶
func NewIterator(ac *conf.AppConfig, fol objectify.FileObjList, grp int) (iter *AwsIterator, err error)
func (*AwsIterator) Err ¶
func (ai *AwsIterator) Err() (err error)
func (*AwsIterator) Final ¶
func (ai *AwsIterator) Final() (err error)
func (*AwsIterator) First ¶
func (ai *AwsIterator) First() (err error)
func (*AwsIterator) MarkFailed ¶
func (ai *AwsIterator) MarkFailed(s string)
func (*AwsIterator) MarkIgnore ¶
func (ai *AwsIterator) MarkIgnore(s string)
func (*AwsIterator) Next ¶
func (ai *AwsIterator) Next() bool
func (*AwsIterator) Prepare ¶
func (ai *AwsIterator) Prepare() *provider.PutObject
type AwsOperator ¶
type AwsOperator struct {
// contains filtered or unexported fields
}
func NewAwsOperator ¶
func NewAwsOperator(ac *conf.AppConfig) (*AwsOperator, error)
func (*AwsOperator) BucketExists ¶
func (op *AwsOperator) BucketExists() (exists bool, errs provider.Errs)
func (*AwsOperator) CreateBucket ¶
func (op *AwsOperator) CreateBucket() (err error)
func (*AwsOperator) MultipartAbort ¶
func (op *AwsOperator) MultipartAbort() (err error)
func (*AwsOperator) MultipartFinalize ¶
func (op *AwsOperator) MultipartFinalize() (err error)
func (*AwsOperator) MultipartParallelize ¶
func (op *AwsOperator) MultipartParallelize() (err error)
func (*AwsOperator) MultipartUpload ¶
func (op *AwsOperator) MultipartUpload(i int) (complete bool, output *s3.UploadPartOutput, err error)
func (*AwsOperator) ObjectExists ¶
func (op *AwsOperator) ObjectExists(key string) (exists bool, err error)
func (*AwsOperator) SupportsMultipartUploads ¶
func (op *AwsOperator) SupportsMultipartUploads() bool
func (*AwsOperator) UploadMultipart ¶
func (op *AwsOperator) UploadMultipart(po provider.PutObject) (err error)
type MultipartControl ¶
type MultipartControl struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.