tos

package

Go to main page

Versions in this module

v2

v2.7.9

Jan 27, 2025

Changes in this version

+ const HeaderTrashPath

+ const QueryRecursive

+ func SupportedControlRegion() map[string]string

type ClientOption

+ func WithControlEndpoint(controlEndpoint string) ClientOption

type ClientV2

+ func (cli *ClientV2) DeleteQosPolicy(ctx context.Context, input *DeleteQosPolicyInput) (*DeleteQosPolicyOutput, error)

+ func (cli *ClientV2) GetQosPolicy(ctx context.Context, input *GetQosPolicyInput) (*GetQosPolicyOutput, error)

+ func (cli *ClientV2) PutQosPolicy(ctx context.Context, input *PutQosPolicyInput) (*PutQosPolicyOutput, error)

type DeleteMultiObjectsInput

+ Recursive bool

type DeleteObjectOutput

+ TrashPath string

type DeleteObjectV2Input

+ Recursive bool

+ type DeleteQosPolicyInput struct

+ AccountID string

+ type DeleteQosPolicyOutput struct

type DeletedV2

+ TrashPath string

type GetFileStatusOutput

+ Etag string

+ type GetQosPolicyInput struct

+ AccountID string

+ type GetQosPolicyOutput struct

+ Policy string

type ListedCommonPrefix

+ LastModified *time.Time

type NoCurrentVersionExpiration

+ NonCurrentDate *time.Time

type NonCurrentVersionTransition

+ NonCurrentDate *time.Time

+ type PutQosPolicyInput struct

+ AccountID string

+ Policy string

+ type PutQosPolicyOutput struct

type RenameObjectInput

+ RecursiveMkdir bool

v2.7.8

Nov 26, 2024

v2.7.7

Sep 23, 2024

v2.7.6

Sep 19, 2024

v2.7.5

Sep 10, 2024

Changes in this version

type GetObjectAclOutput

+ BucketOwnerEntrusted bool

+ IsDefault bool

type ObjectAclRules

+ BucketOwnerEntrusted bool

v2.7.4

Sep 6, 2024

Changes in this version

+ const HeaderSymlinkTarget

+ const HeaderSymlinkTargetBucket

+ const HeaderSymlinkTargetSize

+ const HeaderTaggingCount

+ const HeaderTosExpiration

type AppendObjectV2Input

+ ObjectExpires int64

type Bucket

+ func (bkt *Bucket) GetSymlink(ctx context.Context, input *GetSymlinkInput, option ...Option) (*GetSymlinkOutput, error)

+ func (bkt *Bucket) PutSymlink(ctx context.Context, input *PutSymlinkInput, option ...Option) (*PutSymlinkOutput, error)

type Client

+ func (cli *Client) GetBucketACL(ctx context.Context, input *GetBucketACLInput, option ...Option) (*GetBucketACLOutput, error)

+ func (cli *Client) PutBucketACL(ctx context.Context, input *PutBucketACLInput, option ...Option) (*PutBucketACLOutput, error)

type ClientV2

+ func (cli *ClientV2) GetSymlink(ctx context.Context, input *GetSymlinkInput) (*GetSymlinkOutput, error)

+ func (cli *ClientV2) PutSymlink(ctx context.Context, input *PutSymlinkInput) (*PutSymlinkOutput, error)

type CopyObjectInput

+ ObjectExpires int64

+ Tagging string

+ TaggingDirective enum.TaggingDirectiveType

type CreateMultipartUploadV2Input

+ ObjectExpires int64

+ Tagging string

type GetBucketACLOutput

+ BucketAclDelivered bool

type GetObjectACLOutput

+ IsDefault bool

+ type GetSymlinkInput struct

+ Bucket string

+ Key string

+ VersionID string

+ type GetSymlinkOutput struct

+ LastModified time.Time

+ SymlinkTargetBucket string

+ SymlinkTargetKey string

+ VersionID string

type HeadObjectOutput

+ SymlinkTargetSize int64

type HeadObjectV2Output

+ SymlinkTargetSize int64

type ListedObject

+ ObjectType string

type ListedObjectV2

+ ObjectType string

type ListedObjectVersion

+ ObjectType string

type ListedObjectVersionV2

+ ObjectType string

type ObjectAclRules

+ IsDefault bool

type ObjectMetaV2

+ Expiration string

+ TaggingCount int64

type PutBucketACLInput

+ BucketAclDelivered bool

type PutObjectACLInput

+ IsDefault bool

type PutObjectBasicInput

+ ObjectExpires int64

+ Tagging string

+ type PutSymlinkInput struct

+ ACL enum.ACLType

+ Bucket string

+ CacheControl string

+ ContentDisposition string

+ ContentLanguage string

+ ContentType string

+ Expires time.Time

+ ForbidOverwrite bool

+ Key string

+ Meta map[string]string

+ StorageClass enum.StorageClassType

+ SymlinkTargetBucket string

+ SymlinkTargetKey string

+ Tagging string

+ type PutSymlinkOutput struct

+ VersionID string

v2.7.3

Aug 28, 2024

v2.7.2

Aug 8, 2024

Changes in this version

+ const HeaderBucketType

+ const HeaderDirectory

+ const HeaderHashCrc32C

+ const HeaderNextModifyOffset

+ type CommonSourceEndpoint struct

+ Follower []EndpointCredentialProvider

+ Primary []EndpointCredentialProvider

type Condition

+ AllowHost []string

+ HttpMethod []string

type CreateBucketV2Input

+ BucketType enum.BucketType

+ type CredentialProvider struct

+ Role string

+ type EndpointCredentialProvider struct

+ BucketName string

+ CredentialProvider *CredentialProvider

+ Endpoint string

type HeadBucketOutput

+ BucketType enum.BucketType

type ListBucketsInput

+ BucketType enum.BucketType

type ListedBucket

+ BucketType enum.BucketType

type MirrorHeader

+ Set []MirrorHeaderKeyValue

+ type MirrorHeaderKeyValue struct

+ Key string

+ Value string

type ObjectMeta

+ IsDirectory bool

type ObjectMetaV2

+ IsDirectory bool

+ type PrivateSource struct

+ SourceEndpoint CommonSourceEndpoint

type Redirect

+ FetchSourceOnRedirectWithQuery *bool

+ PrivateSource *PrivateSource

type SetObjectMetaInput

+ ObjectExpires int64

type UnexpectedStatusCodeError

+ func (us *UnexpectedStatusCodeError) WithEC(Ec string) *UnexpectedStatusCodeError

v2.7.0

Jul 4, 2024

Changes in this version

+ const HeaderExpect

+ const HeaderProjectName

+ const HeaderReplicationStatus

+ const HeaderRestoreExpiryDays

+ const HeaderRestoreRequestDate

+ const HeaderRestoreTier

+ const HeaderTOSEC

+ type ApplyServerSideEncryptionByDefault struct

+ KMSMasterKeyID string

+ SSEAlgorithm string

+ type BucketEncryptionRule struct

+ ApplyServerSideEncryptionByDefault ApplyServerSideEncryptionByDefault

type ClientOption

+ func WithExcept100ContinueThreshold(threshold int64) ClientOption

type ClientV2

+ func (cli *ClientV2) DeleteBucketEncryption(ctx context.Context, input *DeleteBucketEncryptionInput) (*DeleteBucketEncryptionOutput, error)

+ func (cli *ClientV2) GetBucketEncryption(ctx context.Context, input *GetBucketEncryptionInput) (*GetBucketEncryptionOutput, error)

+ func (cli *ClientV2) PutBucketEncryption(ctx context.Context, input *PutBucketEncryptionInput) (*PutBucketEncryptionOutput, error)

type CorsRule

+ ResponseVary bool

type CreateBucketV2Input

+ ProjectName string

type DataTransferStatus

+ RetryCount int

+ type DeleteBucketEncryptionInput struct

+ Bucket string

+ type DeleteBucketEncryptionOutput struct

+ type FetchHeaderToMetaDataRule struct

+ MetaDataSuffix string

+ SourceHeader string

type FetchObjectInputV2

+ ContentMD5 string

+ type GetBucketEncryptionInput struct

+ Bucket string

+ type GetBucketEncryptionOutput struct

+ Rule BucketEncryptionRule

type GetObjectV2Input

+ DocPage int

+ DstType enum.DocPreviewDstType

+ SrcType enum.DocPreviewSrcType

type HeadBucketOutput

+ ProjectName string

type LifecycleRule

+ Filter *LifecycleRuleFilter

+ type LifecycleRuleFilter struct

+ GreaterThanIncludeEqual enum.StatusType

+ LessThanIncludeEqual enum.StatusType

+ ObjectSizeGreaterThan int

+ ObjectSizeLessThan int

type ListBucketsInput

+ ProjectName string

type ListedBucket

+ ProjectName string

type ObjectMeta

+ RestoreInfo *RestoreInfo

type ObjectMetaV2

+ ReplicationStatus enum.ReplicationStatusType

+ RestoreInfo *RestoreInfo

+ type PutBucketEncryptionInput struct

+ Bucket string

+ Rule BucketEncryptionRule

+ type PutBucketEncryptionOutput struct

type PutBucketLifecycleInput

+ AllowSameActionOverlap bool

type PutFetchTaskInputV2

+ CallbackBody string

+ CallbackBodyType string

+ CallbackHost string

+ CallbackUrl string

+ ContentMD5 string

type Redirect

+ FetchHeaderToMetaDataRules []FetchHeaderToMetaDataRule

type RequestInfo

+ EcCode string

+ type RestoreInfo struct

+ RestoreParam *RestoreParam

+ RestoreStatus RestoreStatus

+ type RestoreParam struct

+ ExpiryDays int

+ RequestDate time.Time

+ Tier enum.TierType

+ type RestoreStatus struct

+ ExpiryDate time.Time

+ OngoingRequest bool

type TosError

+ EcCode string

+ ReqID string

v2.6.9

Jun 11, 2024

Changes in this version

type CompleteMultipartUploadOutput

+ Bucket string

+ ETag string

+ Key string

+ Location string

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

v2.6.8

May 8, 2024

Changes in this version

type ClientV2

+ func (cli *ClientV2) GetFileStatus(ctx context.Context, input *GetFileStatusInput) (*GetFileStatusOutput, error)

+ type GenericInput struct

+ RequestDate time.Time

+ RequestHost string

+ type GetFileStatusInput struct

+ Bucket string

+ Key string

+ type GetFileStatusOutput struct

+ Crc32 string

+ Crc64 string

+ Key string

+ LastModified time.Time

+ Size int64

type Request

+ RequestDate time.Time

+ RequestHost string

v2.6.7

Apr 1, 2024

v2.6.6

Feb 2, 2024

Changes in this version

type ClientV2

+ func (cli *ClientV2) DeleteBucketTagging(ctx context.Context, input *DeleteBucketTaggingInput) (*DeleteBucketTaggingOutput, error)

+ func (cli *ClientV2) GetBucketNotificationType2(ctx context.Context, input *GetBucketNotificationType2Input) (*GetBucketNotificationType2Output, error)

+ func (cli *ClientV2) GetBucketTagging(ctx context.Context, input *GetBucketTaggingInput) (*GetBucketTaggingOutput, error)

+ func (cli *ClientV2) PutBucketNotificationType2(ctx context.Context, input *PutBucketNotificationType2Input) (*PutBucketNotificationType2Output, error)

+ func (cli *ClientV2) PutBucketTagging(ctx context.Context, input *PutBucketTaggingInput) (*PutBucketTaggingOutput, error)

+ type DeleteBucketTaggingInput struct

