Versions in this module Expand all Collapse all v1 v1.0.0 May 29, 2024 Changes in this version + const AsyncReadeBufferSize + const BwTokenBucketSlotRx + const BwTokenBucketSlotTx + const BwTokenBucketSlots + const CheckpointFileSuffixDownloader + const CheckpointFileSuffixUploader + const CheckpointMagic + const ContinuousFrameType + const DataFrameType + const DefaultCopyParallel + const DefaultCopyPartSize + const DefaultCopyThreshold + const DefaultDownloadParallel + const DefaultDownloadPartSize + const DefaultEndpointScheme + const DefaultParallel + const DefaultPartSize + const DefaultPrefetchChunkSize + const DefaultPrefetchNum + const DefaultPrefetchThreshold + const DefaultProduct + const DefaultSignatureVersion + const DefaultUploadParallel + const DefaultUploadPartSize + const EncryptionUaSuffix + const EndFrameType + const FilePermMode + const HTTPHeaderAcceptEncoding + const HTTPHeaderAuthorization + const HTTPHeaderCacheControl + const HTTPHeaderContentDisposition + const HTTPHeaderContentEncoding + const HTTPHeaderContentLanguage + const HTTPHeaderContentLength + const HTTPHeaderContentMD5 + const HTTPHeaderContentRange + const HTTPHeaderContentType + const HTTPHeaderDate + const HTTPHeaderETag + const HTTPHeaderExpires + const HTTPHeaderHost + const HTTPHeaderIfMatch + const HTTPHeaderIfModifiedSince + const HTTPHeaderIfNoneMatch + const HTTPHeaderIfUnmodifiedSince + const HTTPHeaderLastModified + const HTTPHeaderLocation + const HTTPHeaderRange + const HTTPHeaderUserAgent + const HeaderOssACL + const HeaderOssAllowSameActionOverLap + const HeaderOssCRC64 + const HeaderOssCallback + const HeaderOssCallbackVar + const HeaderOssContentSha256 + const HeaderOssCopySource + const HeaderOssCopySourceIfMatch + const HeaderOssCopySourceIfModifiedSince + const HeaderOssCopySourceIfNoneMatch + const HeaderOssCopySourceIfUnmodifiedSince + const HeaderOssCopySourceRange + const HeaderOssDate + const HeaderOssEC + const HeaderOssERR + const HeaderOssForbidOverWrite + const HeaderOssMetaPrefix + const HeaderOssMetadataDirective + const HeaderOssNextAppendPosition + const HeaderOssObjectACL + const HeaderOssObjectType + const HeaderOssPrefix + const HeaderOssRangeBehavior + const HeaderOssRequestID + const HeaderOssRequester + const HeaderOssSSECAlgorithm + const HeaderOssSSECKey + const HeaderOssSSECKeyMd5 + const HeaderOssSecurityToken + const HeaderOssServerSideDataEncryption + const HeaderOssServerSideEncryption + const HeaderOssServerSideEncryptionKeyID + const HeaderOssStorageClass + const HeaderOssSymlinkTarget + const HeaderOssTagging + const HeaderOssTaggingDirective + const HeaderOssTrafficLimit + const LogDebug + const LogError + const LogInfo + const LogOff + const LogWarn + const MaxPartSize + const MaxUploadParts + const MetaEndFrameCSVType + const MetaEndFrameJSONType + const MinPartSize + const OpMetaKeyRequestBodyTracker + const OpMetaKeyResponsHandler + const OssClientSideEncryptionCekAlg + const OssClientSideEncryptionDataSize + const OssClientSideEncryptionKey + const OssClientSideEncryptionMatDesc + const OssClientSideEncryptionPartSize + const OssClientSideEncryptionStart + const OssClientSideEncryptionUnencryptedContentLength + const OssClientSideEncryptionUnencryptedContentMD5 + const OssClientSideEncryptionWrapAlg + const SdkName + const TempFileSuffix + func CRC64Combine(crc1 uint64, crc2 uint64, len2 uint64) uint64 + func DirExists(dir string) bool + func EmptyFile(filename string) bool + func FileExists(filename string) bool + func GetReaderLen(r io.Reader) int64 + func NewCRC64(init uint64) hash.Hash64 + func NewLimitedReadCloser(rc io.ReadCloser, limit int64) io.ReadCloser + func NewProgress(pr ProgressFunc, total int64) io.Writer + func OpReadWriteTimeout(value time.Duration) func(*Options) + func ParseContentRange(s string) (from int64, to int64, total int64, err error) + func ParseOffsetAndSizeFromHeaders(headers http.Header) (offset, size int64) + func PresignExpiration(value time.Time) func(*PresignOptions) + func PresignExpires(value time.Duration) func(*PresignOptions) + func Ptr[T any](v T) *T + func SliceOfPtrs[T any](vv ...T) []*T + func TeeReadNopCloser(reader io.Reader, writers ...io.Writer) io.ReadCloser + func ToBool(p *bool) (v bool) + func ToDuration(p *time.Duration) (v time.Duration) + func ToInt(p *int) (v int) + func ToInt64(p *int64) (v int64) + func ToLogLevel(s string) int + func ToString(p *string) (v string) + func ToTime(p *time.Time) (v time.Time) + func TypeByExtension(filePath string) string + func Version() string + type AbortMultipartUploadRequest struct + Bucket *string + Key *string + RequestPayer *string + UploadId *string + type AbortMultipartUploadResult struct + type AppendFileAPIClient interface + AppendObject func(ctx context.Context, request *AppendObjectRequest, optFns ...func(*Options)) (*AppendObjectResult, error) + HeadObject func(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + type AppendObjectRequest struct + Acl ObjectACLType + Body io.Reader + Bucket *string + CacheControl *string + ContentDisposition *string + ContentEncoding *string + ContentLength *int64 + ContentMD5 *string + ContentType *string + Expires *string + ForbidOverwrite *string + InitHashCRC64 *string + Key *string + Metadata map[string]string + Position *int64 + ProgressFn ProgressFunc + RequestPayer *string + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + StorageClass StorageClassType + Tagging *string + TrafficLimit int64 + type AppendObjectResult struct + HashCRC64 *string + Metadata map[string]string + NextPosition int64 + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + VersionId *string + type AppendOnlyFile struct + func NewAppendFile(ctx context.Context, c AppendFileAPIClient, bucket string, key string, ...) (*AppendOnlyFile, error) + func (f *AppendOnlyFile) Close() error + func (f *AppendOnlyFile) Stat() (os.FileInfo, error) + func (f *AppendOnlyFile) Write(b []byte) (n int, err error) + func (f *AppendOnlyFile) WriteFrom(r io.Reader) (n int64, err error) + type AppendOptions struct + CreateParameter *AppendObjectRequest + RequestPayer *string + type AsyncProcessObjectRequest struct + AsyncProcess *string + Bucket *string + Key *string + RequestPayer *string + type AsyncProcessObjectResult struct + EventId string + RequestId string + TaskId string + type AsyncRangeReader struct + func NewAsyncRangeReader(ctx context.Context, rangeGet ReaderRangeGetFn, httpRange *HTTPRange, ...) (*AsyncRangeReader, error) + func (a *AsyncRangeReader) Close() (err error) + func (a *AsyncRangeReader) Offset() int64 + func (a *AsyncRangeReader) Read(p []byte) (n int, err error) + type AuthMethodType int + const AuthMethodHeader + const AuthMethodQuery + func (f AuthMethodType) String() string + type BucketACLType string + const BucketACLPrivate + const BucketACLPublicRead + const BucketACLPublicReadWrite + type BucketInfo struct + ACL *string + AccessMonitor *string + BucketPolicy BucketPolicy + CreationDate *time.Time + CrossRegionReplication *string + DataRedundancyType *string + ExtranetEndpoint *string + IntranetEndpoint *string + Location *string + Name *string + Owner *Owner + ResourceGroupId *string + SseRule SSERule + StorageClass *string + TransferAcceleration *string + Versioning *string + type BucketPolicy struct + LogBucket *string + LogPrefix *string + type BucketProperties struct + CreationDate *time.Time + ExtranetEndpoint *string + IntranetEndpoint *string + Location *string + Name *string + Region *string + ResourceGroupId *string + StorageClass *string + type BwTokenBucket struct + Bandwidth int64 + Limiter *rate.Limiter + func (tb *BwTokenBucket) LimitBandwidth(n int) + type BwTokenBuckets [BwTokenBucketSlots]*BwTokenBucket + type CSVSelectInput struct + AllowQuotedRecordDelimiter *bool + CommentCharacter *string + FieldDelimiter *string + FileHeaderInfo *string + QuoteCharacter *string + Range *string + RecordDelimiter *string + SplitRange *string + type CSVSelectOutput struct + FieldDelimiter *string + RecordDelimiter *string + type CanceledError struct + Err error + func (*CanceledError) CanceledError() bool + func (e *CanceledError) Error() string + func (e *CanceledError) Unwrap() error + type Client struct + func NewClient(cfg *Config, optFns ...func(*Options)) *Client + func (c *Client) AbortMultipartUpload(ctx context.Context, request *AbortMultipartUploadRequest, ...) (*AbortMultipartUploadResult, error) + func (c *Client) AppendFile(ctx context.Context, bucket string, key string, optFns ...func(*AppendOptions)) (*AppendOnlyFile, error) + func (c *Client) AppendObject(ctx context.Context, request *AppendObjectRequest, optFns ...func(*Options)) (*AppendObjectResult, error) + func (c *Client) AsyncProcessObject(ctx context.Context, request *AsyncProcessObjectRequest, ...) (*AsyncProcessObjectResult, error) + func (c *Client) CompleteMultipartUpload(ctx context.Context, request *CompleteMultipartUploadRequest, ...) (*CompleteMultipartUploadResult, error) + func (c *Client) CopyObject(ctx context.Context, request *CopyObjectRequest, optFns ...func(*Options)) (*CopyObjectResult, error) + func (c *Client) CreateSelectObjectMeta(ctx context.Context, request *CreateSelectObjectMetaRequest, ...) (*CreateSelectObjectMetaResult, error) + func (c *Client) DeleteBucket(ctx context.Context, request *DeleteBucketRequest, optFns ...func(*Options)) (*DeleteBucketResult, error) + func (c *Client) DeleteMultipleObjects(ctx context.Context, request *DeleteMultipleObjectsRequest, ...) (*DeleteMultipleObjectsResult, error) + func (c *Client) DeleteObject(ctx context.Context, request *DeleteObjectRequest, optFns ...func(*Options)) (*DeleteObjectResult, error) + func (c *Client) DeleteObjectTagging(ctx context.Context, request *DeleteObjectTaggingRequest, ...) (*DeleteObjectTaggingResult, error) + func (c *Client) GetBucketAcl(ctx context.Context, request *GetBucketAclRequest, optFns ...func(*Options)) (*GetBucketAclResult, error) + func (c *Client) GetBucketInfo(ctx context.Context, request *GetBucketInfoRequest, optFns ...func(*Options)) (*GetBucketInfoResult, error) + func (c *Client) GetBucketLocation(ctx context.Context, request *GetBucketLocationRequest, ...) (*GetBucketLocationResult, error) + func (c *Client) GetBucketRequestPayment(ctx context.Context, request *GetBucketRequestPaymentRequest, ...) (*GetBucketRequestPaymentResult, error) + func (c *Client) GetBucketStat(ctx context.Context, request *GetBucketStatRequest, optFns ...func(*Options)) (*GetBucketStatResult, error) + func (c *Client) GetBucketVersioning(ctx context.Context, request *GetBucketVersioningRequest, ...) (*GetBucketVersioningResult, error) + func (c *Client) GetObject(ctx context.Context, request *GetObjectRequest, optFns ...func(*Options)) (*GetObjectResult, error) + func (c *Client) GetObjectAcl(ctx context.Context, request *GetObjectAclRequest, optFns ...func(*Options)) (*GetObjectAclResult, error) + func (c *Client) GetObjectMeta(ctx context.Context, request *GetObjectMetaRequest, optFns ...func(*Options)) (*GetObjectMetaResult, error) + func (c *Client) GetObjectTagging(ctx context.Context, request *GetObjectTaggingRequest, ...) (*GetObjectTaggingResult, error) + func (c *Client) GetObjectToFile(ctx context.Context, request *GetObjectRequest, filePath string, ...) (*GetObjectResult, error) + func (c *Client) GetSymlink(ctx context.Context, request *GetSymlinkRequest, optFns ...func(*Options)) (*GetSymlinkResult, error) + func (c *Client) HeadObject(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + func (c *Client) InitiateMultipartUpload(ctx context.Context, request *InitiateMultipartUploadRequest, ...) (*InitiateMultipartUploadResult, error) + func (c *Client) InvokeOperation(ctx context.Context, input *OperationInput, optFns ...func(*Options)) (*OperationOutput, error) + func (c *Client) IsBucketExist(ctx context.Context, bucket string, optFns ...func(*Options)) (bool, error) + func (c *Client) IsObjectExist(ctx context.Context, bucket string, key string, ...) (bool, error) + func (c *Client) ListBuckets(ctx context.Context, request *ListBucketsRequest, optFns ...func(*Options)) (*ListBucketsResult, error) + func (c *Client) ListMultipartUploads(ctx context.Context, request *ListMultipartUploadsRequest, ...) (*ListMultipartUploadsResult, error) + func (c *Client) ListObjectVersions(ctx context.Context, request *ListObjectVersionsRequest, ...) (*ListObjectVersionsResult, error) + func (c *Client) ListObjects(ctx context.Context, request *ListObjectsRequest, optFns ...func(*Options)) (*ListObjectsResult, error) + func (c *Client) ListObjectsV2(ctx context.Context, request *ListObjectsV2Request, optFns ...func(*Options)) (*ListObjectsV2Result, error) + func (c *Client) ListParts(ctx context.Context, request *ListPartsRequest, optFns ...func(*Options)) (*ListPartsResult, error) + func (c *Client) NewCopier(optFns ...func(*CopierOptions)) *Copier + func (c *Client) NewDownloader(optFns ...func(*DownloaderOptions)) *Downloader + func (c *Client) NewListBucketsPaginator(request *ListBucketsRequest, optFns ...func(*PaginatorOptions)) *ListBucketsPaginator + func (c *Client) NewListMultipartUploadsPaginator(request *ListMultipartUploadsRequest, optFns ...func(*PaginatorOptions)) *ListMultipartUploadsPaginator + func (c *Client) NewListObjectVersionsPaginator(request *ListObjectVersionsRequest, optFns ...func(*PaginatorOptions)) *ListObjectVersionsPaginator + func (c *Client) NewListObjectsPaginator(request *ListObjectsRequest, optFns ...func(*PaginatorOptions)) *ListObjectsPaginator + func (c *Client) NewListObjectsV2Paginator(request *ListObjectsV2Request, optFns ...func(*PaginatorOptions)) *ListObjectsV2Paginator + func (c *Client) NewListPartsPaginator(request *ListPartsRequest, optFns ...func(*PaginatorOptions)) *ListPartsPaginator + func (c *Client) NewUploader(optFns ...func(*UploaderOptions)) *Uploader + func (c *Client) OpenFile(ctx context.Context, bucket string, key string, optFns ...func(*OpenOptions)) (*ReadOnlyFile, error) + func (c *Client) Presign(ctx context.Context, request any, optFns ...func(*PresignOptions)) (*PresignResult, error) + func (c *Client) ProcessObject(ctx context.Context, request *ProcessObjectRequest, optFns ...func(*Options)) (*ProcessObjectResult, error) + func (c *Client) PutBucket(ctx context.Context, request *PutBucketRequest, optFns ...func(*Options)) (*PutBucketResult, error) + func (c *Client) PutBucketAcl(ctx context.Context, request *PutBucketAclRequest, optFns ...func(*Options)) (*PutBucketAclResult, error) + func (c *Client) PutBucketRequestPayment(ctx context.Context, request *PutBucketRequestPaymentRequest, ...) (*PutBucketRequestPaymentResult, error) + func (c *Client) PutBucketVersioning(ctx context.Context, request *PutBucketVersioningRequest, ...) (*PutBucketVersioningResult, error) + func (c *Client) PutObject(ctx context.Context, request *PutObjectRequest, optFns ...func(*Options)) (*PutObjectResult, error) + func (c *Client) PutObjectAcl(ctx context.Context, request *PutObjectAclRequest, optFns ...func(*Options)) (*PutObjectAclResult, error) + func (c *Client) PutObjectFromFile(ctx context.Context, request *PutObjectRequest, filePath string, ...) (*PutObjectResult, error) + func (c *Client) PutObjectTagging(ctx context.Context, request *PutObjectTaggingRequest, ...) (*PutObjectTaggingResult, error) + func (c *Client) PutSymlink(ctx context.Context, request *PutSymlinkRequest, optFns ...func(*Options)) (*PutSymlinkResult, error) + func (c *Client) RestoreObject(ctx context.Context, request *RestoreObjectRequest, optFns ...func(*Options)) (*RestoreObjectResult, error) + func (c *Client) SelectObject(ctx context.Context, request *SelectObjectRequest, optFns ...func(*Options)) (*SelectObjectResult, error) + func (c *Client) UploadPart(ctx context.Context, request *UploadPartRequest, optFns ...func(*Options)) (*UploadPartResult, error) + func (c *Client) UploadPartCopy(ctx context.Context, request *UploadPartCopyRequest, optFns ...func(*Options)) (*UploadPartCopyResult, error) + type ClientError struct + Code string + Err error + Message string + func (e *ClientError) Error() string + func (e *ClientError) Unwrap() error + type CommonPrefix struct + Prefix *string + type CompleteMultipartUpload struct + Parts []UploadPart + type CompleteMultipartUploadRequest struct + Acl ObjectACLType + Bucket *string + Callback *string + CallbackVar *string + CompleteAll *string + CompleteMultipartUpload *CompleteMultipartUpload + EncodingType *string + ForbidOverwrite *string + Key *string + RequestPayer *string + UploadId *string + type CompleteMultipartUploadResult struct + Bucket *string + CallbackResult map[string]any + ETag *string + EncodingType *string + HashCRC64 *string + Key *string + Location *string + VersionId *string + type Config struct + ConnectTimeout *time.Duration + CredentialsProvider credentials.CredentialsProvider + DisableDownloadCRC64Check *bool + DisableSSL *bool + DisableUploadCRC64Check *bool + DownloadBandwidthlimit *int64 + EnabledRedirect *bool + Endpoint *string + HttpClient HTTPClient + InsecureSkipVerify *bool + LogLevel *int + LogPrinter LogPrinter + ProxyFromEnvironment *bool + ProxyHost *string + ReadWriteTimeout *time.Duration + Region *string + RetryMaxAttempts *int + Retryer retry.Retryer + SignatureVersion *SignatureVersionType + UploadBandwidthlimit *int64 + UseAccelerateEndpoint *bool + UseCName *bool + UseDualStackEndpoint *bool + UseInternalEndpoint *bool + UsePathStyle *bool + func LoadDefaultConfig() *Config + func NewConfig() *Config + func (c *Config) WithConnectTimeout(value time.Duration) *Config + func (c *Config) WithCredentialsProvider(provider credentials.CredentialsProvider) *Config + func (c *Config) WithDisableDownloadCRC64Check(value bool) *Config + func (c *Config) WithDisableSSL(value bool) *Config + func (c *Config) WithDisableUploadCRC64Check(value bool) *Config + func (c *Config) WithDownloadBandwidthlimit(value int64) *Config + func (c *Config) WithEnabledRedirect(value bool) *Config + func (c *Config) WithEndpoint(endpoint string) *Config + func (c *Config) WithHttpClient(client *http.Client) *Config + func (c *Config) WithInsecureSkipVerify(value bool) *Config + func (c *Config) WithLogLevel(level int) *Config + func (c *Config) WithLogPrinter(printer LogPrinter) *Config + func (c *Config) WithProxyFromEnvironment(value bool) *Config + func (c *Config) WithProxyHost(value string) *Config + func (c *Config) WithReadWriteTimeout(value time.Duration) *Config + func (c *Config) WithRegion(region string) *Config + func (c *Config) WithRetryMaxAttempts(value int) *Config + func (c *Config) WithRetryer(retryer retry.Retryer) *Config + func (c *Config) WithSignatureVersion(value SignatureVersionType) *Config + func (c *Config) WithUploadBandwidthlimit(value int64) *Config + func (c *Config) WithUseAccelerateEndpoint(value bool) *Config + func (c *Config) WithUseCName(enable bool) *Config + func (c *Config) WithUseDualStackEndpoint(value bool) *Config + func (c *Config) WithUseInternalEndpoint(value bool) *Config + func (c *Config) WithUsePathStyle(enable bool) *Config + func (c Config) Copy() Config + type Copier struct + func NewCopier(api CopyAPIClient, optFns ...func(*CopierOptions)) *Copier + func (c *Copier) Copy(ctx context.Context, request *CopyObjectRequest, ...) (*CopyResult, error) + type CopierOptions struct + ClientOptions []func(*Options) + DisableShallowCopy bool + LeavePartsOnError bool + MetadataProperties *HeadObjectResult + MultipartCopyThreshold int64 + ParallelNum int + PartSize int64 + TagProperties *GetObjectTaggingResult + type CopyAPIClient interface + AbortMultipartUpload func(ctx context.Context, request *AbortMultipartUploadRequest, ...) (*AbortMultipartUploadResult, error) + CompleteMultipartUpload func(ctx context.Context, request *CompleteMultipartUploadRequest, ...) (*CompleteMultipartUploadResult, error) + CopyObject func(ctx context.Context, request *CopyObjectRequest, optFns ...func(*Options)) (*CopyObjectResult, error) + GetObjectTagging func(ctx context.Context, request *GetObjectTaggingRequest, ...) (*GetObjectTaggingResult, error) + HeadObject func(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + InitiateMultipartUpload func(ctx context.Context, request *InitiateMultipartUploadRequest, ...) (*InitiateMultipartUploadResult, error) + ListParts func(ctx context.Context, request *ListPartsRequest, optFns ...func(*Options)) (*ListPartsResult, error) + UploadPartCopy func(ctx context.Context, request *UploadPartCopyRequest, optFns ...func(*Options)) (*UploadPartCopyResult, error) + type CopyError struct + Err error + Path string + UploadId string + func (m *CopyError) Error() string + func (m *CopyError) Unwrap() error + type CopyObjectRequest struct + Acl ObjectACLType + Bucket *string + CacheControl *string + ContentDisposition *string + ContentEncoding *string + ContentType *string + Expires *string + ForbidOverwrite *string + IfMatch *string + IfModifiedSince *string + IfNoneMatch *string + IfUnmodifiedSince *string + Key *string + Metadata map[string]string + MetadataDirective *string + ProgressFn ProgressFunc + RequestPayer *string + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + SourceBucket *string + SourceKey *string + SourceVersionId *string + StorageClass StorageClassType + Tagging *string + TaggingDirective *string + TrafficLimit int64 + type CopyObjectResult struct + ETag *string + HashCRC64 *string + LastModified *time.Time + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + SourceVersionId *string + VersionId *string + type CopyResult struct + ETag *string + HashCRC64 *string + UploadId *string + VersionId *string + type CreateBucketConfiguration struct + DataRedundancyType DataRedundancyType + StorageClass StorageClassType + XMLName xml.Name + type CreateSelectObjectMetaRequest struct + Bucket *string + Key *string + MetaRequest any + type CreateSelectObjectMetaResult struct + ColumnsCount int32 + ErrorMsg string + MetaStatus int + RowsCount int64 + SplitsCount int32 + TotalScanned int64 + type CsvMetaRequest struct + InputSerialization *InputSerialization + OverwriteIfExists *bool + type DataRedundancyType string + const DataRedundancyLRS + const DataRedundancyZRS + type DeleteBucketRequest struct + Bucket *string + type DeleteBucketResult struct + type DeleteMultipleObjectsRequest struct + Bucket *string + ContentLength int64 + EncodingType *string + Objects []DeleteObject + Quiet bool + RequestPayer *string + type DeleteMultipleObjectsResult struct + DeletedObjects []DeletedInfo + EncodingType *string + type DeleteObject struct + Key *string + VersionId *string + type DeleteObjectRequest struct + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type DeleteObjectResult struct + DeleteMarker bool + VersionId *string + type DeleteObjectTaggingRequest struct + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type DeleteObjectTaggingResult struct + VersionId *string + type DeletedInfo struct + DeleteMarker bool + DeleteMarkerVersionId *string + Key *string + VersionId *string + type DeserializationError struct + Err error + Snapshot []byte + func (e *DeserializationError) Error() string + func (e *DeserializationError) Unwrap() error + type DiscardReadCloser struct + Discard int + RC io.ReadCloser + func (drc *DiscardReadCloser) Close() error + func (drc *DiscardReadCloser) Read(b []byte) (int, error) + type DownloadAPIClient interface + GetObject func(ctx context.Context, request *GetObjectRequest, optFns ...func(*Options)) (*GetObjectResult, error) + HeadObject func(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + type DownloadError struct + Err error + Path string + func (m *DownloadError) Error() string + func (m *DownloadError) Unwrap() error + type DownloadResult struct + Written int64 + type Downloader struct + func NewDownloader(c DownloadAPIClient, optFns ...func(*DownloaderOptions)) *Downloader + func (d *Downloader) DownloadFile(ctx context.Context, request *GetObjectRequest, filePath string, ...) (result *DownloadResult, err error) + type DownloaderOptions struct + CheckpointDir string + ClientOptions []func(*Options) + EnableCheckpoint bool + ParallelNum int + PartSize int64 + UseTempFile bool + VerifyData bool + type EncryptionClient struct + func NewEncryptionClient(c *Client, masterCipher crypto.MasterCipher, ...) (*EncryptionClient, error) + func (c *EncryptionClient) NewDownloader(optFns ...func(*DownloaderOptions)) *Downloader + func (c *EncryptionClient) NewUploader(optFns ...func(*UploaderOptions)) *Uploader + func (c *EncryptionClient) OpenFile(ctx context.Context, bucket string, key string, optFns ...func(*OpenOptions)) (*ReadOnlyFile, error) + func (e *EncryptionClient) AbortMultipartUpload(ctx context.Context, request *AbortMultipartUploadRequest, ...) (*AbortMultipartUploadResult, error) + func (e *EncryptionClient) CompleteMultipartUpload(ctx context.Context, request *CompleteMultipartUploadRequest, ...) (*CompleteMultipartUploadResult, error) + func (e *EncryptionClient) GetObject(ctx context.Context, request *GetObjectRequest, optFns ...func(*Options)) (*GetObjectResult, error) + func (e *EncryptionClient) GetObjectMeta(ctx context.Context, request *GetObjectMetaRequest, optFns ...func(*Options)) (*GetObjectMetaResult, error) + func (e *EncryptionClient) HeadObject(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + func (e *EncryptionClient) InitiateMultipartUpload(ctx context.Context, request *InitiateMultipartUploadRequest, ...) (*InitiateMultipartUploadResult, error) + func (e *EncryptionClient) ListParts(ctx context.Context, request *ListPartsRequest, optFns ...func(*Options)) (*ListPartsResult, error) + func (e *EncryptionClient) PutObject(ctx context.Context, request *PutObjectRequest, optFns ...func(*Options)) (*PutObjectResult, error) + func (e *EncryptionClient) Unwrap() *Client + func (e *EncryptionClient) UploadPart(ctx context.Context, request *UploadPartRequest, optFns ...func(*Options)) (*UploadPartResult, error) + type EncryptionClientOptions struct + MasterCiphers []crypto.MasterCipher + type EncryptionMultiPartContext struct + ContentCipher crypto.ContentCipher + DataSize int64 + PartSize int64 + func (ec EncryptionMultiPartContext) Valid() bool + type EndpointType int + const EndpointAccelerate + const EndpointAccelerateOverseas + const EndpointDualStack + const EndpointInternal + const EndpointPublic + type FeatureFlagsType int + const FeatureAutoDetectMimeType + const FeatureCorrectClockSkew + const FeatureEnableCRC64CheckDownload + const FeatureEnableCRC64CheckUpload + const FeatureEnableMD5 + const FeatureFlagsDefault + type GetBucketAclRequest struct + Bucket *string + type GetBucketAclResult struct + ACL *string + Owner *Owner + type GetBucketInfoRequest struct + Bucket *string + type GetBucketInfoResult struct + BucketInfo BucketInfo + type GetBucketLocationRequest struct + Bucket *string + type GetBucketLocationResult struct + LocationConstraint *string + type GetBucketRequestPaymentRequest struct + Bucket *string + type GetBucketRequestPaymentResult struct + Payer *string + type GetBucketStatRequest struct + Bucket *string + type GetBucketStatResult struct + ArchiveObjectCount int64 + ArchiveRealStorage int64 + ArchiveStorage int64 + ColdArchiveObjectCount int64 + ColdArchiveRealStorage int64 + ColdArchiveStorage int64 + InfrequentAccessObjectCount int64 + InfrequentAccessRealStorage int64 + InfrequentAccessStorage int64 + LastModifiedTime int64 + LiveChannelCount int64 + MultipartUploadCount int64 + ObjectCount int64 + StandardObjectCount int64 + StandardStorage int64 + Storage int64 + type GetBucketVersioningRequest struct + Bucket *string + type GetBucketVersioningResult struct + VersionStatus *string + type GetObjectAclRequest struct + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type GetObjectAclResult struct + ACL *string + Owner *Owner + VersionId *string + type GetObjectMetaRequest struct + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type GetObjectMetaResult struct + ContentLength int64 + ETag *string + HashCRC64 *string + LastAccessTime *time.Time + LastModified *time.Time + VersionId *string + type GetObjectRequest struct + Bucket *string + IfMatch *string + IfModifiedSince *string + IfNoneMatch *string + IfUnmodifiedSince *string + Key *string + Process *string + ProgressFn ProgressFunc + Range *string + RangeBehavior *string + RequestPayer *string + ResponseCacheControl *string + ResponseContentDisposition *string + ResponseContentEncoding *string + ResponseContentLanguage *string + ResponseContentType *string + ResponseExpires *string + TrafficLimit int64 + VersionId *string + type GetObjectResult struct + Body io.ReadCloser + ContentLength int64 + ContentMD5 *string + ContentRange *string + ContentType *string + DeleteMarker bool + ETag *string + Expiration *string + HashCRC64 *string + LastModified *time.Time + Metadata map[string]string + NextAppendPosition *string + ObjectType *string + ProcessStatus *string + Restore *string + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + StorageClass *string + TaggingCount int32 + VersionId *string + type GetObjectTaggingRequest struct + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type GetObjectTaggingResult struct + Tags []Tag + VersionId *string + type GetSymlinkRequest struct + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type GetSymlinkResult struct + ETag *string + Metadata map[string]string + Target *string + VersionId *string + type HTTPClient interface + Do func(*http.Request) (*http.Response, error) + type HTTPContentRange struct + Count int64 + Offset int64 + Total int64 + func (r HTTPContentRange) FormatHTTPContentRange() *string + type HTTPRange struct + Count int64 + Offset int64 + func ParseRange(s string) (r *HTTPRange, err error) + func (r HTTPRange) FormatHTTPRange() *string + type HeadObjectRequest struct + Bucket *string + IfMatch *string + IfModifiedSince *string + IfNoneMatch *string + IfUnmodifiedSince *string + Key *string + RequestPayer *string + VersionId *string + type HeadObjectResult struct + AllowAge *string + AllowHeaders *string + AllowMethods *string + AllowOrigin *string + CacheControl *string + ContentDisposition *string + ContentEncoding *string + ContentLength int64 + ContentMD5 *string + ContentType *string + ETag *string + Expiration *string + Expires *string + ExposeHeaders *string + HashCRC64 *string + LastModified *time.Time + Metadata map[string]string + NextAppendPosition *string + ObjectType *string + ProcessStatus *string + RequestCharged *string + Restore *string + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + StorageClass *string + TaggingCount int32 + VersionId *string + type InitiateMultipartUploadRequest struct + Bucket *string + CSEDataSize *int64 + CSEPartSize *int64 + CacheControl *string + ContentDisposition *string + ContentEncoding *string + ContentType *string + DisableAutoDetectMimeType bool + EncodingType *string + Expires *string + ForbidOverwrite *string + Key *string + Metadata map[string]string + RequestPayer *string + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + StorageClass StorageClassType + Tagging *string + type InitiateMultipartUploadResult struct + Bucket *string + CSEMultiPartContext *EncryptionMultiPartContext + EncodingType *string + Key *string + UploadId *string + type InputSerialization struct + CSV *InputSerializationCSV + CompressionType *string + JSON *InputSerializationJSON + type InputSerializationCSV struct + FieldDelimiter *string + QuoteCharacter *string + RecordDelimiter *string + type InputSerializationJSON struct + JSONType *string + type InputSerializationSelect struct + CompressionType *string + CsvBodyInput *CSVSelectInput + JsonBodyInput *JSONSelectInput + type InvalidParamError interface + Field func() string + SetContext func(string) + func NewErrParamInvalid(field string) InvalidParamError + func NewErrParamNull(field string) InvalidParamError + func NewErrParamRequired(field string) InvalidParamError + func NewErrParamTypeNotSupport(field string) InvalidParamError + type IsObjectExistOptions struct + RequestPayer *string + VersionId *string + type JSONSelectInput struct + JSONType *string + ParseJSONNumberAsString *bool + Range *string + SplitRange *string + type JSONSelectOutput struct + RecordDelimiter *string + type JsonMetaRequest struct + InputSerialization *InputSerialization + OverwriteIfExists *bool + type LimitedReadCloser struct + type ListBucketsPaginator struct + func (p *ListBucketsPaginator) HasNext() bool + func (p *ListBucketsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListBucketsResult, error) + type ListBucketsRequest struct + Marker *string + MaxKeys int32 + Prefix *string + ResourceGroupId *string + type ListBucketsResult struct + Buckets []BucketProperties + IsTruncated bool + Marker *string + MaxKeys int32 + NextMarker *string + Owner *Owner + Prefix *string + type ListMultipartUploadsPaginator struct + func (p *ListMultipartUploadsPaginator) HasNext() bool + func (p *ListMultipartUploadsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListMultipartUploadsResult, error) + type ListMultipartUploadsRequest struct + Bucket *string + Delimiter *string + EncodingType *string + KeyMarker *string + MaxUploads int32 + Prefix *string + RequestPayer *string + UploadIdMarker *string + type ListMultipartUploadsResult struct + Bucket *string + Delimiter *string + EncodingType *string + IsTruncated bool + KeyMarker *string + MaxUploads int32 + NextKeyMarker *string + NextUploadIdMarker *string + Prefix *string + UploadIdMarker *string + Uploads []Upload + type ListObjectVersionsPaginator struct + func (p *ListObjectVersionsPaginator) HasNext() bool + func (p *ListObjectVersionsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListObjectVersionsResult, error) + type ListObjectVersionsRequest struct + Bucket *string + Delimiter *string + EncodingType *string + IsMix bool + KeyMarker *string + MaxKeys int32 + Prefix *string + RequestPayer *string + VersionIdMarker *string + type ListObjectVersionsResult struct + CommonPrefixes []CommonPrefix + Delimiter *string + EncodingType *string + IsTruncated bool + KeyMarker *string + MaxKeys int32 + Name *string + NextKeyMarker *string + NextVersionIdMarker *string + ObjectDeleteMarkers []ObjectDeleteMarkerProperties + ObjectVersions []ObjectVersionProperties + ObjectVersionsDeleteMarkers []ObjectMixProperties + Prefix *string + VersionIdMarker *string + type ListObjectsPaginator struct + func (p *ListObjectsPaginator) HasNext() bool + func (p *ListObjectsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListObjectsResult, error) + type ListObjectsRequest struct + Bucket *string + Delimiter *string + EncodingType *string + Marker *string + MaxKeys int32 + Prefix *string + RequestPayer *string + type ListObjectsResult struct + CommonPrefixes []CommonPrefix + Contents []ObjectProperties + Delimiter *string + EncodingType *string + IsTruncated bool + Marker *string + MaxKeys int32 + Name *string + NextMarker *string + Prefix *string + type ListObjectsV2Paginator struct + func (p *ListObjectsV2Paginator) HasNext() bool + func (p *ListObjectsV2Paginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListObjectsV2Result, error) + type ListObjectsV2Request struct + Bucket *string + ContinuationToken *string + Delimiter *string + EncodingType *string + FetchOwner bool + MaxKeys int32 + Prefix *string + RequestPayer *string + StartAfter *string + type ListObjectsV2Result struct + CommonPrefixes []CommonPrefix + Contents []ObjectProperties + ContinuationToken *string + Delimiter *string + EncodingType *string + IsTruncated bool + KeyCount int + MaxKeys int32 + Name *string + NextContinuationToken *string + Prefix *string + StartAfter *string + type ListPartsAPIClient interface + ListParts func(ctx context.Context, request *ListPartsRequest, optFns ...func(*Options)) (*ListPartsResult, error) + type ListPartsPaginator struct + func NewListPartsPaginator(c ListPartsAPIClient, request *ListPartsRequest, ...) *ListPartsPaginator + func (p *ListPartsPaginator) HasNext() bool + func (p *ListPartsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListPartsResult, error) + type ListPartsRequest struct + Bucket *string + EncodingType *string + Key *string + MaxParts int32 + PartNumberMarker int32 + RequestPayer *string + UploadId *string + type ListPartsResult struct + Bucket *string + ClientEncryptionCekAlg *string + ClientEncryptionDataSize *int64 + ClientEncryptionKey *string + ClientEncryptionPartSize *int64 + ClientEncryptionStart *string + ClientEncryptionWrapAlg *string + EncodingType *string + IsTruncated bool + Key *string + MaxParts int32 + NextPartNumberMarker int32 + PartNumberMarker int32 + Parts []Part + StorageClass *string + UploadId *string + type LogPrinter interface + Print func(...any) + type LogPrinterFunc func(...any) + func (f LogPrinterFunc) Print(v ...any) + type Logger interface + Debugf func(format string, v ...any) + Errorf func(format string, v ...any) + Infof func(format string, v ...any) + Level func() int + Warnf func(format string, v ...any) + func NewLogger(level int, printer LogPrinter) Logger + type MultiBytesReader struct + func NewMultiBytesReader(b [][]byte) *MultiBytesReader + func (r *MultiBytesReader) Len() int + func (r *MultiBytesReader) Read(b []byte) (n int, err error) + func (r *MultiBytesReader) Reset(b [][]byte) + func (r *MultiBytesReader) Seek(offset int64, whence int) (int64, error) + func (r *MultiBytesReader) Size() int64 + type ObjectACLType string + const ObjectACLDefault + const ObjectACLPrivate + const ObjectACLPublicRead + const ObjectACLPublicReadWrite + type ObjectDeleteMarkerProperties struct + IsLatest bool + Key *string + LastModified *time.Time + Owner *Owner + VersionId *string + type ObjectMixProperties ObjectVersionProperties + func (m ObjectMixProperties) IsDeleteMarker() bool + type ObjectProperties struct + ETag *string + Key *string + LastModified *time.Time + Owner *Owner + RestoreInfo *string + Size int64 + StorageClass *string + Type *string + type ObjectVersionProperties struct + ETag *string + IsLatest bool + Key *string + LastModified *time.Time + Owner *Owner + RestoreInfo *string + Size int64 + StorageClass *string + Type *string + VersionId *string + type OpenFileAPIClient interface + GetObject func(ctx context.Context, request *GetObjectRequest, optFns ...func(*Options)) (*GetObjectResult, error) + HeadObject func(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + type OpenOptions struct + ChunkSize int64 + EnablePrefetch bool + Offset int64 + PrefetchNum int + PrefetchThreshold int64 + RequestPayer *string + VersionId *string + type OperationError struct + func (e *OperationError) Error() string + func (e *OperationError) Operation() string + func (e *OperationError) Unwrap() error + type OperationInput struct + Body io.Reader + Bucket *string + Headers map[string]string + Key *string + Method string + OpMetadata OperationMetadata + OpName string + Parameters map[string]string + type OperationMetadata struct + func (m *OperationMetadata) Add(key, value any) + func (m *OperationMetadata) Set(key, value any) + func (m OperationMetadata) Clone() OperationMetadata + func (m OperationMetadata) Get(key any) any + func (m OperationMetadata) Has(key any) bool + func (m OperationMetadata) Values(key any) []any + type OperationOutput struct + Body io.ReadCloser + Headers http.Header + Input *OperationInput + OpMetadata OperationMetadata + Status string + StatusCode int + type Options struct + AdditionalHeaders []string + AuthMethod *AuthMethodType + CredentialsProvider credentials.CredentialsProvider + Endpoint *url.URL + FeatureFlags FeatureFlagsType + HttpClient HTTPClient + OpReadWriteTimeout *time.Duration + Product string + Region string + ResponseHandlers []func(*http.Response) error + RetryMaxAttempts *int + Retryer retry.Retryer + Signer signer.Signer + UrlStyle UrlStyleType + func (c Options) Copy() Options + type OutputSerializationSelect struct + CsvBodyOutput *CSVSelectOutput + EnablePayloadCrc *bool + JsonBodyOutput *JSONSelectOutput + KeepAllColumns *bool + OutputHeader *bool + OutputRawData *bool + type Owner struct + DisplayName *string + ID *string + type PaginatorOptions struct + Limit int32 + type Part struct + ETag *string + HashCRC64 *string + LastModified *time.Time + PartNumber int32 + Size int64 + type PayerType string + const BucketOwner + const Requester + type PresignOptions struct + Expiration time.Time + Expires time.Duration + type PresignResult struct + Expiration time.Time + Method string + SignedHeaders map[string]string + URL string + type ProcessObjectRequest struct + Bucket *string + Key *string + Process *string + RequestPayer *string + type ProcessObjectResult struct + Bucket string + FileSize int + Object string + ProcessStatus string + type ProgressFunc func(increment, transferred, total int64) + type PutBucketAclRequest struct + Acl BucketACLType + Bucket *string + type PutBucketAclResult struct + type PutBucketRequest struct + Acl BucketACLType + Bucket *string + CreateBucketConfiguration *CreateBucketConfiguration + ResourceGroupId *string + type PutBucketRequestPaymentRequest struct + Bucket *string + PaymentConfiguration *RequestPaymentConfiguration + type PutBucketRequestPaymentResult struct + type PutBucketResult struct + type PutBucketVersioningRequest struct + Bucket *string + VersioningConfiguration *VersioningConfiguration + type PutBucketVersioningResult struct + type PutObjectAclRequest struct + Acl ObjectACLType + Bucket *string + Key *string + RequestPayer *string + VersionId *string + type PutObjectAclResult struct + VersionId *string + type PutObjectRequest struct + Acl ObjectACLType + Body io.Reader + Bucket *string + CacheControl *string + Callback *string + CallbackVar *string + ContentDisposition *string + ContentEncoding *string + ContentLength *int64 + ContentMD5 *string + ContentType *string + Expires *string + ForbidOverwrite *string + Key *string + Metadata map[string]string + ProgressFn ProgressFunc + RequestPayer *string + SSEKMSKeyId *string + ServerSideDataEncryption *string + ServerSideEncryption *string + StorageClass StorageClassType + Tagging *string + TrafficLimit int64 + type PutObjectResult struct + CallbackResult map[string]any + ContentMD5 *string + ETag *string + HashCRC64 *string + VersionId *string + type PutObjectTaggingRequest struct + Bucket *string + Key *string + RequestPayer *string + Tagging *Tagging + VersionId *string + type PutObjectTaggingResult struct + VersionId *string + type PutSymlinkRequest struct + Acl ObjectACLType + Bucket *string + ForbidOverwrite *string + Key *string + Metadata map[string]string + RequestPayer *string + StorageClass StorageClassType + Target *string + type PutSymlinkResult struct + VersionId *string + type RangeReader struct + func NewRangeReader(ctx context.Context, rangeGet ReaderRangeGetFn, httpRange *HTTPRange, ...) (*RangeReader, error) + func (r *RangeReader) Close() (err error) + func (r *RangeReader) Offset() int64 + func (r *RangeReader) Read(p []byte) (n int, err error) + type ReadFlagInfo struct + ConsumedBytesLength int32 + EnablePayloadCrc bool + OpenLine bool + OutputRawData bool + type ReadOnlyFile struct + func NewReadOnlyFile(ctx context.Context, c OpenFileAPIClient, bucket string, key string, ...) (*ReadOnlyFile, error) + func (f *ReadOnlyFile) Close() error + func (f *ReadOnlyFile) Read(p []byte) (bytesRead int, err error) + func (f *ReadOnlyFile) Seek(offset int64, whence int) (int64, error) + func (f *ReadOnlyFile) Stat() (os.FileInfo, error) + type ReadSeekerNopClose struct + func ReadSeekNopCloser(r io.Reader) ReadSeekerNopClose + func (r ReadSeekerNopClose) Close() error + func (r ReadSeekerNopClose) GetLen() (int64, error) + func (r ReadSeekerNopClose) HasLen() (int, bool) + func (r ReadSeekerNopClose) IsSeeker() bool + func (r ReadSeekerNopClose) Read(p []byte) (int, error) + func (r ReadSeekerNopClose) Seek(offset int64, whence int) (int64, error) + type ReaderRangeGetFn func(context.Context, HTTPRange) (output *ReaderRangeGetOutput, err error) + type ReaderRangeGetOutput struct + Body io.ReadCloser + ContentLength int64 + ContentRange *string + ETag *string + LastModified *time.Time + type ReaderWrapper struct + Body io.ReadCloser + ClientCRC32 uint32 + ColumnsCount int32 + Data string + ErrorMsg string + Finish bool + FrameType int32 + HTTPStatusCode int32 + HeaderCheckSum uint32 + Offset uint64 + PayloadChecksum uint32 + PayloadLength int32 + RowsCount int64 + ServerCRC32 uint32 + SplitsCount int32 + Status int32 + TotalScanned int64 + Version byte + WriterForCheckCrc32 hash.Hash32 + func (rw *ReaderWrapper) Close() error + func (rw *ReaderWrapper) Read(p []byte) (n int, err error) + type RequestBodyTracker interface + Reset func() + type RequestCommon struct + Headers map[string]string + Parameters map[string]string + Payload io.Reader + func (r *RequestCommon) GetCommonFileds() (map[string]string, map[string]string, io.Reader) + type RequestCommonInterface interface + GetCommonFileds func() (map[string]string, map[string]string, io.Reader) + type RequestPaymentConfiguration struct + Payer PayerType + XMLName xml.Name + type RestoreObjectRequest struct + Bucket *string + Key *string + RequestPayer *string + RestoreRequest *RestoreRequest + VersionId *string + type RestoreObjectResult struct + RestorePriority *string + VersionId *string + type RestoreRequest struct + Days int32 + Tier *string + type ResultCommon struct + Headers http.Header + OpMetadata OperationMetadata + Status string + StatusCode int + func (r *ResultCommon) CopyIn(status string, statusCode int, headers http.Header, meta OperationMetadata) + type ResultCommonInterface interface + CopyIn func(status string, statusCode int, headers http.Header, meta OperationMetadata) + type SSERule struct + KMSDataEncryption *string + KMSMasterKeyID *string + SSEAlgorithm *string + type SelectObjectRequest struct + Bucket *string + Key *string + SelectRequest *SelectRequest + type SelectObjectResult struct + Body io.ReadCloser + type SelectOptions struct + MaxSkippedRecordsAllowed *int + SkipPartialDataRecord *bool + type SelectRequest struct + Expression *string + InputSerializationSelect InputSerializationSelect + OutputSerializationSelect OutputSerializationSelect + SelectOptions *SelectOptions + type SerializationError struct + Err error + func (e *SerializationError) Error() string + func (e *SerializationError) Unwrap() error + type ServiceError struct + Code string + EC string + Headers http.Header + Message string + RequestID string + RequestTarget string + Snapshot []byte + StatusCode int + Timestamp time.Time + XMLName xml.Name + func (e *ServiceError) Error() string + func (e *ServiceError) ErrorCode() string + func (e *ServiceError) HttpStatusCode() int + type SignatureVersionType int + const SignatureVersionV1 + const SignatureVersionV4 + func (f SignatureVersionType) String() string + type StorageClassType string + const StorageClassArchive + const StorageClassColdArchive + const StorageClassDeepColdArchive + const StorageClassIA + const StorageClassStandard + type Tag struct + Key *string + Value *string + type TagSet struct + Tags []Tag + type Tagging struct + TagSet TagSet + type Upload struct + Initiated *time.Time + Key *string + UploadId *string + type UploadAPIClient interface + AbortMultipartUpload func(ctx context.Context, request *AbortMultipartUploadRequest, ...) (*AbortMultipartUploadResult, error) + CompleteMultipartUpload func(ctx context.Context, request *CompleteMultipartUploadRequest, ...) (*CompleteMultipartUploadResult, error) + HeadObject func(ctx context.Context, request *HeadObjectRequest, optFns ...func(*Options)) (*HeadObjectResult, error) + InitiateMultipartUpload func(ctx context.Context, request *InitiateMultipartUploadRequest, ...) (*InitiateMultipartUploadResult, error) + ListParts func(ctx context.Context, request *ListPartsRequest, optFns ...func(*Options)) (*ListPartsResult, error) + PutObject func(ctx context.Context, request *PutObjectRequest, optFns ...func(*Options)) (*PutObjectResult, error) + UploadPart func(ctx context.Context, request *UploadPartRequest, optFns ...func(*Options)) (*UploadPartResult, error) + type UploadError struct + Err error + Path string + UploadId string + func (m *UploadError) Error() string + func (m *UploadError) Unwrap() error + type UploadPart struct + ETag *string + PartNumber int32 + type UploadPartCopyRequest struct + Bucket *string + IfMatch *string + IfModifiedSince *string + IfNoneMatch *string + IfUnmodifiedSince *string + Key *string + PartNumber int32 + Range *string + RequestPayer *string + SourceBucket *string + SourceKey *string + SourceVersionId *string + TrafficLimit int64 + UploadId *string + type UploadPartCopyResult struct + ETag *string + LastModified *time.Time + VersionId *string + type UploadPartRequest struct + Body io.Reader + Bucket *string + CSEMultiPartContext *EncryptionMultiPartContext + ContentLength *int64 + ContentMD5 *string + Key *string + PartNumber int32 + ProgressFn ProgressFunc + RequestPayer *string + TrafficLimit int64 + UploadId *string + type UploadPartResult struct + ContentMD5 *string + ETag *string + HashCRC64 *string + type UploadParts []UploadPart + func (slice UploadParts) Len() int + func (slice UploadParts) Less(i, j int) bool + func (slice UploadParts) Swap(i, j int) + type UploadResult struct + ETag *string + HashCRC64 *string + UploadId *string + VersionId *string + type Uploader struct + func NewUploader(c UploadAPIClient, optFns ...func(*UploaderOptions)) *Uploader + func (u *Uploader) UploadFile(ctx context.Context, request *PutObjectRequest, filePath string, ...) (*UploadResult, error) + func (u *Uploader) UploadFrom(ctx context.Context, request *PutObjectRequest, body io.Reader, ...) (*UploadResult, error) + type UploaderOptions struct + CheckpointDir string + ClientOptions []func(*Options) + EnableCheckpoint bool + LeavePartsOnError bool + ParallelNum int + PartSize int64 + type UrlStyleType int + const UrlStyleCName + const UrlStylePath + const UrlStyleVirtualHosted + func (f UrlStyleType) String() string + type VersioningConfiguration struct + Status VersioningStatusType + type VersioningStatusType string + const VersionEnabled + const VersionSuspended + type XmlChildren struct + K string + V []*XmlNode + type XmlDecoderLite struct + func NewXmlDecoderLite(r io.Reader) *XmlDecoderLite + func (dec *XmlDecoderLite) Decode(root *XmlNode) error + type XmlNode struct + Children []*XmlChildren + Data []string + func (n *XmlNode) GetMap() map[string]any