Versions in this module Expand all Collapse all v1 v1.6.0 Aug 29, 2018 Changes in this version + func DumpRequest(req *http.Request, body bool) string + func DumpResponse(resp *http.Response, body bool) string + func GetMimeType(filename string) string + type Bucket struct + CreationDate time.Time + Name string + func (b Bucket) String() string + type BucketListing struct + Buckets []Bucket + Owner Owner + type CommonPrefix struct + Prefix string + func (prefix CommonPrefix) String() string + type CompleteMultipartUploadResult struct + Bucket string + ETag string + Key string + Location string + type DefaultHTTPClient struct + func (client *DefaultHTTPClient) Do(req *http.Request) (resp *http.Response, err error) + type DefaultStorageClient struct + Config StorageClientConfig + HTTPClient NewHTTPClient + Logger *log.Logger + func (cli *DefaultStorageClient) AbortMultipartUpload(upload *MultipartUpload) error + func (cli *DefaultStorageClient) CompleteMultipartUpload(upload *MultipartUpload, parts []*Part) (res *CompleteMultipartUploadResult, err error) + func (cli *DefaultStorageClient) DeleteBucket(bucket string) error + func (cli *DefaultStorageClient) DeleteBucketPolicy(bucket string) error + func (cli *DefaultStorageClient) DeleteMultipleObjects(bucket string, keys []string, quiet bool) (res *MultipleDeletionResult, err error) + func (cli *DefaultStorageClient) DeleteObject(bucket, key string) (err error) + func (cli *DefaultStorageClient) Do(req *http.Request, result interface{}) (resp *http.Response, err error) + func (cli *DefaultStorageClient) DoAndRetry(fn func() (*http.Request, error), result interface{}) (resp *http.Response, err error) + func (cli *DefaultStorageClient) DoesBucketExist(bucket string) (result bool, err error) + func (cli *DefaultStorageClient) DoesObjectExist(bucket, key string) (bool, error) + func (cli *DefaultStorageClient) GetBucketPolicy(bucket string) (policy io.ReadCloser, err error) + func (cli *DefaultStorageClient) GetNetworkTraffic(date string) (traffic *DownTraffic, err error) + func (cli *DefaultStorageClient) GetObject(bucket, key string) (r io.ReadCloser, err error) + func (cli *DefaultStorageClient) GetObjectMetadata(bucket, key string) (o *Object, err error) + func (cli *DefaultStorageClient) GetObjectSummary(bucket, key string) (os *ObjectSummary, err error) + func (cli *DefaultStorageClient) GetStorageSpace() (usage *StorageSpace, err error) + func (cli *DefaultStorageClient) InitiateMultipartUpload(bucket, key string, metadata *ObjectMetadata) (res *MultipartUpload, err error) + func (cli *DefaultStorageClient) ListBuckets() (listing *BucketListing, err error) + func (cli *DefaultStorageClient) ListMultipartUploads(bucket, prefix, keyMarker, uploadIdMarker, delimiter string, maxUploads int) (listing *MultipartUploadListing, err error) + func (cli *DefaultStorageClient) ListNetworkTraffics(backwardTo int) (result *ListTrafficResult, err error) + func (cli *DefaultStorageClient) ListObjects(bucket, prefix, marker, delimiter string, maxKeys int) (listing *ObjectListing, err error) + func (cli *DefaultStorageClient) ListParts(bucket, key, uploadId string, partNumberMarker, maxParts int) (listing *PartListing, err error) + func (cli *DefaultStorageClient) NewListObjectsRequest(bucket, prefix, marker, delimiter string, maxKeys int) (*http.Request, error) + func (cli *DefaultStorageClient) NextListMultipartUploads(prev *MultipartUploadListing) (listing *MultipartUploadListing, err error) + func (cli *DefaultStorageClient) NextListObjects(listing *ObjectListing) (*ObjectListing, error) + func (cli *DefaultStorageClient) NextListParts(prev *PartListing) (listing *PartListing, err error) + func (cli *DefaultStorageClient) PutBucket(bucket string) error + func (cli *DefaultStorageClient) PutBucketPolicy(bucket string, r io.Reader) error + func (cli *DefaultStorageClient) PutObject(bucket, key string, f *os.File, metadata *ObjectMetadata) error + func (cli *DefaultStorageClient) PutObjectAt(bucket, key string, f *os.File, off, n int64, metadata *ObjectMetadata) error + func (cli *DefaultStorageClient) ResumeUploadFile(bucket, key, uploadId string, fd *os.File, metadata *ObjectMetadata) (err error) + func (cli *DefaultStorageClient) Sign(req *http.Request) error + func (cli *DefaultStorageClient) Upload(bucket, key string, r io.Reader, metadata *ObjectMetadata) (err error) + func (cli *DefaultStorageClient) UploadFile(bucket, key string, fd *os.File, metadata *ObjectMetadata) (err error) + func (cli *DefaultStorageClient) UploadPart(upload *MultipartUpload, num int, f *os.File) (p *Part, err error) + func (cli *DefaultStorageClient) UploadPartAt(upload *MultipartUpload, num int, f *os.File, off, n int64) (p *Part, err error) + type DeletedObject struct + Key string + type DigestReader struct + func (r DigestReader) Digest() []byte + func (r DigestReader) Read(p []byte) (n int, err error) + type DownTraffic struct + Amount int64 + ChargeDate string + type ErrorResponse struct + Code string + ErrorCode int + Message string + RequestID string + Resource string + XMLName xml.Name + func (e ErrorResponse) Error() string + type HTTPClient interface + Do func(req *http.Request) (resp *http.Response, err error) + func NewDefaultHTTPClient(cli *DefaultStorageClient) HTTPClient + type ListTrafficResult struct + DownTraffics []*DownTraffic + XMLName xml.Name + type MockHTTPClient struct + func NewMockHTTPClient(ctrl *gomock.Controller) *MockHTTPClient + func (m *MockHTTPClient) Do(req *http.Request) (*http.Response, error) + func (m *MockHTTPClient) EXPECT() *MockHTTPClientMockRecorder + type MockHTTPClientMockRecorder struct + func (mr *MockHTTPClientMockRecorder) Do(req interface{}) *gomock.Call + type MockStorageClient struct + func NewMockStorageClient(ctrl *gomock.Controller) *MockStorageClient + func (m *MockStorageClient) AbortMultipartUpload(upload *MultipartUpload) error + func (m *MockStorageClient) CompleteMultipartUpload(upload *MultipartUpload, parts []*Part) (*CompleteMultipartUploadResult, error) + func (m *MockStorageClient) DeleteBucket(bucket string) error + func (m *MockStorageClient) DeleteBucketPolicy(bucket string) error + func (m *MockStorageClient) DeleteMultipleObjects(bucket string, keys []string, quiet bool) (*MultipleDeletionResult, error) + func (m *MockStorageClient) DeleteObject(bucket, key string) error + func (m *MockStorageClient) DoesBucketExist(bucket string) (bool, error) + func (m *MockStorageClient) DoesObjectExist(bucket, key string) (bool, error) + func (m *MockStorageClient) EXPECT() *MockStorageClientMockRecorder + func (m *MockStorageClient) GetBucketPolicy(bucket string) (io.ReadCloser, error) + func (m *MockStorageClient) GetNetworkTraffic(date string) (*DownTraffic, error) + func (m *MockStorageClient) GetObject(bucket, key string) (io.ReadCloser, error) + func (m *MockStorageClient) GetObjectMetadata(bucket, key string) (*Object, error) + func (m *MockStorageClient) GetObjectSummary(bucket, key string) (*ObjectSummary, error) + func (m *MockStorageClient) GetStorageSpace() (*StorageSpace, error) + func (m *MockStorageClient) InitiateMultipartUpload(bucket, key string, metadata *ObjectMetadata) (*MultipartUpload, error) + func (m *MockStorageClient) ListBuckets() (*BucketListing, error) + func (m *MockStorageClient) ListMultipartUploads(bucket, prefix, keyMarker, uploadIdMarker, delimiter string, maxUploads int) (*MultipartUploadListing, error) + func (m *MockStorageClient) ListNetworkTraffics(backwardTo int) (*ListTrafficResult, error) + func (m *MockStorageClient) ListObjects(bucket, prefix, marker, delimiter string, maxKeys int) (*ObjectListing, error) + func (m *MockStorageClient) ListParts(bucket, key, uploadId string, partNumberMarker, maxParts int) (*PartListing, error) + func (m *MockStorageClient) NextListMultipartUploads(previous *MultipartUploadListing) (*MultipartUploadListing, error) + func (m *MockStorageClient) NextListObjects(previous *ObjectListing) (*ObjectListing, error) + func (m *MockStorageClient) NextListParts(previous *PartListing) (*PartListing, error) + func (m *MockStorageClient) PutBucket(bucket string) error + func (m *MockStorageClient) PutBucketPolicy(bucket string, policy io.Reader) error + func (m *MockStorageClient) PutObject(bucket, key string, data *os.File, metadata *ObjectMetadata) error + func (m *MockStorageClient) PutObjectAt(bucket, key string, data *os.File, off, length int64, metadata *ObjectMetadata) error + func (m *MockStorageClient) ResumeUploadFile(bucket, key, uploadId string, fd *os.File, metadata *ObjectMetadata) error + func (m *MockStorageClient) Sign(req *http.Request) error + func (m *MockStorageClient) Upload(bucket, key string, data io.Reader, metadata *ObjectMetadata) error + func (m *MockStorageClient) UploadFile(bucket, key string, fd *os.File, metadata *ObjectMetadata) error + func (m *MockStorageClient) UploadPart(upload *MultipartUpload, num int, data *os.File) (*Part, error) + func (m *MockStorageClient) UploadPartAt(upload *MultipartUpload, num int, data *os.File, off, length int64) (*Part, error) + type MockStorageClientMockRecorder struct + func (mr *MockStorageClientMockRecorder) AbortMultipartUpload(upload interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) CompleteMultipartUpload(upload, parts interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) DeleteBucket(bucket interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) DeleteBucketPolicy(bucket interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) DeleteMultipleObjects(bucket, keys, quiet interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) DeleteObject(bucket, key interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) DoesBucketExist(bucket interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) DoesObjectExist(bucket, key interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) GetBucketPolicy(bucket interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) GetNetworkTraffic(date interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) GetObject(bucket, key interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) GetObjectMetadata(bucket, key interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) GetObjectSummary(bucket, key interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) GetStorageSpace() *gomock.Call + func (mr *MockStorageClientMockRecorder) InitiateMultipartUpload(bucket, key, metadata interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) ListBuckets() *gomock.Call + func (mr *MockStorageClientMockRecorder) ListMultipartUploads(bucket, prefix, keyMarker, uploadIdMarker, delimiter, maxUploads interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) ListNetworkTraffics(backwardTo interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) ListObjects(bucket, prefix, marker, delimiter, maxKeys interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) ListParts(bucket, key, uploadId, partNumberMarker, maxParts interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) NextListMultipartUploads(previous interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) NextListObjects(previous interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) NextListParts(previous interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) PutBucket(bucket interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) PutBucketPolicy(bucket, policy interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) PutObject(bucket, key, data, metadata interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) PutObjectAt(bucket, key, data, off, length, metadata interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) ResumeUploadFile(bucket, key, uploadId, fd, metadata interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) Sign(req interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) Upload(bucket, key, data, metadata interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) UploadFile(bucket, key, fd, metadata interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) UploadPart(upload, num, data interface{}) *gomock.Call + func (mr *MockStorageClientMockRecorder) UploadPartAt(upload, num, data, off, length interface{}) *gomock.Call + type MultipartUpload struct + Bucket string + Key string + UploadID string + func (m *MultipartUpload) String() string + type MultipartUploadListing struct + Bucket string + CommonPrefixes []string + Delimiter string + IsTruncated bool + KeyMarker string + MaxUploads int + NextKeyMarker string + NextUploadIdMarker string + Prefix string + UploadIdMarker string + Uploads []MultipartUploadSummary + func (listing *MultipartUploadListing) IsEmpty() bool + func (listing *MultipartUploadListing) String() string + type MultipartUploadSummary struct + Initiated time.Time + Initiator Owner + Key string + Owner Owner + StorageClass string + UploadId string + func (summary *MultipartUploadSummary) String() string + type MultipleDeletionError struct + Code string + Key string + Message string + func (e *MultipleDeletionError) Error() string + func (e *MultipleDeletionError) String() string + type MultipleDeletionResult struct + DeletedObjects []DeletedObject + Errors []MultipleDeletionError + func (res *MultipleDeletionResult) HasErrors() bool + type NewHTTPClient func(cli *DefaultStorageClient) HTTPClient + type Object struct + Bucket string + ETag string + Key string + LastModified time.Time + Metadata *ObjectMetadata + Size int64 + type ObjectListing struct + CommonPrefixes []CommonPrefix + Delimiter string + IsTruncated bool + Marker string + MaxKeys int + Name string + NextMarker string + Prefix string + Summaries []ObjectSummary + func (listing *ObjectListing) IsEmpty() bool + func (listing *ObjectListing) String() string + type ObjectMetadata struct + CacheControl string + ContentDisposition string + ContentEncoding string + ContentLength int64 + ContentMD5 string + ContentType string + UserMetadata *UserMetadata + WebsiteRedirectLocation string + func (m *ObjectMetadata) AddUserMetadata(name string, value string) + func (m *ObjectMetadata) GetUserMetadata(key string) string + func (m *ObjectMetadata) SetMetadata(h http.Header) + func (m *ObjectMetadata) String() string + type ObjectSummary struct + ETag string + Key string + LastModified time.Time + Owner Owner + Size int64 + StorageClass string + func (s ObjectSummary) String() string + type Owner struct + DisplayName string + ID string + func (o Owner) String() string + type Part struct + ETag string + PartNumber int + func (p Part) String() string + type PartDescription struct + LastModified time.Time + Size int64 + type PartListing struct + Bucket string + Initiator Owner + IsTruncated bool + Key string + MaxParts int + NextPartNumberMarker int + Owner Owner + PartNumberMarker int + Parts []PartDescription + StorageClass string + UploadId string + func (listing *PartListing) IsEmpty() bool + func (listing *PartListing) String() string + func (listing PartListing) GetPart(partNumber int) *PartDescription + type StorageClient interface + AbortMultipartUpload func(upload *MultipartUpload) error + CompleteMultipartUpload func(upload *MultipartUpload, parts []*Part) (*CompleteMultipartUploadResult, error) + DeleteBucket func(bucket string) error + DeleteBucketPolicy func(bucket string) error + DeleteMultipleObjects func(bucket string, keys []string, quiet bool) (*MultipleDeletionResult, error) + DeleteObject func(bucket, key string) error + DoesBucketExist func(bucket string) (bool, error) + DoesObjectExist func(bucket, key string) (bool, error) + GetBucketPolicy func(bucket string) (io.ReadCloser, error) + GetNetworkTraffic func(date string) (*DownTraffic, error) + GetObject func(bucket, key string) (io.ReadCloser, error) + GetObjectMetadata func(bucket, key string) (*Object, error) + GetObjectSummary func(bucket, key string) (*ObjectSummary, error) + GetStorageSpace func() (*StorageSpace, error) + InitiateMultipartUpload func(bucket, key string, metadata *ObjectMetadata) (*MultipartUpload, error) + ListBuckets func() (*BucketListing, error) + ListMultipartUploads func(bucket, prefix, keyMarker, uploadIdMarker, delimiter string, maxUploads int) (*MultipartUploadListing, error) + ListNetworkTraffics func(backwardTo int) (*ListTrafficResult, error) + ListObjects func(bucket, prefix, marker, delimiter string, maxKeys int) (*ObjectListing, error) + ListParts func(bucket, key, uploadId string, partNumberMarker, maxParts int) (*PartListing, error) + NextListMultipartUploads func(previous *MultipartUploadListing) (*MultipartUploadListing, error) + NextListObjects func(previous *ObjectListing) (*ObjectListing, error) + NextListParts func(previous *PartListing) (*PartListing, error) + PutBucket func(bucket string) error + PutBucketPolicy func(bucket string, policy io.Reader) error + PutObject func(bucket, key string, data *os.File, metadata *ObjectMetadata) error + PutObjectAt func(bucket, key string, data *os.File, off, length int64, metadata *ObjectMetadata) error + ResumeUploadFile func(bucket, key, uploadId string, fd *os.File, metadata *ObjectMetadata) error + Sign func(req *http.Request) error + Upload func(bucket, key string, data io.Reader, metadata *ObjectMetadata) error + UploadFile func(bucket, key string, fd *os.File, metadata *ObjectMetadata) error + UploadPart func(upload *MultipartUpload, num int, data *os.File) (*Part, error) + UploadPartAt func(upload *MultipartUpload, num int, data *os.File, off, length int64) (*Part, error) + func NewStorageClient(env *env.Environment) (StorageClient, error) + type StorageClientConfig struct + AbortOnFailure bool + AccessKeyID string + Endpoint string + MultipartChunkSize int64 + Proxy string + Retry int + RetryInterval time.Duration + SecretAccessKey string + Secure bool + TempDir string + Vendor string + type StorageSpace struct + AccountUsed int64 + ContractUsed int64 + XMLName xml.Name + type UserMetadata map[string][]string + func (um *UserMetadata) Add(name string, value string) + func (um *UserMetadata) String() string