+ Bucket string

+ type DeleteBucketTaggingOutput struct

+ type DestinationRocketMQ struct

+ AccessKeyID string

+ InstanceID string

+ Role string

+ Topic string

+ type DestinationVeFaaS struct

+ FunctionID string

+ type GetBucketNotificationType2Input struct

+ Bucket string

+ type GetBucketNotificationType2Output struct

+ Rules []NotificationRule

+ Version string

+ type GetBucketTaggingInput struct

+ Bucket string

+ type GetBucketTaggingOutput struct

+ TagSet TagSet

+ type NotificationDestination struct

+ RocketMQ []DestinationRocketMQ

+ VeFaaS []DestinationVeFaaS

+ type NotificationFilter struct

+ TOSKey NotificationFilterKey

+ type NotificationFilterKey struct

+ FilterRules []NotificationFilterRule

+ type NotificationFilterRule struct

+ Name string

+ Value string

+ type NotificationRule struct

+ Destination NotificationDestination

+ Events []string

+ Filter NotificationFilter

+ RuleID string

+ type PutBucketNotificationType2Input struct

+ Bucket string

+ Rules []NotificationRule

+ Version string

+ type PutBucketNotificationType2Output struct

+ type PutBucketTaggingInput struct

+ Bucket string

+ TagSet TagSet

+ type PutBucketTaggingOutput struct

v2.6.5

Dec 22, 2023

Changes in this version

+ const DefaultHighLatencyLogThreshold

+ var RefreshInterval = time.Second * 30

+ func LookupIP(ctx context.Context, host string) ([]net.IP, error)

+ func MinDuration(t1, t2 time.Duration) time.Duration

type ClientOption

+ func WithHighLatencyLogThreshold(highLatencyLogThreshold int) ClientOption

type Error

+ EC string

type Response

+ RequestUrl string

type TosError

+ RequestUrl string

type TosServerError

+ EC string

type TransportConfig

+ HighLatencyLogThreshold *int

v2.6.4

Nov 2, 2023

v2.6.3

Sep 28, 2023

Changes in this version

type ClientOption

+ func WithDisableEncodingMeta(disable bool) ClientOption

type GetObjectV2Input

+ SaveBucket string

+ SaveObject string

v2.6.2

Sep 6, 2023

Changes in this version

type AppendObjectV2Input

+ IfMatch string

type Bucket

+ func (bkt *Bucket) DeleteObjectTagging(ctx context.Context, input *DeleteObjectTaggingInput, option ...Option) (*DeleteObjectTaggingOutput, error)

+ func (bkt *Bucket) GetObjectTagging(ctx context.Context, input *GetObjectTaggingInput, option ...Option) (*GetObjectTaggingOutput, error)

+ func (bkt *Bucket) PutObjectTagging(ctx context.Context, input *PutObjectTaggingInput, option ...Option) (*PutObjectTaggingOutput, error)

+ func (bkt *Bucket) RestoreObject(ctx context.Context, input *RestoreObjectInput, option ...Option) (*RestoreObjectOutput, error)

type CompleteMultipartUploadV2Input

+ ForbidOverwrite bool

type CompleteMultipartUploadV2Output

+ CompletedParts []UploadedPartV2

type CopyObjectInput

+ ForbidOverwrite bool

+ IfMatch string

type CreateMultipartUploadV2Input

+ ForbidOverwrite bool

type PutObjectBasicInput

+ ForbidOverwrite bool

+ IfMatch string

v2.6.1

Jul 11, 2023

Changes in this version

+ const HeaderServerSideEncryptionKmsKeyID

type CompleteMultipartUploadV2Output

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

type CopyObjectInput

+ ServerSideEncryptionKeyID string

type CopyObjectOutput

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

type CreateMultipartUploadV2Input

+ ServerSideEncryptionKeyID string

type CreateMultipartUploadV2Output

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

type ObjectMetaV2

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

type PutObjectBasicInput

+ ServerSideEncryptionKeyID string

type PutObjectV2Output

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

type UploadPartBasicInput

+ ServerSideEncryptionKeyID string

type UploadPartCopyV2Output

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

type UploadPartV2Output

+ ServerSideEncryption string

+ ServerSideEncryptionKeyID string

v2.6.0

Jun 13, 2023

Changes in this version

+ const DefaultRetryTime

+ var InvalidCompleteAllPartsLength = newTosClientError("Should not specify both complete all and Parts", nil)

+ var InvalidPartsLength = newTosClientError("You must specify at least one part", nil)

+ var InvlidDeleteMultiObjectsLength = newTosClientError("You must specify at least one object", nil)

type AppendObjectV2Input

+ TrafficLimit int64

type ClientOption

+ func WithCustomDomain(isCustomDomain bool) ClientOption

type ClientV2

+ func (cli *ClientV2) RestoreObject(ctx context.Context, input *RestoreObjectInput) (*RestoreObjectOutput, error)

type CompleteMultipartUploadV2Input

+ Callback string

+ CallbackVar string

+ CompleteAll bool

type CompleteMultipartUploadV2Output

+ CallbackResult string

type Condition

+ KeyPrefix string

+ KeySuffix string

type CopyObjectInput

+ TrafficLimit int64

type DownloadFileInput

+ TrafficLimit int64

type GetObjectV2Input

+ Process string

+ TrafficLimit int64

type PreSignedURLInput

+ IsCustomDomain *bool

type PublicSource

+ FixedEndpoint bool

type PutObjectBasicInput

+ Callback string

+ CallbackVar string

+ TrafficLimit int64

type PutObjectV2Output

+ CallbackResult string

type Redirect

+ Transform Transform

+ type ReplaceKeyPrefix struct

+ KeyPrefix string

+ ReplaceWith string

+ type RestoreJobParameters struct

+ Tier enum.TierType

+ type RestoreObjectInput struct

+ Bucket string

+ Days int

+ Key string

+ RestoreJobParameters *RestoreJobParameters

+ VersionID string

+ type RestoreObjectOutput struct

type ResumableCopyObjectInput

+ TrafficLimit int64

+ type Transform struct

+ ReplaceKeyPrefix ReplaceKeyPrefix

+ WithKeyPrefix string

+ WithKeySuffix string

type UnexpectedStatusCodeError

+ func (us *UnexpectedStatusCodeError) WithRequestBody(res *Response) *UnexpectedStatusCodeError

type UploadFileInput

+ TrafficLimit int64

type UploadPartBasicInput

+ TrafficLimit int64

type UploadPartCopyV2Input

+ TrafficLimit int64

v2.5.5

May 11, 2023

Changes in this version

+ var NotificationConfigurationsInvalid = newTosClientError("Notification Configurations invalid", nil)

type GetBucketNotificationOutput

+ RocketMQConfigurations []RocketMQConfiguration

type PutBucketNotificationInput

+ RocketMQConfigurations []RocketMQConfiguration

+ type RocketMQConf struct

+ AccessKeyID string

+ InstanceID string

+ Topic string

+ type RocketMQConfiguration struct

+ Events []string

+ Filter Filter

+ ID string

+ RocketMQ RocketMQConf

+ Role string

v2.5.4

May 5, 2023

Changes in this version

type ClientV2

+ func (cli *ClientV2) DeleteBucketRename(ctx context.Context, input *DeleteBucketRenameInput) (*DeleteBucketRenameOutput, error)

+ func (cli *ClientV2) GetBucketRename(ctx context.Context, input *GetBucketRenameInput) (*GetBucketRenameOutput, error)

+ func (cli *ClientV2) PutBucketRename(ctx context.Context, input *PutBucketRenameInput) (*PutBucketRenameOutput, error)

+ func (cli *ClientV2) RenameObject(ctx context.Context, input *RenameObjectInput) (*RenameObjectOutput, error)

+ type DeleteBucketRenameInput struct

+ Bucket string

+ type DeleteBucketRenameOutput struct

+ type GetBucketRenameInput struct

+ Bucket string

+ type GetBucketRenameOutput struct

+ RenameEnable bool

type ListObjectVersionsInput

+ FetchMeta bool

type ListObjectsInput

+ FetchMeta bool

type ListObjectsType2Input

+ FetchMeta bool

type ListedObject

+ Meta Metadata

type ListedObjectV2

+ Meta Metadata

type ListedObjectVersion

+ Meta Metadata

type ListedObjectVersionV2

+ Meta Metadata

+ type PutBucketRenameInput struct

+ Bucket string

+ RenameEnable bool

+ type PutBucketRenameOutput struct

+ type RenameObjectInput struct

+ Bucket string

+ Key string

+ NewKey string

+ type RenameObjectOutput struct

v2.5.3

Mar 15, 2023

v2.5.2

Mar 13, 2023

v2.5.1

Feb 27, 2023

Changes in this version

+ var InvalidPartNumber = newTosClientError("input part number is invalid. ", nil)

+ var InvalidUploadID = newTosClientError("input upload id is invalid. ", nil)

+ var ProxyNotSupportHttps = newTosClientError("proxy not support https", nil)

+ var ProxyUrlInvalid = newTosClientError("proxy not support https", nil)

v2.5.0

Jan 6, 2023

Changes in this version

+ const DefaultListMaxKeys

+ var InvalidS3Endpoint = newTosClientError("do not support s3 endpoint, please use tos endpoint", nil)

+ var NotSupportSeek = newTosClientError("reader not support seek", nil)

+ func OnRetryFromStart(req *Request) error

+ type AccessLogConfiguration struct

+ TLSProjectID string

+ TLSTopicID string

+ UseServiceTopic bool

type ClientV2

+ func (cli *ClientV2) DeleteBucketCustomDomain(ctx context.Context, input *DeleteBucketCustomDomainInput) (*DeleteBucketCustomDomainOutput, error)

+ func (cli *ClientV2) DeleteBucketRealTimeLog(ctx context.Context, input *DeleteBucketRealTimeLogInput) (*DeleteBucketRealTimeLogOutput, error)

+ func (cli *ClientV2) DeleteBucketReplication(ctx context.Context, input *DeleteBucketReplicationInput) (*DeleteBucketReplicationOutput, error)

+ func (cli *ClientV2) DeleteBucketWebsite(ctx context.Context, input *DeleteBucketWebsiteInput) (*DeleteBucketWebsiteOutput, error)

+ func (cli *ClientV2) GetBucketNotification(ctx context.Context, input *GetBucketNotificationInput) (*GetBucketNotificationOutput, error)

+ func (cli *ClientV2) GetBucketRealTimeLog(ctx context.Context, input *GetBucketRealTimeLogInput) (*GetBucketRealTimeLogOutput, error)

+ func (cli *ClientV2) GetBucketReplication(ctx context.Context, input *GetBucketReplicationInput) (*GetBucketReplicationOutput, error)

+ func (cli *ClientV2) GetBucketVersioning(ctx context.Context, input *GetBucketVersioningInput) (*GetBucketVersioningOutputV2, error)

+ func (cli *ClientV2) GetBucketWebsite(ctx context.Context, input *GetBucketWebsiteInput) (*GetBucketWebsiteOutput, error)

+ func (cli *ClientV2) ListBucketCustomDomain(ctx context.Context, input *ListBucketCustomDomainInput) (*ListBucketCustomDomainOutput, error)

+ func (cli *ClientV2) PutBucketCustomDomain(ctx context.Context, input *PutBucketCustomDomainInput) (*PutBucketCustomDomainOutput, error)

+ func (cli *ClientV2) PutBucketNotification(ctx context.Context, input *PutBucketNotificationInput) (*PutBucketNotificationOutput, error)

