sos

Jun 29, 2023

Changes in this version

+ func GetCommonPrefixDeduplicator(stream bool) func([]types.CommonPrefix) []string

type Client

+ func (c *Client) ListObjectsFunc(bucket, prefix string, recursive, stream bool) listFunc[object.ObjectInterface]

+ func (c *Client) ListObjectsVersions(ctx context.Context, list listFunc[object.ObjectVersionInterface], ...) (*object.ListObjectsOutput, error)

+ func (c *Client) ListVersionedObjectsFunc(bucket, prefix string, recursive, stream bool) listFunc[object.ObjectVersionInterface]

+ type ObjectListing struct

+ CommonPrefixes []string

+ List []ObjectType

type S3API

+ ListObjectVersions func(ctx context.Context, params *s3.ListObjectVersionsInput, ...) (*s3.ListObjectVersionsOutput, error)

Jun 2, 2023

Changes in this version

+ var ClientNewUploaderDefaultFunc = s3manager.NewUploader

type Client

+ NewUploaderFunc func(client s3manager.UploadAPIClient, options ...func(*s3manager.Uploader)) Uploader

+ S3Client S3API

+ Zone string

+ func (c *Client) BucketVersioningStatus(ctx context.Context, bucket string) (output.Outputter, error)

+ func (c *Client) EnableBucketVersioning(ctx context.Context, bucket string) error

+ func (c *Client) GetBucketVersioning(ctx context.Context, bucket string) (types.BucketVersioningStatus, error)

+ func (c *Client) NewUploader(client s3manager.UploadAPIClient, options ...func(*s3manager.Uploader)) Uploader

+ func (c *Client) SuspendBucketVersioning(ctx context.Context, bucket string) error

+ func (c Client) GetBucketObjectOwnershipInfo(ctx context.Context, bucket string) (output.Outputter, error)

+ type S3API interface

+ AbortMultipartUpload func(ctx context.Context, params *s3.AbortMultipartUploadInput, ...) (*s3.AbortMultipartUploadOutput, error)

+ CopyObject func(ctx context.Context, params *s3.CopyObjectInput, optFns ...func(*s3.Options)) (*s3.CopyObjectOutput, error)

+ CreateBucket func(ctx context.Context, params *s3.CreateBucketInput, optFns ...func(*s3.Options)) (*s3.CreateBucketOutput, error)

+ DeleteBucket func(ctx context.Context, params *s3.DeleteBucketInput, optFns ...func(*s3.Options)) (*s3.DeleteBucketOutput, error)

+ DeleteBucketCors func(ctx context.Context, params *s3.DeleteBucketCorsInput, ...) (*s3.DeleteBucketCorsOutput, error)

+ DeleteObjects func(ctx context.Context, params *s3.DeleteObjectsInput, ...) (*s3.DeleteObjectsOutput, error)

+ GetBucketAcl func(ctx context.Context, params *s3.GetBucketAclInput, optFns ...func(*s3.Options)) (*s3.GetBucketAclOutput, error)

+ GetBucketCors func(ctx context.Context, params *s3.GetBucketCorsInput, ...) (*s3.GetBucketCorsOutput, error)

+ GetBucketOwnershipControls func(ctx context.Context, params *s3.GetBucketOwnershipControlsInput, ...) (*s3.GetBucketOwnershipControlsOutput, error)

+ GetBucketVersioning func(ctx context.Context, params *s3.GetBucketVersioningInput, ...) (*s3.GetBucketVersioningOutput, error)

+ GetObject func(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)

+ GetObjectAcl func(ctx context.Context, params *s3.GetObjectAclInput, optFns ...func(*s3.Options)) (*s3.GetObjectAclOutput, error)

+ ListMultipartUploads func(ctx context.Context, params *s3.ListMultipartUploadsInput, ...) (*s3.ListMultipartUploadsOutput, error)

+ ListObjectsV2 func(ctx context.Context, params *s3.ListObjectsV2Input, ...) (*s3.ListObjectsV2Output, error)

