Documentation ¶
Index ¶
- type AwsS3Adapter
- func (a *AwsS3Adapter) BucketClear(name string) (err error)
- func (a *AwsS3Adapter) BucketCreate(name string, wait bool) (err error)
- func (a *AwsS3Adapter) BucketDelete(name string, wait bool) (err error)
- func (a *AwsS3Adapter) BucketItemDelete(name string, key string, wait bool) (err error)
- func (a *AwsS3Adapter) BucketItemDownload(bucket string, key string, body io.WriterAt) (bytes int64, err error)
- func (a *AwsS3Adapter) BucketItemDownloadBytes(bucket string, key string) ([]byte, error)
- func (a *AwsS3Adapter) BucketItemDownloadFile(bucket string, key string, path string) (numBytes int64, err error)
- func (a *AwsS3Adapter) BucketItemList(name string, prefix string) ([]*s3.Object, error)
- func (a *AwsS3Adapter) BucketItemUpload(bucket string, key string, body io.Reader) (err error)
- func (a *AwsS3Adapter) BucketList() (response []string, err error)
- func (a *AwsS3Adapter) Close() error
- func (a *AwsS3Adapter) Setup() (err error)
- type AwsS3Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AwsS3Adapter ¶
type AwsS3Adapter struct { *adapter.BaseAdapter // contains filtered or unexported fields }
func NewAwsS3Adapter ¶
func NewAwsS3Adapter(name string, config *AwsS3Config) *AwsS3Adapter
func (*AwsS3Adapter) BucketClear ¶
func (a *AwsS3Adapter) BucketClear(name string) (err error)
func (*AwsS3Adapter) BucketCreate ¶
func (a *AwsS3Adapter) BucketCreate(name string, wait bool) (err error)
func (*AwsS3Adapter) BucketDelete ¶
func (a *AwsS3Adapter) BucketDelete(name string, wait bool) (err error)
func (*AwsS3Adapter) BucketItemDelete ¶
func (a *AwsS3Adapter) BucketItemDelete(name string, key string, wait bool) (err error)
func (*AwsS3Adapter) BucketItemDownload ¶
func (*AwsS3Adapter) BucketItemDownloadBytes ¶
func (a *AwsS3Adapter) BucketItemDownloadBytes(bucket string, key string) ([]byte, error)
func (*AwsS3Adapter) BucketItemDownloadFile ¶
func (*AwsS3Adapter) BucketItemList ¶
func (*AwsS3Adapter) BucketItemUpload ¶
func (*AwsS3Adapter) BucketList ¶
func (a *AwsS3Adapter) BucketList() (response []string, err error)
func (*AwsS3Adapter) Close ¶
func (a *AwsS3Adapter) Close() error
func (*AwsS3Adapter) Setup ¶
func (a *AwsS3Adapter) Setup() (err error)
type AwsS3Config ¶
type AwsS3Config struct { Endpoint string `json:"Endpoint,omitempty" config:"Endpoint"` AccessKeyID string `json:"AccessKeyID,omitempty" config:"AccessKeyID"` SecretAccessKey string `json:"SecretAccessKey,omitempty" config:"SecretAccessKey"` SessionToken string `json:"SessionToken,omitempty" config:"SessionToken"` Region string `json:"Region,omitempty" config:"Region,required"` }
Click to show internal directories.
Click to hide internal directories.