+ func (cli *ClientV2) PutBucketRealTimeLog(ctx context.Context, input *PutBucketRealTimeLogInput) (*PutBucketRealTimeLogOutput, error)

+ func (cli *ClientV2) PutBucketReplication(ctx context.Context, input *PutBucketReplicationInput) (*PutBucketReplicationOutput, error)

+ func (cli *ClientV2) PutBucketVersioning(ctx context.Context, input *PutBucketVersioningInput) (*PutBucketVersioningOutput, error)

+ func (cli *ClientV2) PutBucketWebsite(ctx context.Context, input *PutBucketWebsiteInput) (*PutBucketWebsiteOutput, error)

+ func (cli *ClientV2) ResumableCopyObject(ctx context.Context, input *ResumableCopyObjectInput) (*ResumableCopyObjectOutput, error)

+ type CloudFunctionConfiguration struct

+ CloudFunction string

+ Events []string

+ Filter Filter

+ ID string

+ type CopyEvent struct

+ Bucket string

+ CheckpointFile *string

+ CopyPartInfo *copyPartInfo

+ Err error

+ Key string

+ SrcBucket string

+ SrcKey string

+ SrcVersionID string

+ Type enum.CopyEventType

+ UploadID *string

+ type CopyEventListener interface

+ EventChange func(event *CopyEvent)

type CopyObjectInput

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ type CopyPartInfo struct

+ CopySourceRangeEnd int64

+ CopySourceRangeStart int64

+ Etag *string

+ PartNumber int

+ type CustomDomainRule struct

+ CertID string

+ CertStatus enum.CertStatusType

+ Cname string

+ Domain string

+ Forbidden bool

+ ForbiddenReason string

+ type DeleteBucketCustomDomainInput struct

+ Bucket string

+ Domain string

+ type DeleteBucketCustomDomainOutput struct

+ type DeleteBucketRealTimeLogInput struct

+ Bucket string

+ type DeleteBucketRealTimeLogOutput struct

+ type DeleteBucketReplicationInput struct

+ Bucket string

+ type DeleteBucketReplicationOutput struct

+ type DeleteBucketWebsiteInput struct

+ Bucket string

+ type DeleteBucketWebsiteOutput struct

+ type Destination struct

+ Bucket string

+ Location string

+ StorageClass enum.StorageClassType

+ StorageClassInheritDirective enum.StorageClassInheritDirectiveType

+ type ErrorDocument struct

+ Key string

+ type Filter struct

+ Key FilterKey

+ type FilterKey struct

+ Rules []FilterRule

+ type FilterRule struct

+ Name string

+ Value string

+ type GetBucketNotificationInput struct

+ Bucket string

+ type GetBucketNotificationOutput struct

+ CloudFunctionConfigurations []CloudFunctionConfiguration

+ type GetBucketRealTimeLogInput struct

+ Bucket string

+ type GetBucketRealTimeLogOutput struct

+ Configuration RealTimeLogConfiguration

+ type GetBucketReplicationInput struct

+ Bucket string

+ RuleID string

+ type GetBucketReplicationOutput struct

+ Role string

+ Rules []ReplicationRuleWithProgress

+ type GetBucketVersioningInput struct

+ Bucket string

+ type GetBucketVersioningOutputV2 struct

+ Status enum.VersioningStatusType

+ type GetBucketWebsiteInput struct

+ Bucket string

+ type GetBucketWebsiteOutput struct

+ ErrorDocument *ErrorDocument

+ IndexDocument *IndexDocument

+ RedirectAllRequestsTo *RedirectAllRequestsTo

+ RoutingRules []RoutingRule

type GetObjectACLOutput

+ BucketOwnerEntrusted bool

type GetObjectV2Input

+ Range string

+ type IndexDocument struct

+ ForbiddenSubDir bool

+ Suffix string

+ type ListBucketCustomDomainInput struct

+ Bucket string

+ type ListBucketCustomDomainOutput struct

+ Rules []CustomDomainRule

type ListObjectsType2Input

+ ListOnlyOnce bool

+ type Progress struct

+ HistoricalObject float64

+ NewObject string

+ type PutBucketCustomDomainInput struct

+ Bucket string

+ Rule CustomDomainRule

+ type PutBucketCustomDomainOutput struct

+ type PutBucketNotificationInput struct

+ Bucket string

+ CloudFunctionConfigurations []CloudFunctionConfiguration

+ type PutBucketNotificationOutput struct

+ type PutBucketRealTimeLogInput struct

+ Bucket string

+ Configuration RealTimeLogConfiguration

+ type PutBucketRealTimeLogOutput struct

+ type PutBucketReplicationInput struct

+ Bucket string

+ Role string

+ Rules []ReplicationRule

+ type PutBucketReplicationOutput struct

+ type PutBucketVersioningInput struct

+ Bucket string

+ Status enum.VersioningStatusType

+ type PutBucketVersioningOutput struct

+ type PutBucketWebsiteInput struct

+ Bucket string

+ ErrorDocument *ErrorDocument

+ IndexDocument *IndexDocument

+ RedirectAllRequestsTo *RedirectAllRequestsTo

+ RoutingRules *RoutingRules

+ type PutBucketWebsiteOutput struct

type PutObjectACLInput

+ BucketOwnerEntrusted bool

type RateLimiter

+ func NewDefaultRateLimit(rate int64, capacity int64) RateLimiter

type ReadCloserWithLimiter

+ func (r *ReadCloserWithLimiter) Seek(offset int64, whence int) (int64, error)

+ type RealTimeLogConfiguration struct

+ Configuration AccessLogConfiguration

+ Role string

+ type RedirectAllRequestsTo struct

+ HostName string

+ Protocol string

+ type ReplicationRule struct

+ Destination Destination

+ HistoricalObjectReplication enum.StatusType

+ ID string

+ PrefixSet []string

+ Status enum.StatusType

+ type ReplicationRuleWithProgress struct

+ Progress *Progress

+ type ResumableCopyObjectInput struct

+ CancelHook CancelHook

+ CheckpointFile string

+ CopyEventListener CopyEventListener

+ CopySourceIfMatch string

+ CopySourceIfModifiedSince time.Time

+ CopySourceIfNoneMatch string

+ CopySourceIfUnmodifiedSince time.Time

+ CopySourceSSECAlgorithm string

+ CopySourceSSECKey string

+ CopySourceSSECKeyMD5 string

+ EnableCheckpoint bool

+ PartSize int64

+ SrcBucket string

+ SrcKey string

+ SrcVersionID string

+ TaskNum int

+ type ResumableCopyObjectOutput struct

+ Bucket string

+ EncodingType string

+ Etag string

+ HashCrc64ecma uint64

+ Key string

+ Location string

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ UploadID string

+ VersionID string

+ type RoutingRule struct

+ Condition RoutingRuleCondition

+ Redirect RoutingRuleRedirect

+ type RoutingRuleCondition struct

+ HttpErrorCodeReturnedEquals int

+ KeyPrefixEquals string

+ type RoutingRuleRedirect struct

+ HostName string

+ HttpRedirectCode int

+ Protocol enum.ProtocolType

+ ReplaceKeyPrefixWith string

+ ReplaceKeyWith string

+ type RoutingRules struct

+ Rules []RoutingRule

type UploadPartCopyV2Input

+ CopySourceRange string

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

v2.4.8

Dec 21, 2022

Changes in this version

type ListObjectsV2Output

+ func ParseListObjectsV2Output(httpRes *http.Response) (*ListObjectsV2Output, error)

v2.4.7

Dec 21, 2022

Changes in this version

type GetObjectV2Output

+ func ParseGetObjectV2Output(httpRes *http.Response, expectedCode int) (*GetObjectV2Output, error)

type HeadObjectV2Output

+ func ParseHeadObjectV2Output(httpRes *http.Response) (*HeadObjectV2Output, error)

type ListObjectVersionsV2Output

+ func ParseListObjectVersionsV2Output(httpRes *http.Response) (*ListObjectVersionsV2Output, error)

type ListObjectsType2Output

+ func ParseListObjectsType2Output(httpRes *http.Response) (*ListObjectsType2Output, error)

v2.4.6

Dec 14, 2022

Changes in this version

+ var InvalidPreSignedConditions = newTosClientError("invalid pre signed url conditions.", nil)

type PreSingedPolicyURLInput

+ Bucket string

+ IsCustomDomain bool

v2.4.5

Nov 14, 2022

Changes in this version

type ClientV2

+ func (cli *ClientV2) PreSignedPolicyURL(ctx context.Context, input *PreSingedPolicyURLInput) (*PreSingedPolicyURLOutput, error)

+ type PolicySignatureCondition struct

+ Key string

+ Operator *string

+ Value string

+ type PreSignedPolicyURLGenerator interface

+ GetSignedURLForGetOrHead func(bucket, key string, additionalQuery map[string]string) string

+ GetSignedURLForList func(bucket string, additionalQuery map[string]string) string

+ type PreSingedPolicyURLInput struct

+ AlternativeEndpoint string

+ Conditions []PolicySignatureCondition

+ Expires int64

+ type PreSingedPolicyURLOutput struct

+ SignatureQuery string

+ func (output *PreSingedPolicyURLOutput) GetSignedURLForGetOrHead(bucket, key string, additionalQuery map[string]string) string

+ func (output *PreSingedPolicyURLOutput) GetSignedURLForList(bucket string, additionalQuery map[string]string) string

v2.4.4

Nov 2, 2022

v2.4.3

Oct 28, 2022

v2.4.2

Oct 19, 2022

Changes in this version

+ func SupportedEndpoint() map[string]string

v2.4.1

Oct 17, 2022

v2.4.0

Oct 14, 2022

Changes in this version

+ const DefaultPartSize

+ var CrcCheckFail = newTosClientError("crc check not equal", nil)

+ var InvalidCheckpointFilePath = newTosClientError("invalid checkpoint file path", nil)

+ var InvalidFilePath = newTosClientError("invalid file path", nil)

+ type AbortInCompleteMultipartUpload struct

+ DaysAfterInitiation int

type ClientV2

+ func (cli *ClientV2) DeleteBucketLifecycle(ctx context.Context, input *DeleteBucketLifecycleInput) (*DeleteBucketLifecycleOutput, error)

+ func (cli *ClientV2) DeleteBucketMirrorBack(ctx context.Context, input *DeleteBucketMirrorBackInput) (*DeleteBucketMirrorBackOutput, error)

+ func (cli *ClientV2) DeleteBucketPolicyV2(ctx context.Context, input *DeleteBucketPolicyV2Input) (*DeleteBucketPolicyV2Output, error)

+ func (cli *ClientV2) DeleteObjectTagging(ctx context.Context, input *DeleteObjectTaggingInput) (*DeleteObjectTaggingOutput, error)

+ func (cli *ClientV2) FetchObjectV2(ctx context.Context, input *FetchObjectInputV2) (*FetchObjectOutputV2, error)

+ func (cli *ClientV2) GetBucketACL(ctx context.Context, input *GetBucketACLInput) (*GetBucketACLOutput, error)

+ func (cli *ClientV2) GetBucketLifecycle(ctx context.Context, input *GetBucketLifecycleInput) (*GetBucketLifecycleOutput, error)

+ func (cli *ClientV2) GetBucketLocation(ctx context.Context, input *GetBucketLocationInput) (*GetBucketLocationOutput, error)

+ func (cli *ClientV2) GetBucketMirrorBack(ctx context.Context, input *GetBucketMirrorBackInput) (*GetBucketMirrorBackOutput, error)