+ PutBucketAcl func(ctx context.Context, params *s3.PutBucketAclInput, optFns ...func(*s3.Options)) (*s3.PutBucketAclOutput, error)

+ PutBucketCors func(ctx context.Context, params *s3.PutBucketCorsInput, ...) (*s3.PutBucketCorsOutput, error)

+ PutBucketOwnershipControls func(ctx context.Context, params *s3.PutBucketOwnershipControlsInput, ...) (*s3.PutBucketOwnershipControlsOutput, error)

+ PutBucketVersioning func(ctx context.Context, params *s3.PutBucketVersioningInput, ...) (*s3.PutBucketVersioningOutput, error)

+ PutObjectAcl func(ctx context.Context, params *s3.PutObjectAclInput, optFns ...func(*s3.Options)) (*s3.PutObjectAclOutput, error)

type ShowBucketOutput

+ ObjectOwnership BucketObjectOwnership

type StorageUploadConfig

+ ACL string

+ type Uploader interface

+ Upload func(ctx context.Context, input *s3.PutObjectInput, ...) (*s3manager.UploadOutput, error)

May 2, 2023

Changes in this version

+ const ACLGranteeAllUsers

+ const ACLGranteeAuthenticatedUsers

+ const BucketPrefix

+ const MetadataForbiddenCharset

+ const ObjectHeaderCacheControl

+ const ObjectHeaderContentDisposition

+ const ObjectHeaderContentEncoding

+ const ObjectHeaderContentLanguage

+ const ObjectHeaderContentType

+ const ObjectHeaderExpires

+ const SetACLCmdFlagFullControl

+ const SetACLCmdFlagRead

+ const SetACLCmdFlagReadACP

+ const SetACLCmdFlagWrite

+ const SetACLCmdFlagWriteACP

+ const TimestampFormat

+ var CommonConfigOptFns []func(*awsconfig.LoadOptions) error

+ func BucketCannedACLToStrings() []string

+ func ObjectCannedACLToStrings() []string

+ func ObjectHeadersFromS3(o *s3.GetObjectOutput) map[string]string

+ type ACL struct

+ Canned string

+ FullControl string

+ Read string

+ ReadACP string

+ Write string

+ WriteACP string

+ func ACLFromS3(grants []s3types.Grant) ACL

+ type BucketObjectOwnership string

+ const ObjectOwnershipBucketOwnerEnforced

+ const ObjectOwnershipBucketOwnerPreferred

+ const ObjectOwnershipObjectWriter

+ type CORSRule struct

+ AllowedHeaders []string

+ AllowedMethods []string

+ AllowedOrigins []string

+ func CORSRulesFromS3(v *s3.GetBucketCorsOutput) []CORSRule

+ type Client struct

+ func NewStorageClient(ctx context.Context, opts ...ClientOpt) (*Client, error)

+ func (c *Client) AddBucketCORSRule(ctx context.Context, bucket string, cors *CORSRule) error

+ func (c *Client) AddObjectMetadata(ctx context.Context, bucket, key string, metadata map[string]string) error

+ func (c *Client) AddObjectsMetadata(ctx context.Context, bucket, prefix string, metadata map[string]string, ...) error

+ func (c *Client) CopyObject(ctx context.Context, bucket, key string) (*s3.CopyObjectInput, error)

+ func (c *Client) CreateNewBucket(ctx context.Context, name, acl string) error

+ func (c *Client) DeleteBucketCORS(ctx context.Context, bucket string) error

+ func (c *Client) DeleteObjectHeaders(ctx context.Context, bucket, key string, headers []string) error

+ func (c *Client) DeleteObjectMetadata(ctx context.Context, bucket, key string, mdKeys []string) error

+ func (c *Client) DeleteObjects(ctx context.Context, bucket, prefix string, recursive bool) ([]s3types.DeletedObject, error)

+ func (c *Client) DeleteObjectsHeaders(ctx context.Context, bucket, prefix string, headers []string, recursive bool) error

