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.