+ func (cli *ClientV2) GetBucketPolicyV2(ctx context.Context, input *GetBucketPolicyV2Input) (*GetBucketPolicyV2Output, error)

+ func (cli *ClientV2) GetObjectTagging(ctx context.Context, input *GetObjectTaggingInput) (*GetObjectTaggingOutput, error)

+ func (cli *ClientV2) ListObjectsType2(ctx context.Context, input *ListObjectsType2Input) (*ListObjectsType2Output, error)

+ func (cli *ClientV2) PreSignedPostSignature(ctx context.Context, input *PreSingedPostSignatureInput) (*PreSingedPostSignatureOutput, error)

+ func (cli *ClientV2) PutBucketACL(ctx context.Context, input *PutBucketACLInput) (*PutBucketACLOutput, error)

+ func (cli *ClientV2) PutBucketLifecycle(ctx context.Context, input *PutBucketLifecycleInput) (*PutLifecycleOutput, error)

+ func (cli *ClientV2) PutBucketMirrorBack(ctx context.Context, input *PutBucketMirrorBackInput) (*PutBucketMirrorBackOutput, error)

+ func (cli *ClientV2) PutBucketPolicyV2(ctx context.Context, input *PutBucketPolicyV2Input) (*PutBucketPolicyV2Output, error)

+ func (cli *ClientV2) PutBucketStorageClass(ctx context.Context, input *PutBucketStorageClassInput) (*PutBucketStorageClassOutput, error)

+ func (cli *ClientV2) PutFetchTaskV2(ctx context.Context, input *PutFetchTaskInputV2) (*PutFetchTaskOutputV2, error)

+ func (cli *ClientV2) PutObjectTagging(ctx context.Context, input *PutObjectTaggingInput) (*PutObjectTaggingOutput, error)

+ type Condition struct

+ HttpCode int

+ type ContentLengthRange struct

+ RangeEnd int64

+ RangeStart int64

+ type DeleteBucketLifecycleInput struct

+ Bucket string

+ type DeleteBucketLifecycleOutput struct

+ type DeleteBucketMirrorBackInput struct

+ Bucket string

+ type DeleteBucketMirrorBackOutput struct

+ type DeleteBucketPolicyV2Input struct

+ Bucket string

+ type DeleteBucketPolicyV2Output struct

+ type DeleteObjectTaggingInput struct

+ Bucket string

+ Key string

+ VersionID string

+ type DeleteObjectTaggingOutput struct

+ VersionID string

+ type Expiration struct

+ Date time.Time

+ Days int

+ type FetchObjectInputV2 struct

+ ACL enum.ACLType

+ Bucket string

+ GrantFullControl string

+ GrantRead string

+ GrantReadACP string

+ GrantWriteACP string

+ HexMD5 string

+ IgnoreSameKey bool

+ Key string

+ Meta map[string]string

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ StorageClass enum.StorageClassType

+ URL string

+ type FetchObjectOutputV2 struct

+ Etag string

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ VersionID string

+ type GetBucketACLInput struct

+ Bucket string

+ type GetBucketACLOutput struct

+ Grants []GrantV2

+ Owner Owner

+ type GetBucketLifecycleInput struct

+ Bucket string

+ type GetBucketLifecycleOutput struct

+ Rules []LifecycleRule

+ type GetBucketLocationInput struct

+ Bucket string

+ type GetBucketLocationOutput struct

+ ExtranetEndpoint string

+ IntranetEndpoint string

+ Region string

+ type GetBucketMirrorBackInput struct

+ Bucket string

+ type GetBucketMirrorBackOutput struct

+ Rules []MirrorBackRule

+ type GetBucketPolicyV2Input struct

+ Bucket string

+ type GetBucketPolicyV2Output struct

+ Policy string

+ type GetObjectTaggingInput struct

+ Bucket string

+ Key string

+ VersionID string

+ type GetObjectTaggingOutput struct

+ TagSet TagSet

+ VersionID string

+ type LifecycleRule struct

+ AbortInCompleteMultipartUpload *AbortInCompleteMultipartUpload

+ Expiration *Expiration

+ ID string

+ NoCurrentVersionExpiration *NoCurrentVersionExpiration

+ NonCurrentVersionTransition []NonCurrentVersionTransition

+ Prefix string

+ Status enum.StatusType

+ Tag []Tag

+ Transitions []Transition

+ type ListObjectsType2Input struct

+ Bucket string

+ ContinuationToken string

+ Delimiter string

+ EncodingType string

+ MaxKeys int

+ Prefix string

+ StartAfter string

+ type ListObjectsType2Output struct

+ CommonPrefixes []ListedCommonPrefix

+ Contents []ListedObjectV2

+ ContinuationToken string

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyCount int

+ MaxKeys int

+ Name string

+ NextContinuationToken string

+ Prefix string

+ type MirrorBackRule struct

+ Condition Condition

+ ID string

+ Redirect Redirect

+ type MirrorHeader struct

+ Pass []string

+ PassAll bool

+ Remove []string

+ type NoCurrentVersionExpiration struct

+ NoCurrentDays int

+ type NonCurrentVersionTransition struct

+ NonCurrentDays int

+ StorageClass enum.StorageClassType

+ type PostSignatureCondition struct

+ Key string

+ Operator *string

+ Value string

+ type PreSingedPostSignatureInput struct

+ Bucket string

+ Conditions []PostSignatureCondition

+ ContentLengthRange *ContentLengthRange

+ Expires int64

+ Key string

+ type PreSingedPostSignatureOutput struct

+ Algorithm string

+ Credential string

+ Date string

+ OriginPolicy string

+ Policy string

+ Signature string

+ type PublicSource struct

+ SourceEndpoint SourceEndpoint

+ type PutBucketACLInput struct

+ ACLType enum.ACLType

+ Bucket string

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWrite string

+ GrantWriteAcp string

+ Grants []GrantV2

+ Owner Owner

+ type PutBucketACLOutput struct

+ type PutBucketLifecycleInput struct

+ Bucket string

+ Rules []LifecycleRule

+ type PutBucketMirrorBackInput struct

+ Bucket string

+ Rules []MirrorBackRule

+ type PutBucketMirrorBackOutput struct

+ type PutBucketPolicyV2Input struct

+ Bucket string

+ Policy string

+ type PutBucketPolicyV2Output struct

+ type PutBucketStorageClassInput struct

+ Bucket string

+ StorageClass enum.StorageClassType

+ type PutBucketStorageClassOutput struct

+ type PutFetchTaskInputV2 struct

+ ACL enum.ACLType

+ Bucket string

+ GrantFullControl string

+ GrantRead string

+ GrantReadACP string

+ GrantWriteACP string

+ HexMD5 string

+ IgnoreSameKey bool

+ Key string

+ Meta map[string]string

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ StorageClass enum.StorageClassType

+ URL string

+ type PutFetchTaskOutputV2 struct

+ TaskID string

+ type PutLifecycleOutput struct

+ type PutObjectTaggingInput struct

+ Bucket string

+ Key string

+ TagSet TagSet

+ VersionID string

+ type PutObjectTaggingOutput struct

+ VersionID string

+ type Redirect struct

+ FetchSourceOnRedirect bool

+ FollowRedirect bool

+ MirrorHeader MirrorHeader

+ PassQuery bool

+ PublicSource PublicSource

+ RedirectType enum.RedirectType

+ type SourceEndpoint struct

+ Follower []string

+ Primary []string

+ type Tag struct

+ Key string

+ Value string

+ type TagSet struct

+ Tags []Tag

+ type Transition struct

+ Date time.Time

+ Days int

+ StorageClass enum.StorageClassType

v2.3.3

Oct 12, 2022

Changes in this version

+ var InvalidPreSignedURLExpires = newTosClientError("invalid pre signed url expires, the time must be less 604800 seconds.", nil)

v2.3.2

Oct 10, 2022

v2.3.1

Sep 29, 2022

v2.3.0

Sep 27, 2022

Changes in this version

+ const DefaultCacheCap

+ const HostSplitLength

+ const HostSplitSep

+ const VolceHostSuffix

+ var InvalidACL = newTosClientError("invalid acl type", nil)

+ var InvalidAzRedundancy = newTosClientError("invalid az redundancy type", nil)

+ var InvalidBucketNameCharacter = newTosClientError("invalid bucket name, the character set is illegal", nil)

+ var InvalidBucketNameLength = newTosClientError("invalid bucket name, the length must be [3, 63]", nil)

+ var InvalidBucketNameStartingOrEnding = newTosClientError(...)

+ var InvalidCanned = newTosClientError("invalid canned type", nil)

+ var InvalidFilePartNum = newTosClientError("unsupported part number, the maximum is 10000", nil)

+ var InvalidGrantee = newTosClientError("invalid grantee type", nil)

+ var InvalidMarshal = newTosClientError("unable to do serialization/deserialization", nil)

+ var InvalidMetadataDirective = newTosClientError("invalid metadata directive type", nil)

+ var InvalidObjectNameCharacterSet = newTosClientError("invalid object name, the character set is illegal", nil)

+ var InvalidObjectNameLength = newTosClientError("invalid object name, the length must be [1, 696]", nil)

+ var InvalidObjectNameStartingOrEnding = newTosClientError("invalid object name, the object name can not start with '/' or '\\'", nil)

+ var InvalidPartSize = newTosClientError("invalid part size, the size must be [5242880, 5368709120]", nil)

+ var InvalidPermission = newTosClientError("invalid permission type", nil)

+ var InvalidSSECAlgorithm = newTosClientError("invalid encryption-decryption algorithm", nil)

+ var InvalidSrcFilePath = newTosClientError("invalid file path, the file does not exist", nil)

+ var InvalidStorageClass = newTosClientError("invalid storage class", nil)

type ClientOption

+ func WithDNSCacheTime(dnsCacheTime int) ClientOption

+ func WithProxy(proxy *Proxy) ClientOption

type HeadBucketOutput

+ AzRedundancy enum.AzRedundancyType

+ type Logger interface

+ Debug func(args ...interface{})

+ Error func(args ...interface{})

+ Fatal func(args ...interface{})

+ Info func(args ...interface{})

+ Warn func(args ...interface{})

type PreSignedURLInput

+ AlternativeEndpoint string

type Proxy

+ func (p *Proxy) Url() *url.URL

type TransportConfig

+ DNSCacheTime time.Duration

+ Proxy *Proxy

v2.2.2

Sep 20, 2022

v2.2.1

Sep 19, 2022

Changes in this version

type TransportConfig

+ MaxConnsPerHost int

+ MaxIdleConnsPerHost int

v2.2.0

Sep 12, 2022

Changes in this version

+ const DefaultProgressCallbackSize

+ const EventPartAborted

+ const EventPartFailed

+ const EventPartSucceed

+ var InputInvalidClientError = newTosClientError("input data is invalid. ", nil)

+ func GetUnixTimeMs() int64

+ func StringPtr(input string) *string

+ func ToMillis(t time.Time) int64

type CancelHook

+ func NewCancelHook() CancelHook

type ClientOption

+ func WithEnableCRC(enableCRC bool) ClientOption

+ func WithLogger(logger *logrus.Logger) ClientOption

+ func WithMaxRetryCount(retryCount int) ClientOption

type ClientV2

+ func (cli *ClientV2) DownloadFile(ctx context.Context, input *DownloadFileInput) (*DownloadFileOutput, error)

type DefaultTransport

+ func (d *DefaultTransport) WithDefaultTransportLogger(logger logrus.FieldLogger)

type SignV4

+ func (sv *SignV4) WithSignLogger(logger logrus.FieldLogger)

