Documentation
¶
Index ¶
- Variables
- func CheckResponse(resp *http.Response) error
- func FGetObject(bucket BasicBucket, objectKey string, localFilePath string) error
- func FGetObjectWithURL(signedURL, localFilePath string, timeout time.Duration) error
- func FPutObject(ctx context.Context, bucket BasicBucket, objectKey string, ...) error
- func FPutObjectWithURL(signedURL, localFilePath string, timeout time.Duration) error
- func GetConfig(options ...Option) *config
- func GetObjectWithURL(signedURL string, timeout time.Duration) (io.ReadCloser, *http.Response, error)
- func HeadObjectWithURL(signedURL string, timeout time.Duration) (http.Header, error)
- func PutObjectWithURL(signedURL string, reader io.Reader, timeout time.Duration) (*http.Response, error)
- type ACLType
- type BasicBucket
- type BasicClient
- type BucketProperties
- type CompletePart
- type MultipartUploadAbleBucket
- type MultipartUploadPresignAbleBucket
- type ObjectMeta
- type ObjectProperty
- type Option
- type Part
- type PresignAbleBucket
- type PresignPostAbleBucket
- type Upload
Constants ¶
This section is empty.
Variables ¶
View Source
var BucketNotExist = errors.New("bucket doesn't exist")
Functions ¶
func CheckResponse ¶
func FGetObject ¶
func FGetObject(bucket BasicBucket, objectKey string, localFilePath string) error
func FGetObjectWithURL ¶
func FPutObject ¶
func FPutObjectWithURL ¶
func GetObjectWithURL ¶
func HeadObjectWithURL ¶
Types ¶
type ACLType ¶
type ACLType string
ACLType bucket/object ACL
const ( // ACLPrivate definition : private read and write ACLPrivate ACLType = "private" // ACLPublicRead definition : public read and private write ACLPublicRead ACLType = "public-read" // ACLPublicReadWrite definition : public read and public write ACLPublicReadWrite ACLType = "public-read-write" // ACLDefault Object. It's only applicable for object. ACLDefault ACLType = "default" )
type BasicBucket ¶
type BasicBucket interface {
GetObject(objectKey string) (io.ReadCloser, error)
HeadObject(objectKey string) (object ObjectMeta, err error)
ListObjects(objectPrefix string) (objects []ObjectProperty, err error)
PutObject(objectKey string, reader io.Reader) error
CopyObject(srcObjectKey, dstObjectKey string) error
RemoveObject(objectKey string) error
RemoveObjects(objectKeys []string) error
}
type BasicClient ¶
type BasicClient interface {
Bucket(bucketName string) (bucket BasicBucket, err error)
MakeBucket(bucketName string, options ...Option) error
HeadBucket(bucketName string) error
GetBucketLocation(bucketName string) (location string, err error)
ListBucket(options ...Option) (buckets []BucketProperties, err error)
RemoveBucket(bucketName string) error
CopyObject(srcBucketName, srcObjectKey, dstBucketName, dstObjectKey string) error
}
type BucketProperties ¶
type CompletePart ¶
type MultipartUploadAbleBucket ¶
type MultipartUploadAbleBucket interface {
ListMultipartUploads(objectKeyPrefix string) (uploads []Upload, err error)
InitMultipartUpload(objectKey string) (uploadId string, err error)
UploadPart(objectKey, uploadId string, partNum int, reader io.ReadSeeker) (eTag string, err error)
ListParts(objectKey string, uploadId string) (parts []Part, err error)
CompleteUploadPart(objectKey string, uploadId string, parts []CompletePart) error
AbortMultipartUpload(objectKey string, uploadId string) error
}
type ObjectMeta ¶
func HeaderToObjectMeta ¶
func HeaderToObjectMeta(header http.Header) (objectMeta ObjectMeta, err error)
type ObjectProperty ¶
type ObjectProperty struct {
ObjectMeta
ObjectKey string
}
type PresignAbleBucket ¶
type PresignAbleBucket interface {
PresignGetObject(objectKey string, expiresIn time.Duration) (signedURL string, err error)
PresignHeadObject(objectKey string, expiresIn time.Duration) (signedURL string, err error)
PresignPutObject(objectKey string, expiresIn time.Duration) (signedURL string, err error)
}
type PresignPostAbleBucket ¶
Click to show internal directories.
Click to hide internal directories.