+ func (c *Client) DeleteObjectsMetadata(ctx context.Context, bucket, prefix string, mdKeys []string, recursive bool) error

+ func (c *Client) DownloadFile(ctx context.Context, bucket string, object *s3types.Object, dst string) error

+ func (c *Client) DownloadFiles(ctx context.Context, config *DownloadConfig) error

+ func (c *Client) EstimatePartSize(f *os.File) (int64, error)

+ func (c *Client) ForEachObject(ctx context.Context, bucket, prefix string, recursive bool, ...) error

+ func (c *Client) GenPresignedURL(ctx context.Context, method, bucket, key string, expires time.Duration) (string, error)

+ func (c *Client) ListObjects(ctx context.Context, bucket, prefix string, recursive, stream bool) (output.Outputter, error)

+ func (c *Client) SetBucketACL(ctx context.Context, bucket string, acl *ACL) error

+ func (c *Client) SetObjectACL(ctx context.Context, bucket, key string, acl *ACL) error

+ func (c *Client) SetObjectsACL(ctx context.Context, bucket, prefix string, acl *ACL, recursive bool) error

+ func (c *Client) ShowBucket(ctx context.Context, bucket string) (output.Outputter, error)

+ func (c *Client) ShowObject(ctx context.Context, bucket, key string) (output.Outputter, error)

+ func (c *Client) UpdateObjectHeaders(ctx context.Context, bucket, key string, headers map[string]*string) error

+ func (c *Client) UpdateObjectsHeaders(ctx context.Context, bucket, prefix string, headers map[string]*string, ...) error

+ func (c *Client) UploadFile(ctx context.Context, bucket, file, key, acl string) error

+ func (c *Client) UploadFiles(ctx context.Context, sources []string, config *StorageUploadConfig) error

+ func (c Client) DeleteBucket(ctx context.Context, bucket string, recursive bool) error

+ func (c Client) GetBucketObjectOwnership(ctx context.Context, bucket string) (output.Outputter, error)

+ func (c Client) SetBucketObjectOwnership(ctx context.Context, bucket string, ownership BucketObjectOwnership) error

+ type ClientOpt func(*Client) error

+ func ClientOptWithZone(zone string) ClientOpt

+ func ClientOptZoneFromBucket(ctx context.Context, bucket string) ClientOpt

+ type DownloadConfig struct

+ Bucket string

+ Destination string

+ DryRun bool

+ Objects []*s3types.Object

+ Overwrite bool

+ Prefix string

+ Recursive bool

+ Source string

+ type ListBucketsItemOutput struct

+ Created string

+ Name string

+ Size int64

+ Zone string

+ type ListBucketsOutput []ListBucketsItemOutput

+ func (o *ListBucketsOutput) ToJSON()

+ func (o *ListBucketsOutput) ToTable()

+ func (o *ListBucketsOutput) ToText()

+ type ListObjectsItemOutput struct

+ Dir bool

+ LastModified string

+ Path string

+ Size int64

+ type ListObjectsOutput []ListObjectsItemOutput

+ func (o *ListObjectsOutput) ToJSON()

+ func (o *ListObjectsOutput) ToTable()

+ func (o *ListObjectsOutput) ToText()

+ type ShowBucketOutput struct

+ ACL ACL

+ CORS []CORSRule

+ Name string

+ Zone string

+ func (o *ShowBucketOutput) ToJSON()

+ func (o *ShowBucketOutput) ToTable()

+ func (o *ShowBucketOutput) ToText()

+ type ShowObjectOutput struct

+ ACL ACL

+ Bucket string

+ Headers map[string]string

+ LastModified string

+ Metadata map[string]string

+ Path string

+ Size int64

+ URL string

+ func (o *ShowObjectOutput) ToJSON()

+ func (o *ShowObjectOutput) ToTable()

+ func (o *ShowObjectOutput) ToText()

+ type StorageUploadConfig struct

+ Acl string

+ Bucket string

+ DryRun bool

+ Prefix string

+ Recursive bool