+ type SignV4Option func(*SignV4)

v2.1.10

Aug 24, 2022

Changes in this version

+ const QueryPartNumber

+ var InputIsNilClientError = newTosClientError("input is nil. ", nil)

type ClientV2

+ func (cli *ClientV2) DeleteBucketCORS(ctx context.Context, input *DeleteBucketCORSInput) (*DeleteBucketCORSOutput, error)

+ func (cli *ClientV2) GetBucketCORS(ctx context.Context, input *GetBucketCORSInput) (*GetBucketCORSOutput, error)

+ func (cli *ClientV2) PutBucketCORS(ctx context.Context, input *PutBucketCORSInput) (*PutBucketCORSOutput, error)

+ type CorsRule struct

+ AllowedHeader []string

+ AllowedMethod []string

+ AllowedOrigin []string

+ ExposeHeader []string

+ MaxAgeSeconds int

+ type DeleteBucketCORSInput struct

+ Bucket string

+ type DeleteBucketCORSOutput struct

+ type GetBucketCORSInput struct

+ Bucket string

+ type GetBucketCORSOutput struct

+ CORSRules []CorsRule

type GetObjectV2Input

+ PartNumber int

+ type PutBucketCORSInput struct

+ Bucket string

+ CORSRules []CorsRule

+ type PutBucketCORSOutput struct

v2.1.9

Aug 11, 2022

Changes in this version

type PutFetchTaskInput

+ Object string

v2.1.8

Aug 10, 2022

Changes in this version

+ const FetchTaskStateExpired

+ const FetchTaskStateFailed

+ const FetchTaskStateRunning

+ const FetchTaskStateSucceed

type Bucket

+ func (bkt *Bucket) GetFetchTask(ctx context.Context, input *GetFetchTaskInput, options ...Option) (*GetFetchTaskOutput, error)

+ func (bkt *Bucket) PutFetchTask(ctx context.Context, input *FetchObjectInput, options ...Option) (*PutFetchTaskOutput, error)

+ type GetFetchTaskInput struct

+ TaskID string

+ type GetFetchTaskOutput struct

+ State string

+ type PutFetchTaskInput struct

+ ContentMD5 string

+ IgnoreSameKey bool

+ Key string

+ URL string

+ type PutFetchTaskOutput struct

+ TaskID string

v2.1.7

Aug 9, 2022

v2.1.6

Aug 8, 2022

v2.1.5

Aug 4, 2022

Changes in this version

type ClientV2

+ func (cli *ClientV2) ListBuckets(ctx context.Context, _ *ListBucketsInput) (*ListBucketsOutput, error)

type ListedObject

+ Type string

type ListedObjectVersion

+ Type string

v2.1.4

Aug 4, 2022

v2.1.3

Aug 3, 2022

Changes in this version

+ type CustomMeta struct

+ func (c *CustomMeta) AllKeys() []string

+ func (c *CustomMeta) Get(key string) (val string, ok bool)

+ func (c *CustomMeta) Range(f func(key, val string) bool)

+ type DeletedV2 struct

+ DeleteMarker bool

+ DeleteMarkerVersionID string

+ Key string

+ VersionID string

+ type GrantV2 struct

+ GranteeV2 GranteeV2

+ Permission enum.PermissionType

+ type GranteeV2 struct

+ Canned enum.CannedType

+ DisplayName string

+ ID string

+ Type enum.GranteeType

type ListObjectsV2Output

+ CommonPrefixes []ListedCommonPrefix

+ Contents []ListedObjectV2

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ Marker string

+ MaxKeys int64

+ Name string

+ NextMarker string

+ Prefix string

+ type ListedObjectV2 struct

+ ETag string

+ HashCrc64ecma uint64

+ Key string

+ LastModified time.Time

+ Owner Owner

+ Size int64

+ StorageClass enum.StorageClassType

+ type ListedObjectVersionV2 struct

+ ETag string

+ HashCrc64ecma uint64

+ IsLatest bool

+ Key string

+ LastModified time.Time

+ Owner Owner

+ Size int64

+ StorageClass enum.StorageClassType

+ VersionID string

type Metadata

+ Range func(f func(key, value string) bool)

type UploadedPartV2

+ LastModified time.Time

+ Size int64

v2.1.2

Aug 3, 2022

Changes in this version

type ClientV2

+ func (cli *ClientV2) Close()

+ func (cli *ClientV2) SetHTTPTransport(transport http.RoundTripper)

v2.1.1

Aug 1, 2022

Changes in this version

type ClientOption

+ func WithHTTPTransport(transport http.RoundTripper) ClientOption

+ type Metadata struct

+ func (md Metadata) AllKeys() []string

+ func (md Metadata) Get(key string) (val string)

v2.1.0

Jul 27, 2022

Changes in this version

+ const ACLAuthRead

+ const ACLBucketOwnerFullControl

+ const ACLBucketOwnerRead

+ const ACLLogDeliveryWrite

+ const ACLPrivate

+ const ACLPublicRead

+ const ACLPublicReadWrite

+ const BucketVersioningEnable

+ const BucketVersioningSuspended

+ const DefaultFilePerm

+ const DefaultRetryBackoffBase

+ const DefaultTaskBufferSize

+ const HeaderACL

+ const HeaderAzRedundancy

+ const HeaderBucketRegion

+ const HeaderCSType

+ const HeaderCacheControl

+ const HeaderContentDisposition

+ const HeaderContentEncoding

+ const HeaderContentLanguage

+ const HeaderContentLength

+ const HeaderContentMD5

+ const HeaderContentRange

+ const HeaderContentSha256

+ const HeaderContentType

+ const HeaderCopySource

+ const HeaderCopySourceIfMatch

+ const HeaderCopySourceIfModifiedSince

+ const HeaderCopySourceIfNoneMatch

+ const HeaderCopySourceIfUnmodifiedSince

+ const HeaderCopySourceRange

+ const HeaderCopySourceSSECAlgorithm

+ const HeaderCopySourceSSECKey

+ const HeaderCopySourceSSECKeyMD5

+ const HeaderCopySourceVersionID

+ const HeaderDeleteMarker

+ const HeaderETag

+ const HeaderExpires

+ const HeaderGrantFullControl

+ const HeaderGrantRead

+ const HeaderGrantReadAcp

+ const HeaderGrantWrite

+ const HeaderGrantWriteAcp

+ const HeaderHashCrc64ecma

+ const HeaderID2

+ const HeaderIfMatch

+ const HeaderIfModifiedSince

+ const HeaderIfNoneMatch

+ const HeaderIfUnmodifiedSince

+ const HeaderLastModified

+ const HeaderLocation

+ const HeaderMetaPrefix

+ const HeaderMetadataDirective

+ const HeaderNextAppendOffset

+ const HeaderObjectType

+ const HeaderRange

+ const HeaderRequestID

+ const HeaderRestore

+ const HeaderSSECustomerAlgorithm

+ const HeaderSSECustomerKey

+ const HeaderSSECustomerKeyMD5

+ const HeaderServerSideEncryption

+ const HeaderStorageClass

+ const HeaderTag

+ const HeaderUserAgent

+ const HeaderVersionID

+ const HeaderWebsiteRedirectLocation

+ const ISO8601TimeFormat

+ const MaxPartSize

+ const MetadataDirectiveCopy

+ const MetadataDirectiveReplace

+ const MinPartSize

+ const NoRetry

+ const PermissionFullControl

+ const PermissionRead

+ const PermissionTypeReadAcp

+ const PermissionTypeWrite

+ const PermissionTypeWriteAcp

+ const Retry

+ const TempFileSuffix

+ const Version

+ var DefaultCrcTable = func() *crc64.Table

+ var ErrETagMissMatch = errors.New("tos: ETag miss match")

+ func CRC64Combine(crc1 uint64, crc2 uint64, len2 uint64) uint64

+ func Code(err error) string

+ func Int64(value int64) *int64

+ func IsValidBucketName(name string) error

+ func NewCRC(tab *crc64.Table, init uint64) hash.Hash64

+ func RequestID(err error) string

+ func SigningKey(info *SigningKeyInfo) []byte

+ func StatueCode(err error) int

+ func StatusCode(err error) int

+ func SupportedRegion() map[string]string

+ func URIEncode(in string, encodeSlash bool) []byte

+ func UTCNow() time.Time

+ type AbortMultipartUploadInput struct

+ Bucket string

+ Key string

+ UploadID string

+ type AbortMultipartUploadOutput struct

+ type AppendObjectOutput struct

+ ETag string

+ NextAppendOffset int64

+ type AppendObjectV2Input struct

+ ACL enum.ACLType

+ Bucket string

+ CacheControl string

+ Content io.Reader

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentLength int64

+ ContentMD5 string

+ ContentSHA256 string

+ ContentType string

+ DataTransferListener DataTransferListener

+ Expires time.Time

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWriteAcp string

+ Key string

+ Meta map[string]string

+ Offset int64

+ PreHashCrc64ecma uint64

+ RateLimiter RateLimiter

+ StorageClass enum.StorageClassType

+ WebsiteRedirectLocation string

+ type AppendObjectV2Output struct

+ HashCrc64ecma uint64

+ NextAppendOffset int64

+ VersionID string

+ type Bucket struct

+ func (bkt *Bucket) AbortMultipartUpload(ctx context.Context, input *AbortMultipartUploadInput, options ...Option) (*AbortMultipartUploadOutput, error)

+ func (bkt *Bucket) AppendObject(ctx context.Context, objectKey string, content io.Reader, offset int64, ...) (*AppendObjectOutput, error)

+ func (bkt *Bucket) CompleteMultipartUpload(ctx context.Context, input *CompleteMultipartUploadInput, options ...Option) (*CompleteMultipartUploadOutput, error)

+ func (bkt *Bucket) CopyObject(ctx context.Context, srcObjectKey, dstObjectKey string, options ...Option) (*CopyObjectOutput, error)

+ func (bkt *Bucket) CopyObjectFrom(ctx context.Context, srcBucket, srcObjectKey, dstObjectKey string, ...) (*CopyObjectOutput, error)

+ func (bkt *Bucket) CopyObjectTo(ctx context.Context, dstBucket, dstObjectKey, srcObjectKey string, ...) (*CopyObjectOutput, error)

+ func (bkt *Bucket) CreateMultipartUpload(ctx context.Context, objectKey string, options ...Option) (*CreateMultipartUploadOutput, error)

+ func (bkt *Bucket) DeleteMultiObjects(ctx context.Context, input *DeleteMultiObjectsInput, options ...Option) (*DeleteMultiObjectsOutput, error)

+ func (bkt *Bucket) DeleteObject(ctx context.Context, objectKey string, options ...Option) (*DeleteObjectOutput, error)

+ func (bkt *Bucket) FetchObject(ctx context.Context, input *FetchObjectInput, options ...Option) (*FetchObjectOutput, error)

+ func (bkt *Bucket) GetObject(ctx context.Context, objectKey string, options ...Option) (*GetObjectOutput, error)

+ func (bkt *Bucket) GetObjectAcl(ctx context.Context, objectKey string, options ...Option) (*GetObjectAclOutput, error)

+ func (bkt *Bucket) HeadObject(ctx context.Context, objectKey string, options ...Option) (*HeadObjectOutput, error)

+ func (bkt *Bucket) ListMultipartUploads(ctx context.Context, input *ListMultipartUploadsInput, options ...Option) (*ListMultipartUploadsOutput, error)

+ func (bkt *Bucket) ListObjectVersions(ctx context.Context, input *ListObjectVersionsInput, options ...Option) (*ListObjectVersionsOutput, error)

+ func (bkt *Bucket) ListObjects(ctx context.Context, input *ListObjectsInput, options ...Option) (*ListObjectsOutput, error)

+ func (bkt *Bucket) ListUploadedParts(ctx context.Context, input *ListUploadedPartsInput, options ...Option) (*ListUploadedPartsOutput, error)

+ func (bkt *Bucket) PutObject(ctx context.Context, objectKey string, content io.Reader, options ...Option) (*PutObjectOutput, error)

+ func (bkt *Bucket) PutObjectAcl(ctx context.Context, input *PutObjectAclInput, options ...Option) (*PutObjectAclOutput, error)

+ func (bkt *Bucket) SetObjectMeta(ctx context.Context, objectKey string, options ...Option) (*SetObjectMetaOutput, error)

+ func (bkt *Bucket) UploadPart(ctx context.Context, input *UploadPartInput, options ...Option) (*UploadPartOutput, error)

+ func (bkt *Bucket) UploadPartCopy(ctx context.Context, input *UploadPartCopyInput, options ...Option) (*UploadPartCopyOutput, error)

+ type BucketPolicy struct

+ Policy string

+ type CancelHook interface

+ Cancel func(isAbort bool)

+ func NewUploadCancelHook() CancelHook

+ type ChecksumError struct

+ ActualChecksum string

+ ExpectedChecksum string

+ RequestID string

+ func (ce *ChecksumError) Error() string

+ type Client struct

+ func NewClient(endpoint string, options ...ClientOption) (*Client, error)

+ func (cli *Client) Bucket(bucket string) (*Bucket, error)

+ func (cli *Client) CreateBucket(ctx context.Context, input *CreateBucketInput) (*CreateBucketOutput, error)

+ func (cli *Client) DeleteBucket(ctx context.Context, bucket string) (*DeleteBucketOutput, error)

+ func (cli *Client) DeleteBucketPolicy(ctx context.Context, bucket string) (*DeleteBucketPolicyOutput, error)

+ func (cli *Client) GetBucketPolicy(ctx context.Context, bucket string) (*GetBucketPolicyOutput, error)

+ func (cli *Client) GetBucketVersioning(ctx context.Context, bucket string) (*GetBucketVersioningOutput, error)

+ func (cli *Client) HeadBucket(ctx context.Context, bucket string) (*HeadBucketOutput, error)

+ func (cli *Client) ListBuckets(ctx context.Context, _ *ListBucketsInput) (*ListBucketsOutput, error)

+ func (cli *Client) PreSignedURL(httpMethod string, bucket, objectKey string, ttl time.Duration, ...) (string, error)

+ func (cli *Client) PutBucketPolicy(ctx context.Context, bucket string, policy *BucketPolicy) (*PutBucketPolicyOutput, error)

+ type ClientOption func(*Client)

+ func WithAutoRecognizeContentType(enable bool) ClientOption

+ func WithConnectionTimeout(timeout time.Duration) ClientOption

+ func WithContentTypeRecognizer(recognizer ContentTypeRecognizer) ClientOption

+ func WithCredentials(credentials Credentials) ClientOption

+ func WithEnableVerifySSL(enable bool) ClientOption

+ func WithIdleConnTimeout(timeout time.Duration) ClientOption

+ func WithMaxConnections(max int) ClientOption

+ func WithPathAccessMode(pathAccessMode bool) ClientOption

+ func WithRegion(region string) ClientOption

+ func WithRequestTimeout(timeout time.Duration) ClientOption

+ func WithSigner(signer Signer) ClientOption

+ func WithSocketTimeout(readTimeout, writeTimeout time.Duration) ClientOption

+ func WithTransport(transport Transport) ClientOption

+ func WithTransportConfig(config *TransportConfig) ClientOption

+ func WithUserAgentSuffix(suffix string) ClientOption

+ type ClientV2 struct

+ func NewClientV2(endpoint string, options ...ClientOption) (*ClientV2, error)

+ func (cli *ClientV2) AbortMultipartUpload(ctx context.Context, input *AbortMultipartUploadInput) (*AbortMultipartUploadOutput, error)

+ func (cli *ClientV2) AppendObjectV2(ctx context.Context, input *AppendObjectV2Input) (*AppendObjectV2Output, error)

+ func (cli *ClientV2) CompleteMultipartUploadV2(ctx context.Context, input *CompleteMultipartUploadV2Input) (*CompleteMultipartUploadV2Output, error)

+ func (cli *ClientV2) CopyObject(ctx context.Context, input *CopyObjectInput) (*CopyObjectOutput, error)

+ func (cli *ClientV2) CreateBucketV2(ctx context.Context, input *CreateBucketV2Input) (*CreateBucketV2Output, error)

+ func (cli *ClientV2) CreateMultipartUploadV2(ctx context.Context, input *CreateMultipartUploadV2Input) (*CreateMultipartUploadV2Output, error)

+ func (cli *ClientV2) DeleteBucket(ctx context.Context, input *DeleteBucketInput) (*DeleteBucketOutput, error)

+ func (cli *ClientV2) DeleteMultiObjects(ctx context.Context, input *DeleteMultiObjectsInput) (*DeleteMultiObjectsOutput, error)

+ func (cli *ClientV2) DeleteObjectV2(ctx context.Context, input *DeleteObjectV2Input) (*DeleteObjectV2Output, error)

+ func (cli *ClientV2) GetObjectACL(ctx context.Context, input *GetObjectACLInput) (*GetObjectACLOutput, error)

+ func (cli *ClientV2) GetObjectToFile(ctx context.Context, input *GetObjectToFileInput) (*GetObjectToFileOutput, error)

+ func (cli *ClientV2) GetObjectV2(ctx context.Context, input *GetObjectV2Input) (*GetObjectV2Output, error)

+ func (cli *ClientV2) HeadBucket(ctx context.Context, input *HeadBucketInput) (*HeadBucketOutput, error)

+ func (cli *ClientV2) HeadObjectV2(ctx context.Context, input *HeadObjectV2Input) (*HeadObjectV2Output, error)

+ func (cli *ClientV2) ListBucketsV2(ctx context.Context, _ *ListBucketsV2Input) (*ListBucketsV2Output, error)

+ func (cli *ClientV2) ListMultipartUploadsV2(ctx context.Context, input *ListMultipartUploadsV2Input) (*ListMultipartUploadsV2Output, error)

+ func (cli *ClientV2) ListObjectVersionsV2(ctx context.Context, input *ListObjectVersionsV2Input) (*ListObjectVersionsV2Output, error)

+ func (cli *ClientV2) ListObjectsV2(ctx context.Context, input *ListObjectsV2Input) (*ListObjectsV2Output, error)

+ func (cli *ClientV2) ListParts(ctx context.Context, input *ListPartsInput) (*ListPartsOutput, error)

+ func (cli *ClientV2) PreSignedURL(input *PreSignedURLInput) (*PreSignedURLOutput, error)

+ func (cli *ClientV2) PutObjectACL(ctx context.Context, input *PutObjectACLInput) (*PutObjectACLOutput, error)

+ func (cli *ClientV2) PutObjectFromFile(ctx context.Context, input *PutObjectFromFileInput) (*PutObjectFromFileOutput, error)

+ func (cli *ClientV2) PutObjectV2(ctx context.Context, input *PutObjectV2Input) (*PutObjectV2Output, error)

+ func (cli *ClientV2) SetObjectMeta(ctx context.Context, input *SetObjectMetaInput) (*SetObjectMetaOutput, error)

+ func (cli *ClientV2) UploadFile(ctx context.Context, input *UploadFileInput) (output *UploadFileOutput, err error)

+ func (cli *ClientV2) UploadPartCopyV2(ctx context.Context, input *UploadPartCopyV2Input) (*UploadPartCopyV2Output, error)

+ func (cli *ClientV2) UploadPartFromFile(ctx context.Context, input *UploadPartFromFileInput) (*UploadPartFromFileOutput, error)

+ func (cli *ClientV2) UploadPartV2(ctx context.Context, input *UploadPartV2Input) (*UploadPartV2Output, error)

+ type CommonHeaders struct

+ ACL enum.ACLType

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentLength int64

+ ContentMD5 string

+ ContentSHA256 string

+ ContentType string

+ Expires time.Time

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWriteAcp string

+ StorageClass enum.StorageClassType

+ WebsiteRedirectLocation string

+ type CompleteMultipartUploadInput struct

+ Key string

+ UploadID string

+ UploadedParts []MultipartUploadedPart

+ type CompleteMultipartUploadOutput struct

+ VersionID string

+ type CompleteMultipartUploadV2Input struct

+ Bucket string

+ Key string

+ Parts []UploadedPartV2

+ UploadID string

+ type CompleteMultipartUploadV2Output struct

+ Bucket string

+ ETag string

+ HashCrc64ecma uint64

+ Key string

+ Location string

+ VersionID string

+ type Config struct

+ Endpoint string

+ Region string

+ TransportConfig TransportConfig

+ type ContentTypeRecognizer interface

+ ContentType func(objectKey string) string

+ type CopyObjectInput struct

+ ACL enum.ACLType

+ Bucket string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ CopySourceIfMatch string

+ CopySourceIfModifiedSince time.Time

+ CopySourceIfNoneMatch string

+ CopySourceIfUnmodifiedSince time.Time

+ CopySourceSSECAlgorithm string

+ CopySourceSSECKey string

+ CopySourceSSECKeyMD5 string

+ Expires time.Time

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWriteAcp string

+ Key string

+ Meta map[string]string

+ MetadataDirective enum.MetadataDirectiveType

+ ServerSideEncryption string

+ SrcBucket string

+ SrcKey string

+ SrcVersionID string

+ StorageClass enum.StorageClassType

+ WebsiteRedirectLocation string

+ type CopyObjectOutput struct

+ ETag string

+ LastModified string

+ SourceVersionID string

+ VersionID string

+ type CopySource struct

+ type CreateBucketInput struct

+ ACL string

+ Bucket string

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWrite string

+ GrantWriteAcp string

+ type CreateBucketOutput struct

+ Location string

+ type CreateBucketV2Input struct

+ ACL enum.ACLType

+ AzRedundancy enum.AzRedundancyType

+ Bucket string

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWrite string

+ GrantWriteAcp string

+ StorageClass enum.StorageClassType

+ type CreateBucketV2Output struct

+ type CreateMultipartUploadOutput struct

+ Bucket string

+ Key string

+ SSECustomerAlgorithm string

+ SSECustomerKeyMD5 string

+ UploadID string

+ type CreateMultipartUploadV2Input struct

+ ACL enum.ACLType

+ Bucket string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ EncodingType string

+ Expires time.Time

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWriteAcp string

+ Key string

+ Meta map[string]string

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ ServerSideEncryption string

+ StorageClass enum.StorageClassType

+ WebsiteRedirectLocation string

+ type CreateMultipartUploadV2Output struct

+ Bucket string

+ EncodingType string

+ Key string

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ UploadID string

+ type Credential struct

+ AccessKeyID string

+ AccessKeySecret string

+ SecurityToken string

+ type Credentials interface

+ Credential func() Credential

+ type DataTransferListener interface

+ DataTransferStatusChange func(status *DataTransferStatus)

+ type DataTransferStatus struct

+ ConsumedBytes int64

+ RWOnceBytes int64

+ TotalBytes int64

+ Type enum.DataTransferType

+ type DefaultTransport struct

+ func NewDefaultTransport(config *TransportConfig) *DefaultTransport

+ func NewDefaultTransportWithClient(client http.Client) *DefaultTransport

+ func (dt *DefaultTransport) RoundTrip(ctx context.Context, req *Request) (*Response, error)

+ type DeleteBucketInput struct

+ Bucket string

+ type DeleteBucketOutput struct

+ type DeleteBucketPolicyOutput struct

+ type DeleteError struct

+ Code string

+ Key string

+ Message string

+ VersionID string

+ type DeleteMultiObjectsInput struct

+ Bucket string

+ Objects []ObjectTobeDeleted

+ Quiet bool

+ type DeleteMultiObjectsOutput struct

+ Deleted []Deleted

+ Error []DeleteError

+ type DeleteObjectOutput struct

+ DeleteMarker bool

+ VersionID string

+ type DeleteObjectV2Input struct

+ Bucket string

+ Key string

+ VersionID string

+ type DeleteObjectV2Output struct

+ type Deleted struct

+ DeleteMarker *bool

+ DeleteMarkerVersionID string

+ Key string

+ VersionID string

+ type DownloadEvent struct

+ Bucket string

+ CheckpointFile *string

+ DowloadPartInfo *DownloadPartInfo

+ Err error

+ FilePath string

+ Key string

+ TempFilePath *string

+ Type enum.DownloadEventType

+ VersionID string

+ type DownloadEventListener interface

+ EventChange func(event *DownloadEvent)

+ type DownloadFileInput struct

+ CancelHook CancelHook

+ CheckpointFile string

+ DataTransferListener DataTransferListener

+ DownloadEventListener DownloadEventListener

+ EnableCheckpoint bool

+ FilePath string

+ PartSize int64

+ RateLimiter RateLimiter

+ TaskNum int

+ type DownloadFileOutput struct

+ type DownloadPartInfo struct

+ PartNumber int

+ RangeEnd int64

+ RangeStart int64

+ type ETagCheckReadCloser struct

+ func NewETagCheckReadCloser(reader io.ReadCloser, eTag, requestID string) *ETagCheckReadCloser

+ func (ec *ETagCheckReadCloser) Close() error

+ func (ec *ETagCheckReadCloser) Read(p []byte) (n int, err error)

+ type EmptyContentTypeRecognizer struct

+ func (er EmptyContentTypeRecognizer) ContentType(objectKey string) string

+ type Error struct

+ Code string

+ HostID string

+ Message string

+ RequestID string

+ Resource string

+ StatusCode int

+ func (e *Error) Error() string

+ type ExtensionBasedContentTypeRecognizer struct

+ func (er ExtensionBasedContentTypeRecognizer) ContentType(objectKey string) string

+ type FederationCredentials struct

+ func NewFederationCredentials(tokenProvider FederationTokenProvider) (*FederationCredentials, error)

+ func (fc *FederationCredentials) Credential() Credential

+ func (fc *FederationCredentials) WithPreFetch(preFetch time.Duration)

+ type FederationToken struct

+ Credential Credential

+ Expiration time.Time

+ type FederationTokenProvider interface

+ FederationToken func() (*FederationToken, error)

+ type FetchObjectInput struct

+ ContentMD5 string

+ IgnoreSameKey bool

+ Key string

+ URL string

+ type FetchObjectOutput struct

+ ETag string

+ VersionID string

+ type GetBucketPolicyOutput struct

+ Policy string

+ type GetBucketVersioningOutput struct

+ Status string

+ type GetObjectACLInput struct

+ Bucket string

+ Key string

+ VersionID string

+ type GetObjectACLOutput struct

+ Grants []Grant

+ Owner Owner

+ VersionID string

+ type GetObjectAclOutput struct

+ Grants []Grant

+ Owner Owner

+ VersionID string

+ type GetObjectBasicOutput struct

+ ContentRange string

+ type GetObjectOutput struct

+ Content io.ReadCloser

+ ContentRange string

+ type GetObjectToFileInput struct

+ FilePath string

+ type GetObjectToFileOutput struct

+ type GetObjectV2Input struct

+ Bucket string

+ DataTransferListener DataTransferListener

+ IfMatch string

+ IfModifiedSince time.Time

+ IfNoneMatch string

+ IfUnmodifiedSince time.Time

+ Key string

+ RangeEnd int64

+ RangeStart int64

+ RateLimiter RateLimiter

+ ResponseCacheControl string

+ ResponseContentDisposition string

+ ResponseContentEncoding string

+ ResponseContentLanguage string

+ ResponseContentType string

+ ResponseExpires time.Time

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ VersionID string

+ type GetObjectV2Output struct

+ Content io.ReadCloser

+ type Grant struct

+ Grantee Grantee

+ Permission enum.PermissionType

+ type Grantee struct

+ DisplayName string

+ ID string

+ Type string

+ URI string

+ type HeadBucketInput struct

+ Bucket string

+ type HeadBucketOutput struct

+ Region string

+ StorageClass enum.StorageClassType

+ type HeadObjectOutput struct

+ ContentRange string

+ type HeadObjectV2Input struct

+ Bucket string

+ IfMatch string

+ IfModifiedSince time.Time

+ IfNoneMatch string

+ IfUnmodifiedSince time.Time

+ Key string

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ VersionID string

+ type HeadObjectV2Output struct

+ type KV struct

+ Key string

+ Values []string

+ type KVs []KV

+ func (kvs KVs) Len() int

+ func (kvs KVs) Less(i, j int) bool

+ func (kvs KVs) Swap(i, j int)

+ type ListBucketsInput struct

+ type ListBucketsOutput struct

+ Buckets []ListedBucket

+ Owner ListedOwner

+ type ListBucketsV2Input ListBucketsInput

+ type ListBucketsV2Output struct

+ Buckets []ListedBucket

+ Owner Owner

+ type ListMultipartUploadsInput struct

+ Delimiter string

+ KeyMarker string

+ MaxUploads int

+ Prefix string

+ UploadIDMarker string

+ type ListMultipartUploadsOutput struct

+ Bucket string

+ CommonPrefixes []UploadCommonPrefix

+ Delimiter string

+ IsTruncated bool

+ KeyMarker string

+ MaxUploads int32

+ NextKeyMarker string

+ NextUploadIdMarker string

+ Prefix string

+ Upload []UploadInfo

+ UploadIdMarker string

+ type ListMultipartUploadsV2Input struct

+ Bucket string

+ Delimiter string

+ EncodingType string

+ KeyMarker string

+ MaxUploads int

+ Prefix string

+ UploadIDMarker string

+ type ListMultipartUploadsV2Output struct

+ Bucket string

+ CommonPrefixes []ListedCommonPrefix

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ MaxUploads int

+ NextKeyMarker string

+ NextUploadIDMarker string

+ Prefix string

+ UploadIDMarker string

+ Uploads []ListedUpload

+ type ListObjectVersionsInput struct

+ Delimiter string

+ EncodingType string

+ KeyMarker string

+ MaxKeys int

+ Prefix string

+ VersionIDMarker string

+ type ListObjectVersionsOutput struct

+ CommonPrefixes []ListedCommonPrefix

+ DeleteMarkers []ListedDeleteMarkerEntry

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ MaxKeys int64

+ Name string

+ NextKeyMarker string

+ NextVersionIDMarker string

+ Prefix string

+ VersionIDMarker string

+ Versions []ListedObjectVersion

+ type ListObjectVersionsV2Input struct

+ Bucket string

+ type ListObjectVersionsV2Output struct

+ CommonPrefixes []ListedCommonPrefix

+ DeleteMarkers []ListedDeleteMarker

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ MaxKeys int64

+ Name string

+ NextKeyMarker string

+ NextVersionIDMarker string

+ Prefix string

+ VersionIDMarker string

+ Versions []ListedObjectVersion

+ type ListObjectsInput struct

+ Delimiter string

+ EncodingType string

+ Marker string

+ MaxKeys int

+ Prefix string

+ Reverse bool

+ type ListObjectsOutput struct

+ CommonPrefixes []ListedCommonPrefix

+ Contents []ListedObject

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ Marker string

+ MaxKeys int64

+ Name string

+ NextMarker string

+ Prefix string

+ type ListObjectsV2Input struct

+ Bucket string

+ type ListObjectsV2Output struct

+ type ListPartsInput struct

+ Bucket string

+ EncodingType string

+ Key string

+ MaxParts int

+ PartNumberMarker int

+ UploadID string

+ type ListPartsOutput struct

+ Bucket string

+ EncodingType string

+ IsTruncated bool

+ Key string

+ MaxParts int

+ NextPartNumberMarker int

+ Owner Owner

+ PartNumberMarker int

+ Parts []UploadedPart

+ StorageClass enum.StorageClassType

+ UploadID string

+ type ListUploadedPartsInput struct

+ Key string

+ MaxParts int

+ PartNumberMarker int

+ UploadID string

+ type ListUploadedPartsOutput struct

+ Bucket string

+ IsTruncated bool

+ Key string

+ MaxParts int

+ NextPartNumberMarker int

+ Owner Owner

+ PartNumberMarker int

+ StorageClass string

+ UploadID string

+ UploadedParts []UploadedPart

+ type ListedBucket struct

+ CreationDate string

+ ExtranetEndpoint string

+ IntranetEndpoint string

+ Location string

+ Name string

+ type ListedCommonPrefix struct

+ Prefix string

+ type ListedDeleteMarker struct

+ IsLatest bool

+ Key string

+ LastModified time.Time

+ Owner Owner

+ VersionID string

+ type ListedDeleteMarkerEntry struct

+ IsLatest bool

+ Key string

+ LastModified string

+ Owner Owner

+ VersionID string

+ type ListedObject struct

+ ETag string

+ HashCrc64ecma uint64

+ Key string

+ LastModified string

+ Owner Owner

+ Size int64

+ StorageClass string

+ type ListedObjectVersion struct

+ ETag string

+ HashCrc64ecma uint64

+ IsLatest bool

+ Key string

+ LastModified string

+ Owner Owner

+ Size int64

+ StorageClass string

+ VersionID string

+ type ListedOwner struct

+ ID string

+ type ListedUpload struct

+ Initiated time.Time

+ Key string

+ Owner Owner

+ StorageClass enum.StorageClassType

+ UploadID string

+ type MultipartUploadedPart interface

+ type NoRetryClassifier struct

+ func (classifier NoRetryClassifier) Classify(_ error) retryAction

+ type ObjectAclGrant struct

+ ACL string

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWrite string

+ GrantWriteAcp string

+ type ObjectAclRules struct

+ Grants []Grant

+ Owner Owner

+ type ObjectMeta struct

+ CSType string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentLength int64

+ ContentMD5 string

+ ContentType string

+ DeleteMarker bool

+ ETag string

+ Expires string

+ LastModified string

+ Metadata map[string]string

+ ObjectType string

+ Restore string

+ SSECustomerAlgorithm string

+ SSECustomerKeyMD5 string

+ StorageClass string

+ Tag string

+ VersionID string

+ type ObjectMetaV2 struct

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentLength int64

+ ContentRange string

+ ContentType string

+ DeleteMarker bool

+ ETag string

+ Expires time.Time

+ HashCrc64ecma uint64

+ LastModified time.Time

+ Meta map[string]string

+ ObjectType string

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ StorageClass enum.StorageClassType

+ VersionID string

+ WebsiteRedirectLocation string

+ type ObjectTobeDeleted struct

+ Key string

+ VersionID string

+ type Option func(*requestBuilder)

+ func WithACL(acl string) Option

+ func WithACLGrantFullControl(grantFullControl string) Option

+ func WithACLGrantRead(grantRead string) Option

+ func WithACLGrantReadAcp(grantReadAcp string) Option

+ func WithACLGrantWrite(grantWrite string) Option

+ func WithACLGrantWriteAcp(grantWriteAcp string) Option

+ func WithCacheControl(cacheControl string) Option

+ func WithContentDisposition(contentDisposition string) Option

+ func WithContentEncoding(contentEncoding string) Option

+ func WithContentLanguage(contentLanguage string) Option

+ func WithContentLength(length int64) Option

+ func WithContentMD5(contentMD5 string) Option

+ func WithContentSHA256(contentSHA256 string) Option

+ func WithContentType(contentType string) Option

+ func WithCopySourceIfMatch(ifMatch string) Option

+ func WithCopySourceIfModifiedSince(ifModifiedSince string) Option

+ func WithCopySourceIfNoneMatch(ifNoneMatch string) Option

+ func WithCopySourceIfUnmodifiedSince(ifUnmodifiedSince string) Option

+ func WithExpires(expires time.Time) Option

+ func WithHeader(key, value string) Option

+ func WithIfMatch(ifMatch string) Option

+ func WithIfModifiedSince(since time.Time) Option

+ func WithIfNoneMatch(ifNoneMatch string) Option

+ func WithIfUnmodifiedSince(since time.Time) Option

+ func WithMeta(key, value string) Option

+ func WithMetadataDirective(directive string) Option

+ func WithPerRequestSigner(signer Signer) Option

+ func WithQuery(key, value string) Option

+ func WithRange(start, end int64) Option

+ func WithServerSideEncryptionCustomer(ssecAlgorithm, ssecKey, ssecKeyMD5 string) Option

+ func WithVersionID(versionID string) Option

+ func WithWebsiteRedirectLocation(redirectLocation string) Option

+ type Owner struct

+ DisplayName string

+ ID string

+ type PreSignedURLInput struct

+ Bucket string

+ Expires int64

+ HTTPMethod enum.HttpMethodType

+ Header map[string]string

+ Key string

+ Query map[string]string

+ type PreSignedURLOutput struct

+ SignedHeader map[string]string

+ SignedUrl string

+ type Proxy struct

+ func NewProxy(proxyHost string, proxyPort int) *Proxy

+ func (p *Proxy) WithAuth(username string, password string)

+ type PutBucketPolicyOutput struct

+ type PutObjectACLInput struct

+ ACL enum.ACLType

+ Bucket string

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWrite string

+ GrantWriteAcp string

+ Grants []Grant

+ Key string

+ Owner Owner

+ VersionID string

+ type PutObjectACLOutput struct

+ type PutObjectAclInput struct

+ AclGrant *ObjectAclGrant

+ AclRules *ObjectAclRules

+ Key string

+ VersionID string

+ type PutObjectAclOutput struct

+ type PutObjectBasicInput struct

+ ACL enum.ACLType

+ Bucket string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentLength int64

+ ContentMD5 string

+ ContentSHA256 string

+ ContentType string

+ DataTransferListener DataTransferListener

+ Expires time.Time

+ GrantFullControl string

+ GrantRead string

+ GrantReadAcp string

+ GrantWriteAcp string

+ Key string

+ Meta map[string]string

+ RateLimiter RateLimiter

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ ServerSideEncryption string

+ StorageClass enum.StorageClassType

+ WebsiteRedirectLocation string

+ type PutObjectFromFileInput struct

+ FilePath string

+ type PutObjectFromFileOutput struct

+ type PutObjectOutput struct

+ ETag string

+ SSECustomerAlgorithm string

+ SSECustomerKeyMD5 string

+ VersionID string

+ type PutObjectV2Input struct

+ Content io.Reader

+ type PutObjectV2Output struct

+ ETag string

+ HashCrc64ecma uint64

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ VersionID string

+ type Range struct

+ End int64

+ Start int64

+ func (hr *Range) String() string

+ type RateLimiter interface

+ Acquire func(want int64) (ok bool, timeToWait time.Duration)

+ type ReadCloserWithLimiter struct

+ func (r ReadCloserWithLimiter) Close() error

+ func (r ReadCloserWithLimiter) Read(p []byte) (n int, err error)

+ type Request struct

+ Content io.Reader

+ ContentLength *int64

+ Header http.Header

+ Host string

+ Method string

+ Path string

+ Query url.Values

+ Scheme string

+ func (req *Request) URL() string

+ type RequestInfo struct

+ Header http.Header

+ ID2 string

+ RequestID string

+ StatusCode int

+ type Response struct

+ Body io.ReadCloser

+ ContentLength int64

+ Header http.Header

+ StatusCode int

+ func (r *Response) Close() error

+ func (r *Response) RequestInfo() RequestInfo

+ type SSEHeaders struct

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ ServerSideEncryption string

+ type SerializeError struct

+ Message string

+ RequestID string

+ func (se *SerializeError) Error() string

+ type ServerErrorClassifier struct

+ func (classifier ServerErrorClassifier) Classify(err error) retryAction

+ type SetObjectMetaInput struct

+ Bucket string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ Expires time.Time

+ Key string

+ Meta map[string]string

+ VersionID string

+ type SetObjectMetaOutput struct

+ type SignV4 struct

+ func NewSignV4(credentials Credentials, region string) *SignV4

+ func (sv *SignV4) SignHeader(req *Request) http.Header

+ func (sv *SignV4) SignQuery(req *Request, ttl time.Duration) url.Values

+ func (sv *SignV4) WithSigningKey(signingKey func(*SigningKeyInfo) []byte)

+ type Signer interface

+ SignHeader func(req *Request) http.Header

+ SignQuery func(req *Request, ttl time.Duration) url.Values

+ type SigningKeyInfo struct

+ Credential *Credential

+ Date string

+ Region string

+ type StaticCredentials struct

+ func NewStaticCredentials(accessKeyID, accessKeySecret string) *StaticCredentials

+ func (sc *StaticCredentials) Credential() Credential

+ func (sc *StaticCredentials) WithSecurityToken(securityToken string)

+ type StatusCodeClassifier struct

+ func (classifier StatusCodeClassifier) Classify(err error) retryAction

+ type TimeoutConn struct

+ func NewTimeoutConn(conn net.Conn, readTimeout, writeTimeout time.Duration) *TimeoutConn

+ func (tc *TimeoutConn) Read(b []byte) (n int, err error)

+ func (tc *TimeoutConn) Write(b []byte) (n int, err error)

+ type TimeoutDialer struct

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func (d *TimeoutDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ type TosClientError struct

+ Cause error

+ type TosError struct

+ Message string

+ func (e *TosError) Error() string

+ type TosServerError struct

+ Code string

+ HostID string

+ Resource string

+ type Transport interface

+ RoundTrip func(context.Context, *Request) (*Response, error)

+ type TransportConfig struct

+ DialTimeout time.Duration

+ ExpectContinueTimeout time.Duration

+ IdleConnTimeout time.Duration

+ InsecureSkipVerify bool

+ KeepAlive time.Duration

+ MaxIdleConns int

+ ReadTimeout time.Duration

+ RequestTimeout time.Duration

+ ResponseHeaderTimeout time.Duration

+ TLSHandshakeTimeout time.Duration

+ WriteTimeout time.Duration

+ func DefaultTransportConfig() TransportConfig

+ type UnexpectedStatusCodeError struct

+ ExpectedCodes []int

+ RequestID string

+ StatusCode int

+ func NewUnexpectedStatusCodeError(statusCode int, expectedCode int, expectedCodes ...int) *UnexpectedStatusCodeError

+ func (us *UnexpectedStatusCodeError) Error() string

+ func (us *UnexpectedStatusCodeError) GoString() string

+ func (us *UnexpectedStatusCodeError) WithRequestID(requestID string) *UnexpectedStatusCodeError

+ type UploadCommonPrefix struct

+ Prefix string

+ type UploadEvent struct

+ Bucket string

+ CheckpointFile *string

+ Err error

+ Key string

+ Type enum.UploadEventType

+ UploadID *string

+ UploadPartInfo *UploadPartInfo

+ type UploadEventListener interface

+ EventChange func(event *UploadEvent)

+ type UploadFileInput struct

+ CancelHook CancelHook

+ CheckpointFile string

+ DataTransferListener DataTransferListener

+ EnableCheckpoint bool

+ FilePath string

+ PartSize int64

+ RateLimiter RateLimiter

+ TaskNum int

+ UploadEventListener UploadEventListener

+ type UploadFileOutput struct

+ Bucket string

+ ETag string

+ EncodingType string

+ HashCrc64ecma uint64

+ Key string

+ Location string

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ UploadID string

+ VersionID string

+ type UploadInfo struct

+ Initiated string

+ Key string

+ Owner Owner

+ StorageClass string

+ UploadId string

+ type UploadPartBasicInput struct

+ Bucket string

+ ContentMD5 string

+ DataTransferListener DataTransferListener

+ Key string

+ PartNumber int

+ RateLimiter RateLimiter

+ SSECAlgorithm string

+ SSECKey string

+ SSECKeyMD5 string

+ ServerSideEncryption string

+ UploadID string

+ type UploadPartCopyInput struct

+ DestinationKey string

+ PartNumber int

+ PartSize *int64

+ SourceBucket string

+ SourceKey string

+ SourceVersionID string

+ StartOffset *int64

+ UploadID string

+ type UploadPartCopyOutput struct

+ ETag string

+ LastModified string

+ PartNumber int

+ SourceVersionID string

+ VersionID string

+ type UploadPartCopyV2Input struct

+ Bucket string

+ CopySourceIfMatch string

+ CopySourceIfModifiedSince time.Time

+ CopySourceIfNoneMatch string

+ CopySourceIfUnmodifiedSince time.Time

+ CopySourceRangeEnd int64

+ CopySourceRangeStart int64

+ CopySourceSSECAlgorithm string

+ CopySourceSSECKey string

+ CopySourceSSECKeyMD5 string

+ Key string

+ PartNumber int

+ SrcBucket string

+ SrcKey string

+ SrcVersionID string

+ UploadID string

+ type UploadPartCopyV2Output struct

+ CopySourceVersionID string

+ ETag string

+ LastModified time.Time

+ PartNumber int

+ type UploadPartFromFileInput struct

+ FilePath string

+ Offset uint64

+ PartSize int64

+ type UploadPartFromFileOutput struct

+ type UploadPartInfo struct

+ ETag *string

+ HashCrc64ecma *uint64

+ Offset int64

+ PartNumber int

+ PartSize int64

+ type UploadPartInput struct

+ Content io.Reader

+ Key string

+ PartNumber int

+ UploadID string

+ type UploadPartOutput struct

+ ETag string

+ PartNumber int

+ SSECustomerAlgorithm string

+ SSECustomerKeyMD5 string

+ type UploadPartV2Input struct

+ Content io.Reader

+ ContentLength int64

+ type UploadPartV2Output struct

+ ETag string

+ HashCrc64ecma uint64

+ PartNumber int

+ SSECAlgorithm string

+ SSECKeyMD5 string

+ type UploadedPart struct

+ ETag string

+ LastModified string

+ PartNumber int32

+ Size int64

+ type UploadedPartV2 struct

+ ETag string

+ PartNumber int

+ type WithoutSecretKeyCredentials struct

+ func NewWithoutSecretKeyCredentials(accessKeyID string) *WithoutSecretKeyCredentials

+ func (sc *WithoutSecretKeyCredentials) Credential() Credential

+ func (sc *WithoutSecretKeyCredentials) WithSecurityToken(securityToken string)

Other modules containing this package

github.com/volcengine/ve-tos-golang-sdk

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL