Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

obs

package

Go to main page

Versions in this module

v1

v1.5.9

Jun 17, 2024

v1.5.8

Jun 17, 2024

v1.5.7

Jun 14, 2024

v1.5.6

Jun 12, 2024

v1.5.5

Jun 12, 2024

v1.5.4

Jun 12, 2024

v1.5.3

Jun 12, 2024

v1.5.2

Jun 11, 2024

v1.5.1

Jun 11, 2024

v1.5.0

Jun 11, 2024

v1.3.7

Jun 11, 2024

v1.3.6

Jun 10, 2024

v1.3.5

Jun 9, 2024

v1.3.4

Jun 9, 2024

v1.3.3

Jun 7, 2024

v1.3.2

May 23, 2024

v1.3.1

May 23, 2024

v1.3.0

May 23, 2024

v1.2.9

May 23, 2024

v1.2.8

May 23, 2024

v1.2.7

May 23, 2024

v1.2.6

May 23, 2024

v1.2.5

May 23, 2024

v1.2.4

May 23, 2024

v1.2.3

May 23, 2024

v1.2.2

May 22, 2024

v1.2.1

May 22, 2024

v1.2.0

May 22, 2024

v1.1.26

May 22, 2024

v1.1.25

May 22, 2024

v1.1.24

May 21, 2024

v1.1.23

May 21, 2024

v1.1.22

May 21, 2024

v1.1.21

May 21, 2024

v1.1.20

May 18, 2024

v1.1.19

May 18, 2024

v1.1.18

May 18, 2024

v1.1.17

May 17, 2024

v1.1.16

May 17, 2024

v1.1.15

May 17, 2024

v1.1.14

May 17, 2024

v1.1.13

May 15, 2024

v1.1.12

May 15, 2024

v1.1.11

May 15, 2024

v1.1.10

May 14, 2024

v1.1.9

May 14, 2024

v1.1.8

May 14, 2024

v1.1.7

May 14, 2024

v1.1.6

May 14, 2024

v1.1.5

May 14, 2024

v1.1.4

May 14, 2024

v1.1.3

May 14, 2024

v1.1.2

May 14, 2024

v1.1.1

May 14, 2024

v1.1.0

May 14, 2024

v1.0.1

May 14, 2024

Changes in this version

+ const APPEND_OBJECT

+ const CALLBACK

+ const DEFAULT_CONNECT_TIMEOUT

+ const DEFAULT_HEADER_TIMEOUT

+ const DEFAULT_IDLE_CONN_TIMEOUT

+ const DEFAULT_MAX_CONN_PER_HOST

+ const DEFAULT_MAX_REDIRECT_COUNT

+ const DEFAULT_MAX_RETRY_COUNT

+ const DEFAULT_PART_SIZE

+ const DEFAULT_REGION

+ const DEFAULT_SIGNATURE

+ const DEFAULT_SOCKET_TIMEOUT

+ const DEFAULT_SSE_C_ENCRYPTION

+ const DEFAULT_SSE_KMS_ENCRYPTION

+ const DEFAULT_SSE_KMS_ENCRYPTION_OBS

+ const GET_OBJECT

+ const HEADER_ACCEPT_ENCODING

+ const HEADER_ACCESSS_KEY_AMZ

+ const HEADER_ACCESS_CONRTOL_ALLOW_HEADERS

+ const HEADER_ACCESS_CONRTOL_ALLOW_METHODS

+ const HEADER_ACCESS_CONRTOL_ALLOW_ORIGIN

+ const HEADER_ACCESS_CONRTOL_EXPOSE_HEADERS

+ const HEADER_ACCESS_CONRTOL_MAX_AGE

+ const HEADER_ACCESS_CONTROL_REQUEST_HEADER_CAMEL

+ const HEADER_ACL

+ const HEADER_ACL_AMZ

+ const HEADER_ACL_OBS

+ const HEADER_AUTH_CAMEL

+ const HEADER_AZ_REDUNDANCY

+ const HEADER_BUCKET_LOCATION_OBS

+ const HEADER_BUCKET_REDUNDANCY

+ const HEADER_BUCKET_REGION

+ const HEADER_BUCKET_TYPE

+ const HEADER_CACHE_CONTROL

+ const HEADER_CACHE_CONTROL_CAMEL

+ const HEADER_CONTENT_DISPOSITION

+ const HEADER_CONTENT_DISPOSITION_CAMEL

+ const HEADER_CONTENT_ENCODING

+ const HEADER_CONTENT_ENCODING_CAMEL

+ const HEADER_CONTENT_LANGUAGE

+ const HEADER_CONTENT_LANGUAGE_CAMEL

+ const HEADER_CONTENT_LENGTH

+ const HEADER_CONTENT_LENGTH_CAMEL

+ const HEADER_CONTENT_SHA256_AMZ

+ const HEADER_CONTENT_TYPE

+ const HEADER_CONTENT_TYPE_CAML

+ const HEADER_COPY_SOURCE

+ const HEADER_COPY_SOURCE_IF_MATCH

+ const HEADER_COPY_SOURCE_IF_MODIFIED_SINCE

+ const HEADER_COPY_SOURCE_IF_NONE_MATCH

+ const HEADER_COPY_SOURCE_IF_UNMODIFIED_SINCE

+ const HEADER_COPY_SOURCE_RANGE

+ const HEADER_COPY_SOURCE_VERSION_ID

+ const HEADER_DATE_AMZ

+ const HEADER_DATE_CAMEL

+ const HEADER_DATE_OBS

+ const HEADER_DELETE_MARKER

+ const HEADER_EPID_HEADERS

+ const HEADER_ERROR_CODE

+ const HEADER_ERROR_MESSAGE

+ const HEADER_ETAG

+ const HEADER_EXPIRATION

+ const HEADER_EXPIRES

+ const HEADER_EXPIRES_CAMEL

+ const HEADER_EXPIRES_OBS

+ const HEADER_FS_FILE_INTERFACE_OBS

+ const HEADER_FUSION_ALLOW_ALT

+ const HEADER_FUSION_ALLOW_UPGRADE

+ const HEADER_GRANT_FULL_CONTROL_DELIVERED_OBS

+ const HEADER_GRANT_FULL_CONTROL_OBS

+ const HEADER_GRANT_READ_ACP_OBS

+ const HEADER_GRANT_READ_DELIVERED_OBS

+ const HEADER_GRANT_READ_OBS

+ const HEADER_GRANT_WRITE_ACP_OBS

+ const HEADER_GRANT_WRITE_OBS

+ const HEADER_HOST

+ const HEADER_HOST_CAMEL

+ const HEADER_IF_MATCH

+ const HEADER_IF_MODIFIED_SINCE

+ const HEADER_IF_NONE_MATCH

+ const HEADER_IF_UNMODIFIED_SINCE

+ const HEADER_LASTMODIFIED

+ const HEADER_LOCATION_AMZ

+ const HEADER_LOCATION_CAMEL

+ const HEADER_MD5_CAMEL

+ const HEADER_METADATA_DIRECTIVE

+ const HEADER_MODE

+ const HEADER_NEXT_APPEND_POSITION

+ const HEADER_OBJECT_TYPE

+ const HEADER_ORIGIN_CAMEL

+ const HEADER_PREFIX

+ const HEADER_PREFIX_META

+ const HEADER_PREFIX_META_OBS

+ const HEADER_PREFIX_OBS

+ const HEADER_RANGE

+ const HEADER_REQUEST_ID

+ const HEADER_REQUEST_PAYER

+ const HEADER_RESTORE

+ const HEADER_SSEC_COPY_SOURCE_ENCRYPTION

+ const HEADER_SSEC_COPY_SOURCE_KEY

+ const HEADER_SSEC_COPY_SOURCE_KEY_MD5

+ const HEADER_SSEC_ENCRYPTION

+ const HEADER_SSEC_KEY

+ const HEADER_SSEC_KEY_MD5

+ const HEADER_SSEKMS_ENCRYPTION

+ const HEADER_SSEKMS_ENCRYPT_KEY_OBS

+ const HEADER_SSEKMS_KEY

+ const HEADER_SSEKMS_KEY_AMZ

+ const HEADER_SSEKMS_KEY_OBS

+ const HEADER_STORAGE_CLASS

+ const HEADER_STORAGE_CLASS2

+ const HEADER_STORAGE_CLASS_OBS

+ const HEADER_STS_TOKEN_AMZ

+ const HEADER_STS_TOKEN_OBS

+ const HEADER_SUCCESS_ACTION_REDIRECT

+ const HEADER_USER_AGENT_CAMEL

+ const HEADER_VERSION_ID

+ const HEADER_VERSION_OBS

+ const HEADER_WEBSITE_REDIRECT_LOCATION

+ const HTTP_DELETE

+ const HTTP_GET

+ const HTTP_HEAD

+ const HTTP_OPTIONS

+ const HTTP_POST

+ const HTTP_PUT

+ const ISO8601_DATE_FORMAT

+ const ISO8601_MIDNIGHT_DATE_FORMAT

+ const LONG_DATE_FORMAT

+ const MAX_PART_NUM

+ const MAX_PART_SIZE

+ const MIN_PART_SIZE

+ const MULTI_AZ

+ const OBS_HASH_PREFIX

+ const OBS_SDK_VERSION

+ const PARAM_ALGORITHM_AMZ_CAMEL

+ const PARAM_CREDENTIAL_AMZ_CAMEL

+ const PARAM_DATE_AMZ_CAMEL

+ const PARAM_DATE_OBS_CAMEL

+ const PARAM_EXPIRES_AMZ_CAMEL

+ const PARAM_IMAGE_PROCESS

+ const PARAM_RESPONSE_CACHE_CONTROL

+ const PARAM_RESPONSE_CONTENT_DISPOSITION

+ const PARAM_RESPONSE_CONTENT_ENCODING

+ const PARAM_RESPONSE_CONTENT_LANGUAGE

+ const PARAM_RESPONSE_CONTENT_TYPE

+ const PARAM_RESPONSE_EXPIRES

+ const PARAM_SIGNATURE_AMZ_CAMEL

+ const PARAM_SIGNEDHEADERS_AMZ_CAMEL

+ const PARAM_VERSION_ID

+ const PREFIX_META

+ const PUT_FILE

+ const PUT_OBJECT

+ const REQUEST_PAYER

+ const RFC1123_FORMAT

+ const SHORT_DATE_FORMAT

+ const TRAFFIC_LIMIT

+ const UNSIGNED_PAYLOAD

+ const USER_AGENT

+ const V2_HASH_PREFIX

+ const V4_HASH_PRE

+ const V4_HASH_PREFIX

+ const V4_SERVICE_NAME

+ const V4_SERVICE_SUFFIX

+ var ErrPoolShutDown = errors.New("RoutinePool is shutdown")

+ var ErrSubmitTimeout = errors.New("Submit task timeout")

+ var ErrTaskInvalid = errors.New("Task is nil")

+ var ErrTaskReject = errors.New("Submit task is rejected")

+ func Base64Decode(value string) ([]byte, error)

+ func Base64Encode(value []byte) string

+ func Base64Md5(value []byte) string

+ func CloseLog()

+ func ConverntObsRestoreToXml(restoreObjectInput RestoreObjectInput) string

+ func ConvertAclToXml(input AccessControlPolicy, returnMd5 bool, isObs bool) (data string, md5 string)

+ func ConvertCompleteMultipartUploadInputToXml(input CompleteMultipartUploadInput, returnMd5 bool) (data string, md5 string)

+ func ConvertEncryptionConfigurationToXml(input BucketEncryptionConfiguration, returnMd5 bool, isObs bool) (data string, md5 string)

+ func ConvertLifecyleConfigurationToXml(input BucketLifecyleConfiguration, returnMd5 bool, isObs bool) (data string, md5 string)

+ func ConvertLoggingStatusToXml(input BucketLoggingStatus, returnMd5 bool, isObs bool) (data string, md5 string)

+ func ConvertNotificationToXml(input BucketNotification, returnMd5 bool, isObs bool) (data string, md5 string)

+ func ConvertRequestToIoReader(req interface{}) (io.Reader, error)

+ func ConvertRequestToIoReaderV2(req interface{}) (io.Reader, string, error)

+ func ConvertWebsiteConfigurationToXml(input BucketWebsiteConfiguration, returnMd5 bool) (data string, md5 string)

+ func DoLog(level Level, format string, v ...interface{})

+ func DummyQueryEscape(s string) string

+ func FormatUtcNow(format string) string

+ func FormatUtcToRfc1123(t time.Time) string

+ func GetAuthorization(ak, sk, method, bucketName, objectKey, queryURL string, ...) (ret map[string]string)

+ func GetContentType(key string) (string, bool)

+ func GetCurrentTimestamp() int64

+ func GetReaderLen(reader io.Reader) (int64, error)

+ func GetV2Authorization(ak, sk, method, bucketName, objectKey, queryURL string, ...) (ret map[string]string)

+ func HandleHttpResponse(action string, headers map[string][]string, output IBaseModel, ...) (err error)

+ func Hex(value []byte) string

+ func HexMd5(value []byte) string

+ func HexSha256(value []byte) string

+ func HmacSha1(key, value []byte) []byte

+ func HmacSha256(key, value []byte) []byte

+ func InitLog(logFullPath string, maxLogSize int64, backups int, level Level, ...) error

+ func InitLogWithCacheCnt(logFullPath string, maxLogSize int64, backups int, level Level, ...) error

+ func Int64ToString(value int64) string

+ func IntToString(value int) string

+ func IsContain(items []string, item string) bool

+ func IsHandleCallbackResponse(action string, headers map[string][]string, isObs bool) bool

+ func IsIP(value string) bool

+ func Md5(value []byte) []byte

+ func ParseAppendObjectOutput(output *AppendObjectOutput) (err error)

+ func ParseCallbackResponseToBaseModel(resp *http.Response, baseModel IBaseModel, isObs bool) error

+ func ParseCompleteMultipartUploadOutput(output *CompleteMultipartUploadOutput)

+ func ParseCopyObjectOutput(output *CopyObjectOutput)

+ func ParseCopyPartOutput(output *CopyPartOutput)

+ func ParseDeleteObjectOutput(output *DeleteObjectOutput)

+ func ParseGetAttributeOutput(output *GetAttributeOutput)

+ func ParseGetBucketFSStatusOutput(output *GetBucketFSStatusOutput)

+ func ParseGetBucketMetadataOutput(output *GetBucketMetadataOutput)

+ func ParseGetObjectMetadataOutput(output *GetObjectMetadataOutput)

+ func ParseGetObjectOutput(output *GetObjectOutput)

+ func ParseInitiateMultipartUploadOutput(output *InitiateMultipartUploadOutput)

+ func ParseModifyObjectOutput(output *ModifyObjectOutput)

+ func ParseNewFolderOutput(output *NewFolderOutput)

+ func ParsePutObjectOutput(output *PutObjectOutput)

+ func ParseResponseToBaseModel(resp *http.Response, baseModel IBaseModel, xmlResult bool, isObs bool) (err error)

+ func ParseResponseToObsError(resp *http.Response, isObs bool) error

+ func ParseSetObjectMetadataOutput(output *SetObjectMetadataOutput)

+ func ParseUploadPartOutput(output *UploadPartOutput)

+ func ParseXml(value []byte, result interface{}) error

+ func Sha256Hash(value []byte) []byte

+ func StringContains(src string, subStr string, subTranscoding string) string

+ func StringToInt(value string, def int) int

+ func StringToInt64(value string, def int64) int64

+ func TeeReader(reader io.Reader, totalBytes int64, listener ProgressListener, ...) io.ReadCloser

+ func TransToXml(value interface{}) ([]byte, error)

+ func UrlDecode(value string) (string, error)

+ func UrlDecodeWithoutError(value string) string

+ func UrlEncode(value string, chineseOnly bool) string

+ func V4Auth(ak, sk, region, method, canonicalizedURL, queryURL string, ...) map[string]string

+ func WithCallbackHeader(callback string) extensionHeaders

+ func WithConnectTimeout(connectTimeout int) configurer

+ func WithCustomDomainName(cname bool) configurer

+ func WithCustomHeader(key string, value string) extensionHeaders

+ func WithEnableCompression(enableCompression bool) configurer

+ func WithHeaderTimeout(headerTimeout int) configurer

+ func WithHttpClient(httpClient *http.Client) configurer

+ func WithHttpTransport(transport *http.Transport) configurer

+ func WithIdleConnTimeout(idleConnTimeout int) configurer

+ func WithMaxConnections(maxConnsPerHost int) configurer

+ func WithMaxRedirectCount(maxRedirectCount int) configurer

+ func WithMaxRetryCount(maxRetryCount int) configurer

+ func WithNoProxyUrl(noProxyURL string) configurer

+ func WithPathStyle(pathStyle bool) configurer

+ func WithProgress(progressListener ProgressListener) configurer

+ func WithProxyFromEnv(proxyFromEnv bool) configurer

+ func WithProxyUrl(proxyURL string) configurer

+ func WithRegion(region string) configurer

+ func WithReqPaymentHeader(requester PayerType) extensionHeaders

+ func WithRequestContext(ctx context.Context) configurer

+ func WithSecurityProviders(sps ...securityProvider) configurer

+ func WithSecurityToken(securityToken string) configurer

+ func WithSignature(signature SignatureType) configurer

+ func WithSocketTimeout(socketTimeout int) configurer

+ func WithSslVerify(sslVerify bool) configurer

+ func WithSslVerifyAndPemCerts(sslVerify bool, pemCerts []byte) configurer

+ func WithTrafficLimitHeader(trafficLimit int64) extensionHeaders

+ func WithUserAgent(userAgent string) configurer

+ func XmlTranscoding(src string) string

+ type AbortIncompleteMultipartUpload struct

+ DaysAfterInitiation int

+ XMLName xml.Name

+ type AbortMultipartUploadInput struct

+ Bucket string

+ Key string

+ UploadId string

+ type AccessControlPolicy struct

+ Delivered string

+ Grants []Grant

+ Owner Owner

+ XMLName xml.Name

+ type AclType string

+ const AclAuthenticatedRead

+ const AclBucketOwnerFullControl

+ const AclBucketOwnerRead

+ const AclLogDeliveryWrite

+ const AclPrivate

+ const AclPublicRead

+ const AclPublicReadDelivery

+ const AclPublicReadWrite

+ const AclPublicReadWriteDelivery

+ type AppendObjectInput struct

+ Body io.Reader

+ Position int64

+ type AppendObjectOutput struct

+ ETag string

+ NextAppendPosition int64

+ SseHeader ISseHeader

+ VersionId string

+ type AvailableZoneType string

+ const AvailableZoneMultiAz

+ func ParseStringToAvailableZoneType(value string) (ret AvailableZoneType)

+ type BaseModel struct

+ RequestId string

+ ResponseHeaders map[string][]string

+ StatusCode int

+ type BasicSecurityProvider struct

+ func NewBasicSecurityProvider(ak, sk, securityToken string) *BasicSecurityProvider

+ type Bucket struct

+ BucketType string

+ CreationDate time.Time

+ Location string

+ Name string

+ XMLName xml.Name

+ type BucketCors struct

+ CorsRules []CorsRule

+ XMLName xml.Name

+ type BucketEncryptionConfiguration struct

+ KMSMasterKeyID string

+ ProjectID string

+ SSEAlgorithm string

+ XMLName xml.Name

+ type BucketLifecyleConfiguration struct

+ LifecycleRules []LifecycleRule

+ XMLName xml.Name

+ type BucketLocation struct

+ Location string

+ XMLName xml.Name

+ type BucketLoggingStatus struct

+ Agency string

+ TargetBucket string

+ TargetGrants []Grant

+ TargetPrefix string

+ XMLName xml.Name

+ type BucketNotification struct

+ TopicConfigurations []TopicConfiguration

+ XMLName xml.Name

+ type BucketPayer struct

+ Payer PayerType

+ XMLName xml.Name

+ type BucketQuota struct

+ Quota int64

+ XMLName xml.Name

+ type BucketRedundancyType string

+ const BucketRedundancyClassic

+ const BucketRedundancyFusion

+ type BucketStoragePolicy struct

+ StorageClass StorageClassType

+ XMLName xml.Name

+ type BucketTagging struct

+ Tags []Tag

+ XMLName xml.Name

+ type BucketType string

+ const OBJECT

+ const POSIX

+ type BucketVersioningConfiguration struct

+ Status VersioningStatusType

+ XMLName xml.Name

+ type BucketWebsiteConfiguration struct

+ ErrorDocument ErrorDocument

+ IndexDocument IndexDocument

+ RedirectAllRequestsTo RedirectAllRequestsTo

+ RoutingRules []RoutingRule

+ XMLName xml.Name

+ type CallbackBody struct

+ func (output CallbackBody) CloseCallbackBody() error

+ func (output CallbackBody) ReadCallbackBody(p []byte) (int, error)

+ type CompleteMultipartUploadInput struct

+ Bucket string

+ EncodingType string

+ Key string

+ Parts []Part

+ UploadId string

+ XMLName xml.Name

+ type CompleteMultipartUploadOutput struct

+ Bucket string

+ ETag string

+ EncodingType string

+ Key string

+ Location string

+ SseHeader ISseHeader

+ VersionId string

+ XMLName xml.Name

+ type Condition struct

+ HttpErrorCodeReturnedEquals string

+ KeyPrefixEquals string

+ XMLName xml.Name

+ type Content struct

+ ETag string

+ Key string

+ LastModified time.Time

+ Owner Owner

+ Size int64

+ StorageClass StorageClassType

+ XMLName xml.Name

+ type CopyObjectInput struct

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ CopySourceBucket string

+ CopySourceIfMatch string

+ CopySourceIfModifiedSince time.Time

+ CopySourceIfNoneMatch string

+ CopySourceIfUnmodifiedSince time.Time

+ CopySourceKey string

+ CopySourceVersionId string

+ Expires string

+ MetadataDirective MetadataDirectiveType

+ SourceSseHeader ISseHeader

+ SuccessActionRedirect string

+ type CopyObjectOutput struct

+ CopySourceVersionId string

+ ETag string

+ LastModified time.Time

+ SseHeader ISseHeader

+ VersionId string

+ XMLName xml.Name

+ type CopyPartInput struct

+ Bucket string

+ CopySourceBucket string

+ CopySourceKey string

+ CopySourceRangeEnd int64

+ CopySourceRangeStart int64

+ CopySourceVersionId string

+ Key string

+ PartNumber int

+ SourceSseHeader ISseHeader

+ SseHeader ISseHeader

+ UploadId string

+ type CopyPartOutput struct

+ ETag string

+ LastModified time.Time

+ PartNumber int

+ SseHeader ISseHeader

+ XMLName xml.Name

+ type CorsRule struct

+ AllowedHeader []string

+ AllowedMethod []string

+ AllowedOrigin []string

+ ExposeHeader []string

+ ID string

+ MaxAgeSeconds int

+ XMLName xml.Name

+ type CreateBrowserBasedSignatureInput struct

+ Bucket string

+ Expires int

+ FormParams map[string]string

+ Key string

+ type CreateBrowserBasedSignatureOutput struct

+ Algorithm string

+ Credential string

+ Date string

+ OriginPolicy string

+ Policy string

+ Signature string

+ type CreateBucketInput struct

+ ACL AclType

+ AvailableZone string

+ Bucket string

+ BucketRedundancy BucketRedundancyType

+ Epid string

+ GrantFullControlDeliveredId string

+ GrantFullControlId string

+ GrantReadAcpId string

+ GrantReadDeliveredId string

+ GrantReadId string

+ GrantWriteAcpId string

+ GrantWriteId string

+ IsFSFileInterface bool

+ IsFusionAllowUpgrade bool

+ IsRedundancyAllowALT bool

+ StorageClass StorageClassType

+ type CreateSignedUrlInput struct

+ Bucket string

+ Expires int

+ Headers map[string]string

+ Key string

+ Method HttpMethodType

+ Policy string

+ QueryParams map[string]string

+ SubResource SubResourceType

+ type CreateSignedUrlOutput struct

+ ActualSignedRequestHeaders http.Header

+ SignedUrl string

+ type DefaultSerializable struct

+ type DeleteBucketCustomDomainInput struct

+ Bucket string

+ CustomDomain string

+ type DeleteBucketFetchPolicyInput struct

+ Bucket string

+ type DeleteMarker struct

+ IsLatest bool

+ Key string

+ LastModified time.Time

+ Owner Owner

+ StorageClass StorageClassType

+ VersionId string

+ XMLName xml.Name

+ type DeleteObjectInput struct

+ Bucket string

+ Key string

+ VersionId string

+ type DeleteObjectOutput struct

+ DeleteMarker bool

+ VersionId string

+ type DeleteObjectsInput struct

+ Bucket string

+ EncodingType string

+ Objects []ObjectToDelete

+ Quiet bool

+ XMLName xml.Name

+ type DeleteObjectsOutput struct

+ Deleteds []Deleted

+ EncodingType string

+ Errors []Error

+ XMLName xml.Name

+ type Deleted struct

+ DeleteMarker bool

+ DeleteMarkerVersionId string

+ Key string

+ VersionId string

+ XMLName xml.Name

+ type Domain struct

+ CreateTime string

+ DomainName string

+ type DownloadCheckpoint struct

+ Bucket string

+ DownloadFile string

+ DownloadParts []DownloadPartInfo

+ Key string

+ ObjectInfo ObjectInfo

+ TempFileInfo TempFileInfo

+ VersionId string

+ XMLName xml.Name

+ type DownloadFileInput struct

+ CheckpointFile string

+ DownloadFile string

+ EnableCheckpoint bool

+ IfMatch string

+ IfModifiedSince time.Time

+ IfNoneMatch string

+ IfUnmodifiedSince time.Time

+ PartSize int64

+ TaskNum int

+ type DownloadPartInfo struct

+ IsCompleted bool

+ Offset int64

+ PartNumber int64

+ RangeEnd int64

+ XMLName xml.Name

+ type EcsSecurityProvider struct

+ func NewEcsSecurityProvider(retryCount int) *EcsSecurityProvider

+ type EnvSecurityProvider struct

+ func NewEnvSecurityProvider(suffix string) *EnvSecurityProvider

+ type Error struct

+ Code string

+ Key string

+ Message string

+ VersionId string

+ XMLName xml.Name

+ type ErrorDocument struct

+ Key string

+ type EventType string

+ const ObjectCreatedAll

+ const ObjectCreatedCompleteMultipartUpload

+ const ObjectCreatedCopy

+ const ObjectCreatedPost

+ const ObjectCreatedPut

+ const ObjectRemovedAll

+ const ObjectRemovedDelete

+ const ObjectRemovedDeleteMarkerCreated

+ func ParseStringToEventType(value string) (ret EventType)

+ type Expiration struct

+ Date time.Time

+ Days int

+ ExpiredObjectDeleteMarker string

+ XMLName xml.Name

+ type FSStatusType string

+ const FSStatusDisabled

+ const FSStatusEnabled

+ func ParseStringToFSStatusType(value string) (ret FSStatusType)

+ type FetchPolicyStatusType string

+ const FetchStatusClosed

+ const FetchStatusOpen

+ type FetchResponse struct

+ Agency string

+ Status FetchPolicyStatusType

+ type FileStatus struct

+ LastModified int64

+ Size int64

+ XMLName xml.Name

+ type FilterRule struct

+ Name string

+ Value string

+ XMLName xml.Name

+ type Future interface

+ Get func() interface{}

+ type FutureResult struct

+ func (f *FutureResult) Get() interface{}

+ type GetAttributeInput struct

+ RequestPayer string

+ type GetAttributeOutput struct

+ Mode int

+ type GetBucketAclOutput struct

+ type GetBucketCorsOutput struct

+ type GetBucketCustomDomainOuput struct

+ Domains []Domain

+ type GetBucketEncryptionOutput struct

+ type GetBucketFSStatusInput struct

+ type GetBucketFSStatusOutput struct

+ FSStatus FSStatusType

+ type GetBucketFetchJobInput struct

+ Bucket string

+ JobID string

+ type GetBucketFetchJobOutput struct

+ type GetBucketFetchJobResponse struct

+ Code string

+ Err string

+ Job JobResponse

+ Status string

+ type GetBucketFetchPolicyInput struct

+ Bucket string

+ type GetBucketFetchPolicyOutput struct

+ type GetBucketLifecycleConfigurationOutput struct

+ type GetBucketLocationOutput struct

+ Location string

+ type GetBucketLoggingConfigurationOutput struct

+ type GetBucketMetadataInput struct

+ Bucket string

+ Origin string

+ RequestHeader string

+ type GetBucketMetadataOutput struct

+ AZRedundancy AvailableZoneType

+ AllowHeader string

+ AllowMethod string

+ AllowOrigin string

+ BucketRedundancy BucketRedundancyType

+ Epid string

+ ExposeHeader string

+ FSStatus FSStatusType

+ Location string

+ MaxAgeSeconds int

+ StorageClass StorageClassType

+ Version string

+ type GetBucketMirrorBackToSourceOuput struct

+ Rules string

+ type GetBucketNotificationOutput struct

+ type GetBucketPolicyOutput struct

+ Policy string

+ type GetBucketQuotaOutput struct

+ type GetBucketRequestPaymentOutput struct

+ type GetBucketStorageInfoOutput struct

+ ObjectNumber int

+ Size int64

+ XMLName xml.Name

+ type GetBucketStoragePolicyOutput struct

+ StorageClass string

+ type GetBucketTaggingOutput struct

+ type GetBucketVersioningOutput struct

+ type GetBucketWebsiteConfigurationOutput struct

+ type GetObjectAclInput struct

+ Bucket string

+ Key string

+ VersionId string

+ type GetObjectAclOutput struct

+ VersionId string

+ type GetObjectInput struct

+ AcceptEncoding string

+ IfMatch string

+ IfModifiedSince time.Time

+ IfNoneMatch string

+ IfUnmodifiedSince time.Time

+ ImageProcess string

+ RangeEnd int64

+ RangeStart int64

+ ResponseCacheControl string

+ ResponseContentDisposition string

+ ResponseContentEncoding string

+ ResponseContentLanguage string

+ ResponseContentType string

+ ResponseExpires string

+ type GetObjectMetadataInput struct

+ Bucket string

+ Key string

+ Origin string

+ RequestHeader string

+ SseHeader ISseHeader

+ VersionId string

+ type GetObjectMetadataOutput struct

+ AllowHeader string

+ AllowMethod string

+ AllowOrigin string

+ ContentLength int64

+ ContentType string

+ ETag string

+ Expiration string

+ ExposeHeader string

+ LastModified time.Time

+ MaxAgeSeconds int

+ Metadata map[string]string

+ NextAppendPosition string

+ ObjectType string

+ Restore string

+ SseHeader ISseHeader

+ StorageClass StorageClassType

+ VersionId string

+ WebsiteRedirectLocation string

+ type GetObjectOutput struct

+ Body io.ReadCloser

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ DeleteMarker bool

+ Expires string

+ type Grant struct

+ Delivered bool

+ Grantee Grantee

+ Permission PermissionType

+ XMLName xml.Name

+ type Grantee struct

+ DisplayName string

+ ID string

+ Type GranteeType

+ URI GroupUriType

+ XMLName xml.Name

+ type GranteeType string

+ const GranteeGroup

+ const GranteeUser

+ type GroupUriType string

+ const GroupAllUsers

+ const GroupAuthenticatedUsers

+ const GroupLogDelivery

+ type HeadObjectInput struct

+ Bucket string

+ Key string

+ VersionId string

+ type HttpHeader struct

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ HttpExpires string

+ type HttpMethodType string

+ const HttpMethodDelete

+ const HttpMethodGet

+ const HttpMethodHead

+ const HttpMethodOptions

+ const HttpMethodPost

+ const HttpMethodPut

+ type IBaseModel interface

+ type ICallbackReadCloser interface

+ type IReadCloser interface

+ type IRepeatable interface

+ Reset func() error

+ type ISerializable interface

+ type ISseHeader interface

+ GetEncryption func() string

+ GetKey func() string

+ type IndexDocument struct

+ Suffix string

+ type InitiateMultipartUploadInput struct

+ ContentType string

+ EncodingType string

+ type InitiateMultipartUploadOutput struct

+ Bucket string

+ EncodingType string

+ Key string

+ SseHeader ISseHeader

+ UploadId string

+ XMLName xml.Name

+ type Initiator struct

+ DisplayName string

+ ID string

+ XMLName xml.Name

+ type JobResponse struct

+ Bucket string

+ CallBackBody string

+ CallBackBodyType string

+ CallBackHost string

+ CallBackURL string

+ FileType string

+ Host string

+ IgnoreSameKey bool

+ Key string

+ Md5 string

+ URL string

+ type Level int

+ const LEVEL_DEBUG

+ const LEVEL_ERROR

+ const LEVEL_INFO

+ const LEVEL_OFF

+ const LEVEL_WARN

+ type LifecycleFilter struct

+ Prefix string

+ Tags []Tag

+ XMLName xml.Name

+ type LifecycleRule struct

+ AbortIncompleteMultipartUpload AbortIncompleteMultipartUpload

+ Expiration Expiration

+ Filter LifecycleFilter

+ ID string

+ NoncurrentVersionExpiration NoncurrentVersionExpiration

+ NoncurrentVersionTransitions []NoncurrentVersionTransition

+ Prefix string

+ Status RuleStatusType

+ Transitions []Transition

+ type ListBucketsInput struct

+ BucketType BucketType

+ Marker string

+ MaxKeys int

+ QueryLocation bool

+ type ListBucketsOutput struct

+ Buckets []Bucket

+ IsTruncated bool

+ Marker string

+ MaxKeys int

+ NextMarker string

+ Owner Owner

+ XMLName xml.Name

+ type ListMultipartUploadsInput struct

+ Bucket string

+ Delimiter string

+ EncodingType string

+ KeyMarker string

+ MaxUploads int

+ Prefix string

+ UploadIdMarker string

+ type ListMultipartUploadsOutput struct

+ Bucket string

+ CommonPrefixes []string

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ MaxUploads int

+ NextKeyMarker string

+ NextUploadIdMarker string

+ Prefix string

+ UploadIdMarker string

+ Uploads []Upload

+ XMLName xml.Name

+ type ListObjectsInput struct

+ Bucket string

+ Marker string

+ type ListObjectsOutput struct

+ CommonPrefixes []string

+ Contents []Content

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ Location string

+ Marker string

+ MaxKeys int

+ Name string

+ NextMarker string

+ Prefix string

+ XMLName xml.Name

+ type ListObjsInput struct

+ Delimiter string

+ EncodingType string

+ MaxKeys int

+ Origin string

+ Prefix string

+ RequestHeader string

+ type ListPartsInput struct

+ Bucket string

+ EncodingType string

+ Key string

+ MaxParts int

+ PartNumberMarker int

+ UploadId string

+ type ListPartsOutput struct

+ Bucket string

+ EncodingType string

+ Initiator Initiator

+ IsTruncated bool

+ Key string

+ MaxParts int

+ NextPartNumberMarker int

+ Owner Owner

+ PartNumberMarker int

+ Parts []Part

+ StorageClass StorageClassType

+ UploadId string

+ XMLName xml.Name

+ type ListVersionsInput struct

+ Bucket string

+ KeyMarker string

+ VersionIdMarker string

+ type ListVersionsOutput struct

+ CommonPrefixes []string

+ DeleteMarkers []DeleteMarker

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ Location string

+ MaxKeys int

+ Name string

+ NextKeyMarker string

+ NextVersionIdMarker string

+ Prefix string

+ VersionIdMarker string

+ Versions []Version

+ XMLName xml.Name

+ type MetadataDirectiveType string

+ const CopyMetadata

+ const ReplaceMetadata

+ const ReplaceNew

+ type ModifyObjectInput struct

+ Body io.Reader

+ Bucket string

+ ContentLength int64

+ Key string

+ Position int64

+ type ModifyObjectOutput struct

+ ETag string

+ type NewFolderInput struct

+ RequestPayer string

+ type NewFolderOutput struct

+ type NoChanPool struct

+ func (pool *NoChanPool) AddCurrentWorkingCnt(value int64) int64

+ func (pool *NoChanPool) AddMaxWorkerCnt(value int64) int64

+ func (pool *NoChanPool) AddWorkerCnt(value int64) int64

+ func (pool *NoChanPool) CompareAndSwapCurrentWorkingCnt(oldValue, newValue int64) bool

+ func (pool *NoChanPool) EnableAutoTune()

+ func (pool *NoChanPool) Execute(t Task)

+ func (pool *NoChanPool) ExecuteFunc(f func() interface{})

+ func (pool *NoChanPool) GetCurrentWorkingCnt() int64

+ func (pool *NoChanPool) GetMaxWorkerCnt() int64

+ func (pool *NoChanPool) GetWorkerCnt() int64

+ func (pool *NoChanPool) ShutDown()

+ func (pool *NoChanPool) Submit(t Task) (Future, error)

+ func (pool *NoChanPool) SubmitFunc(f func() interface{}) (Future, error)

+ type NoncurrentVersionExpiration struct

+ NoncurrentDays int

+ XMLName xml.Name

+ type NoncurrentVersionTransition struct

+ NoncurrentDays int

+ StorageClass StorageClassType

+ XMLName xml.Name

+ type ObjectInfo struct

+ ETag string

+ LastModified int64

+ Size int64

+ XMLName xml.Name

+ type ObjectOperationInput struct

+ ACL AclType

+ Bucket string

+ Expires int64

+ GrantFullControlId string

+ GrantReadAcpId string

+ GrantReadId string

+ GrantWriteAcpId string

+ Key string

+ Metadata map[string]string

+ SseHeader ISseHeader

+ StorageClass StorageClassType

+ WebsiteRedirectLocation string

+ type ObjectToDelete struct

+ Key string

+ VersionId string

+ XMLName xml.Name

+ type ObsClient struct

+ func New(ak, sk, endpoint string, configurers ...configurer) (*ObsClient, error)

+ func (obsClient *ObsClient) Close()

+ func (obsClient ObsClient) AbortMultipartUpload(input *AbortMultipartUploadInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) AbortMultipartUploadWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) AppendObject(input *AppendObjectInput, extensions ...extensionOptions) (output *AppendObjectOutput, err error)

+ func (obsClient ObsClient) AppendObjectWithSignedURL(signedURL string, actualSignedRequestHeaders http.Header, data io.Reader) (output *AppendObjectOutput, err error)

+ func (obsClient ObsClient) CompleteMultipartUpload(input *CompleteMultipartUploadInput, extensions ...extensionOptions) (output *CompleteMultipartUploadOutput, err error)

+ func (obsClient ObsClient) CompleteMultipartUploadWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *CompleteMultipartUploadOutput, err error)

+ func (obsClient ObsClient) CopyObject(input *CopyObjectInput, extensions ...extensionOptions) (output *CopyObjectOutput, err error)

+ func (obsClient ObsClient) CopyObjectWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *CopyObjectOutput, err error)

+ func (obsClient ObsClient) CopyPart(input *CopyPartInput, extensions ...extensionOptions) (output *CopyPartOutput, err error)

+ func (obsClient ObsClient) CopyPartWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *CopyPartOutput, err error)

+ func (obsClient ObsClient) CreateBrowserBasedSignature(input *CreateBrowserBasedSignatureInput) (output *CreateBrowserBasedSignatureOutput, err error)

+ func (obsClient ObsClient) CreateBucket(input *CreateBucketInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) CreateBucketWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) CreateSignedUrl(input *CreateSignedUrlInput, extensions ...extensionOptions) (output *CreateSignedUrlOutput, err error)

+ func (obsClient ObsClient) DeleteBucket(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketCors(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketCorsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketCustomDomain(input *DeleteBucketCustomDomainInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketEncryption(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketEncryptionWithSignedURL(signedURL string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketFetchPolicy(input *DeleteBucketFetchPolicyInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketLifecycleConfiguration(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketLifecycleConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketMirrorBackToSource(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketPolicy(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketPolicyWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketTagging(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketTaggingWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketWebsiteConfiguration(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketWebsiteConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteBucketWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) DeleteObject(input *DeleteObjectInput, extensions ...extensionOptions) (output *DeleteObjectOutput, err error)

+ func (obsClient ObsClient) DeleteObjectWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *DeleteObjectOutput, err error)

+ func (obsClient ObsClient) DeleteObjects(input *DeleteObjectsInput, extensions ...extensionOptions) (output *DeleteObjectsOutput, err error)

+ func (obsClient ObsClient) DeleteObjectsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *DeleteObjectsOutput, err error)

+ func (obsClient ObsClient) DownloadFile(input *DownloadFileInput, extensions ...extensionOptions) (output *GetObjectMetadataOutput, err error)

+ func (obsClient ObsClient) GetAttribute(input *GetAttributeInput, extensions ...extensionOptions) (output *GetAttributeOutput, err error)

+ func (obsClient ObsClient) GetBucketAcl(bucketName string, extensions ...extensionOptions) (output *GetBucketAclOutput, err error)

+ func (obsClient ObsClient) GetBucketAclWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketAclOutput, err error)

+ func (obsClient ObsClient) GetBucketCors(bucketName string, extensions ...extensionOptions) (output *GetBucketCorsOutput, err error)

+ func (obsClient ObsClient) GetBucketCorsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketCorsOutput, err error)

+ func (obsClient ObsClient) GetBucketCustomDomain(bucketName string, extensions ...extensionOptions) (output *GetBucketCustomDomainOuput, err error)

+ func (obsClient ObsClient) GetBucketEncryption(bucketName string, extensions ...extensionOptions) (output *GetBucketEncryptionOutput, err error)

+ func (obsClient ObsClient) GetBucketEncryptionWithSignedURL(signedURL string, actualSignedRequestHeaders http.Header) (output *GetBucketEncryptionOutput, err error)

+ func (obsClient ObsClient) GetBucketFSStatus(input *GetBucketFSStatusInput, extensions ...extensionOptions) (output *GetBucketFSStatusOutput, err error)

+ func (obsClient ObsClient) GetBucketFetchJob(input *GetBucketFetchJobInput, extensions ...extensionOptions) (output *GetBucketFetchJobOutput, err error)

+ func (obsClient ObsClient) GetBucketFetchPolicy(input *GetBucketFetchPolicyInput, extensions ...extensionOptions) (output *GetBucketFetchPolicyOutput, err error)

+ func (obsClient ObsClient) GetBucketLifecycleConfiguration(bucketName string, extensions ...extensionOptions) (output *GetBucketLifecycleConfigurationOutput, err error)

+ func (obsClient ObsClient) GetBucketLifecycleConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketLifecycleConfigurationOutput, err error)

+ func (obsClient ObsClient) GetBucketLocation(bucketName string, extensions ...extensionOptions) (output *GetBucketLocationOutput, err error)

+ func (obsClient ObsClient) GetBucketLocationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketLocationOutput, err error)

+ func (obsClient ObsClient) GetBucketLoggingConfiguration(bucketName string, extensions ...extensionOptions) (output *GetBucketLoggingConfigurationOutput, err error)

+ func (obsClient ObsClient) GetBucketLoggingConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketLoggingConfigurationOutput, err error)

+ func (obsClient ObsClient) GetBucketMetadata(input *GetBucketMetadataInput, extensions ...extensionOptions) (output *GetBucketMetadataOutput, err error)

+ func (obsClient ObsClient) GetBucketMetadataWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketMetadataOutput, err error)

+ func (obsClient ObsClient) GetBucketMirrorBackToSource(bucketName string, extensions ...extensionOptions) (output *GetBucketMirrorBackToSourceOuput, err error)

+ func (obsClient ObsClient) GetBucketNotification(bucketName string, extensions ...extensionOptions) (output *GetBucketNotificationOutput, err error)

+ func (obsClient ObsClient) GetBucketNotificationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketNotificationOutput, err error)

+ func (obsClient ObsClient) GetBucketPolicy(bucketName string, extensions ...extensionOptions) (output *GetBucketPolicyOutput, err error)

+ func (obsClient ObsClient) GetBucketPolicyWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketPolicyOutput, err error)

+ func (obsClient ObsClient) GetBucketQuota(bucketName string, extensions ...extensionOptions) (output *GetBucketQuotaOutput, err error)

+ func (obsClient ObsClient) GetBucketQuotaWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketQuotaOutput, err error)

+ func (obsClient ObsClient) GetBucketRequestPayment(bucketName string, extensions ...extensionOptions) (output *GetBucketRequestPaymentOutput, err error)

+ func (obsClient ObsClient) GetBucketRequestPaymentWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketRequestPaymentOutput, err error)

+ func (obsClient ObsClient) GetBucketStorageInfo(bucketName string, extensions ...extensionOptions) (output *GetBucketStorageInfoOutput, err error)

+ func (obsClient ObsClient) GetBucketStorageInfoWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketStorageInfoOutput, err error)

+ func (obsClient ObsClient) GetBucketStoragePolicy(bucketName string, extensions ...extensionOptions) (output *GetBucketStoragePolicyOutput, err error)

+ func (obsClient ObsClient) GetBucketStoragePolicyWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketStoragePolicyOutput, err error)

+ func (obsClient ObsClient) GetBucketTagging(bucketName string, extensions ...extensionOptions) (output *GetBucketTaggingOutput, err error)

+ func (obsClient ObsClient) GetBucketTaggingWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketTaggingOutput, err error)

+ func (obsClient ObsClient) GetBucketVersioning(bucketName string, extensions ...extensionOptions) (output *GetBucketVersioningOutput, err error)

+ func (obsClient ObsClient) GetBucketVersioningWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketVersioningOutput, err error)

+ func (obsClient ObsClient) GetBucketWebsiteConfiguration(bucketName string, extensions ...extensionOptions) (output *GetBucketWebsiteConfigurationOutput, err error)

+ func (obsClient ObsClient) GetBucketWebsiteConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetBucketWebsiteConfigurationOutput, err error)

+ func (obsClient ObsClient) GetClientConfigure(extensions []extensionOptions) *config

+ func (obsClient ObsClient) GetObject(input *GetObjectInput, extensions ...extensionOptions) (output *GetObjectOutput, err error)

+ func (obsClient ObsClient) GetObjectAcl(input *GetObjectAclInput, extensions ...extensionOptions) (output *GetObjectAclOutput, err error)

+ func (obsClient ObsClient) GetObjectAclWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetObjectAclOutput, err error)

+ func (obsClient ObsClient) GetObjectMetadata(input *GetObjectMetadataInput, extensions ...extensionOptions) (output *GetObjectMetadataOutput, err error)

+ func (obsClient ObsClient) GetObjectMetadataWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetObjectMetadataOutput, err error)

+ func (obsClient ObsClient) GetObjectWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *GetObjectOutput, err error)

+ func (obsClient ObsClient) GetObjectWithoutProgress(input *GetObjectInput, extensions ...extensionOptions) (output *GetObjectOutput, err error)

+ func (obsClient ObsClient) HeadBucket(bucketName string, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) HeadBucketWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) HeadObject(input *HeadObjectInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) HeadObjectWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *BaseModel, err error)

+ func (obsClient ObsClient) InitiateMultipartUpload(input *InitiateMultipartUploadInput, extensions ...extensionOptions) (output *InitiateMultipartUploadOutput, err error)

+ func (obsClient ObsClient) InitiateMultipartUploadWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *InitiateMultipartUploadOutput, err error)

+ func (obsClient ObsClient) ListBuckets(input *ListBucketsInput, extensions ...extensionOptions) (output *ListBucketsOutput, err error)

+ func (obsClient ObsClient) ListBucketsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *ListBucketsOutput, err error)

+ func (obsClient ObsClient) ListMultipartUploads(input *ListMultipartUploadsInput, extensions ...extensionOptions) (output *ListMultipartUploadsOutput, err error)

+ func (obsClient ObsClient) ListMultipartUploadsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *ListMultipartUploadsOutput, err error)

+ func (obsClient ObsClient) ListObjects(input *ListObjectsInput, extensions ...extensionOptions) (output *ListObjectsOutput, err error)

+ func (obsClient ObsClient) ListObjectsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *ListObjectsOutput, err error)

+ func (obsClient ObsClient) ListParts(input *ListPartsInput, extensions ...extensionOptions) (output *ListPartsOutput, err error)

+ func (obsClient ObsClient) ListPartsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *ListPartsOutput, err error)

+ func (obsClient ObsClient) ListVersions(input *ListVersionsInput, extensions ...extensionOptions) (output *ListVersionsOutput, err error)

+ func (obsClient ObsClient) ListVersionsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header) (output *ListVersionsOutput, err error)

+ func (obsClient ObsClient) ModifyObject(input *ModifyObjectInput, extensions ...extensionOptions) (output *ModifyObjectOutput, err error)

+ func (obsClient ObsClient) ModifyObjectWithSignedURL(signedURL string, actualSignedRequestHeaders http.Header, data io.Reader) (output *ModifyObjectOutput, err error)

+ func (obsClient ObsClient) NewFolder(input *NewFolderInput, extensions ...extensionOptions) (output *NewFolderOutput, err error)

+ func (obsClient ObsClient) PutFile(input *PutFileInput, extensions ...extensionOptions) (output *PutObjectOutput, err error)

+ func (obsClient ObsClient) PutFileWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, sourceFile string) (output *PutObjectOutput, err error)

+ func (obsClient ObsClient) PutObject(input *PutObjectInput, extensions ...extensionOptions) (output *PutObjectOutput, err error)

+ func (obsClient ObsClient) PutObjectWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *PutObjectOutput, err error)

+ func (obsClient ObsClient) Refresh(ak, sk, securityToken string)

+ func (obsClient ObsClient) RenameFile(input *RenameFileInput, extensions ...extensionOptions) (output *RenameFileOutput, err error)

+ func (obsClient ObsClient) RenameFolder(input *RenameFolderInput, extensions ...extensionOptions) (output *RenameFolderOutput, err error)

+ func (obsClient ObsClient) RestoreObject(input *RestoreObjectInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) RestoreObjectWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketAcl(input *SetBucketAclInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketAclWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketCors(input *SetBucketCorsInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketCorsWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketCustomDomain(input *SetBucketCustomDomainInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketEncryption(input *SetBucketEncryptionInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketEncryptionWithSignedURL(signedURL string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketFetchJob(input *SetBucketFetchJobInput, extensions ...extensionOptions) (output *SetBucketFetchJobOutput, err error)

+ func (obsClient ObsClient) SetBucketFetchPolicy(input *SetBucketFetchPolicyInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketLifecycleConfiguration(input *SetBucketLifecycleConfigurationInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketLifecycleConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketLoggingConfiguration(input *SetBucketLoggingConfigurationInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketLoggingConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketMirrorBackToSource(input *SetBucketMirrorBackToSourceInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketNotification(input *SetBucketNotificationInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketNotificationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketPolicy(input *SetBucketPolicyInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketPolicyWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketQuota(input *SetBucketQuotaInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketQuotaWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketRequestPayment(input *SetBucketRequestPaymentInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketRequestPaymentWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketStoragePolicy(input *SetBucketStoragePolicyInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketStoragePolicyWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketTagging(input *SetBucketTaggingInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketTaggingWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketVersioning(input *SetBucketVersioningInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketVersioningWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketWebsiteConfiguration(input *SetBucketWebsiteConfigurationInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetBucketWebsiteConfigurationWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetObjectAcl(input *SetObjectAclInput, extensions ...extensionOptions) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetObjectAclWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *BaseModel, err error)

+ func (obsClient ObsClient) SetObjectMetadata(input *SetObjectMetadataInput, extensions ...extensionOptions) (output *SetObjectMetadataOutput, err error)

+ func (obsClient ObsClient) UploadFile(input *UploadFileInput, extensions ...extensionOptions) (output *CompleteMultipartUploadOutput, err error)

+ func (obsClient ObsClient) UploadPart(_input *UploadPartInput, extensions ...extensionOptions) (output *UploadPartOutput, err error)

+ func (obsClient ObsClient) UploadPartWithSignedUrl(signedUrl string, actualSignedRequestHeaders http.Header, data io.Reader) (output *UploadPartOutput, err error)

+ type ObsError struct

+ Code string

+ HostId string

+ Message string

+ Resource string

+ Status string

+ XMLName xml.Name

+ func (err ObsError) Error() string

+ type Owner struct

+ DisplayName string

+ ID string

+ XMLName xml.Name

+ type Part struct

+ ETag string

+ LastModified time.Time

+ PartNumber int

+ Size int64

+ XMLName xml.Name

+ type PayerType string

+ const BucketOwnerPayer

+ const Requester

+ const RequesterPayer

+ type PermissionType string

+ const PermissionFullControl

+ const PermissionRead

+ const PermissionReadAcp

+ const PermissionWrite

+ const PermissionWriteAcp

+ type Pool interface

+ AddCurrentWorkingCnt func(value int64) int64

+ AddMaxWorkerCnt func(value int64) int64

+ AddWorkerCnt func(value int64) int64

+ EnableAutoTune func()

+ Execute func(t Task)

+ ExecuteFunc func(f func() interface{})

+ GetCurrentWorkingCnt func() int64

+ GetMaxWorkerCnt func() int64

+ GetWorkerCnt func() int64

+ ShutDown func()

+ Submit func(t Task) (Future, error)

+ SubmitFunc func(f func() interface{}) (Future, error)

+ func NewNochanPool(maxWorkerCnt int) Pool

+ func NewRoutinePool(maxWorkerCnt, cacheCnt int) Pool

+ type ProgressEvent struct

+ ConsumedBytes int64

+ EventType ProgressEventType

+ TotalBytes int64

+ type ProgressEventType int

+ const TransferCompletedEvent

+ const TransferDataEvent

+ const TransferFailedEvent

+ const TransferStartedEvent

+ type ProgressListener interface

+ ProgressChanged func(event *ProgressEvent)

+ type ProtocolType string

+ const ProtocolHttp

+ const ProtocolHttps

+ type PutFileInput struct

+ SourceFile string

+ type PutObjectBasicInput struct

+ ContentLength int64

+ ContentMD5 string

+ type PutObjectInput struct

+ Body io.Reader

+ type PutObjectOutput struct

+ ETag string

+ ObjectUrl string

+ SseHeader ISseHeader

+ StorageClass StorageClassType

+ VersionId string

+ type Redirect struct

+ HostName string

+ HttpRedirectCode string

+ Protocol ProtocolType

+ ReplaceKeyPrefixWith string

+ ReplaceKeyWith string

+ XMLName xml.Name

+ type RedirectAllRequestsTo struct

+ HostName string

+ Protocol ProtocolType

+ XMLName xml.Name

+ type RenameFileInput struct

+ Bucket string

+ Key string

+ NewObjectKey string

+ RequestPayer string

+ type RenameFileOutput struct

+ type RenameFolderInput struct

+ Bucket string

+ Key string

+ NewObjectKey string

+ RequestPayer string

+ type RenameFolderOutput struct

+ type RestoreObjectInput struct

+ Bucket string

+ Days int

+ Key string

+ Tier RestoreTierType

+ VersionId string

+ XMLName xml.Name

+ type RestoreTierType string

+ const RestoreTierBulk

+ const RestoreTierExpedited

+ const RestoreTierStandard

+ type RoutinePool struct

+ func (pool *RoutinePool) AddCurrentWorkingCnt(value int64) int64

+ func (pool *RoutinePool) AddMaxWorkerCnt(value int64) int64

+ func (pool *RoutinePool) AddWorkerCnt(value int64) int64

+ func (pool *RoutinePool) CompareAndSwapCurrentWorkingCnt(oldValue, newValue int64) bool

+ func (pool *RoutinePool) EnableAutoTune()

+ func (pool *RoutinePool) Execute(t Task)

+ func (pool *RoutinePool) ExecuteFunc(f func() interface{})

+ func (pool *RoutinePool) GetCurrentWorkingCnt() int64

+ func (pool *RoutinePool) GetMaxWorkerCnt() int64

+ func (pool *RoutinePool) GetWorkerCnt() int64

+ func (pool *RoutinePool) ShutDown()

+ func (pool *RoutinePool) Submit(t Task) (Future, error)

+ func (pool *RoutinePool) SubmitFunc(f func() interface{}) (Future, error)

+ func (pool *RoutinePool) SubmitWithTimeout(t Task, timeout int64) (Future, error)

+ type RoutingRule struct

+ Condition Condition

+ Redirect Redirect

+ XMLName xml.Name

+ type RuleStatusType string

+ const RuleStatusDisabled

+ const RuleStatusEnabled

+ type SetBucketAclInput struct

+ ACL AclType

+ Bucket string

+ type SetBucketCorsInput struct

+ Bucket string

+ type SetBucketCustomDomainInput struct

+ Bucket string

+ CustomDomain string

+ type SetBucketEncryptionInput struct

+ Bucket string

+ type SetBucketFetchJobInput struct

+ Bucket string

+ CallBackBody string

+ CallBackBodyType string

+ CallBackHost string

+ CallBackURL string

+ Etag string

+ FileType string

+ Host string

+ IgnoreSameKey bool

+ Key string

+ Md5 string

+ ObjectHeaders map[string]string

+ TrustName string

+ URL string

+ type SetBucketFetchJobOutput struct

+ type SetBucketFetchJobResponse struct

+ ID string

+ Wait int

+ type SetBucketFetchPolicyInput struct

+ Agency string

+ Bucket string

+ Status FetchPolicyStatusType

+ type SetBucketLifecycleConfigurationInput struct

+ Bucket string

+ type SetBucketLoggingConfigurationInput struct

+ Bucket string

+ type SetBucketMirrorBackToSourceInput struct

+ Bucket string

+ Rules string

+ type SetBucketNotificationInput struct

+ Bucket string

+ type SetBucketPolicyInput struct

+ Bucket string

+ Policy string

+ type SetBucketQuotaInput struct

+ Bucket string

+ type SetBucketRequestPaymentInput struct

+ Bucket string

+ type SetBucketStoragePolicyInput struct

+ Bucket string

+ type SetBucketTaggingInput struct

+ Bucket string

+ type SetBucketVersioningInput struct

+ Bucket string

+ type SetBucketWebsiteConfigurationInput struct

+ Bucket string

+ type SetObjectAclInput struct

+ ACL AclType

+ Bucket string

+ Key string

+ VersionId string

+ type SetObjectMetadataInput struct

+ Bucket string

+ Expires string

+ Key string

+ Metadata map[string]string

+ MetadataDirective MetadataDirectiveType

+ StorageClass StorageClassType

+ VersionId string

+ WebsiteRedirectLocation string

+ type SetObjectMetadataOutput struct

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ Expires string

+ Metadata map[string]string

+ MetadataDirective MetadataDirectiveType

+ StorageClass StorageClassType

+ WebsiteRedirectLocation string

+ type SignatureType string

+ const SignatureObs

+ const SignatureV2

+ const SignatureV4

+ type SseCHeader struct

+ Encryption string

+ Key string

+ KeyMD5 string

+ func (header SseCHeader) GetEncryption() string

+ func (header SseCHeader) GetKey() string

+ func (header SseCHeader) GetKeyMD5() string

+ type SseKmsHeader struct

+ Encryption string

+ Key string

+ func (header SseKmsHeader) GetEncryption() string

+ func (header SseKmsHeader) GetKey() string

+ type StorageClassType string

+ const StorageClassCold

+ const StorageClassStandard

+ const StorageClassWarm

+ func ParseStringToStorageClassType(value string) (ret StorageClassType)

+ type SubResourceType string

+ const SubResourceAcl

+ const SubResourceAppend

+ const SubResourceCors

+ const SubResourceCustomDomain

+ const SubResourceDelete

+ const SubResourceEncryption

+ const SubResourceLifecycle

+ const SubResourceLocation

+ const SubResourceLogging

+ const SubResourceMetadata

+ const SubResourceMirrorBackToSource

+ const SubResourceModify

+ const SubResourceNotification

+ const SubResourcePolicy

+ const SubResourceQuota

+ const SubResourceRename

+ const SubResourceRequestPayment

+ const SubResourceRestore

+ const SubResourceStorageClass

+ const SubResourceStorageInfo

+ const SubResourceStoragePolicy

+ const SubResourceTagging

+ const SubResourceUploads

+ const SubResourceVersioning

+ const SubResourceVersions

+ const SubResourceWebsite

+ type Tag struct

+ Key string

+ Value string

+ XMLName xml.Name

+ type Task interface

+ Run func() interface{}

+ type TempFileInfo struct

+ Size int64

+ TempFileUrl string

+ XMLName xml.Name

+ type TemporarySecurityHolder struct

+ type TopicConfiguration struct

+ Events []EventType

+ FilterRules []FilterRule

+ ID string

+ Topic string

+ XMLName xml.Name

+ type Transition struct

+ Date time.Time

+ Days int

+ StorageClass StorageClassType

+ XMLName xml.Name

+ type Upload struct

+ Initiated time.Time

+ Initiator Initiator

+ Key string

+ Owner Owner

+ StorageClass StorageClassType

+ UploadId string

+ XMLName xml.Name

+ type UploadCheckpoint struct

+ Bucket string

+ FileInfo FileStatus

+ Key string

+ UploadFile string

+ UploadId string

+ UploadParts []UploadPartInfo

+ XMLName xml.Name

+ type UploadFileInput struct

+ CheckpointFile string

+ ContentType string

+ EnableCheckpoint bool

+ EncodingType string

+ PartSize int64

+ TaskNum int

+ UploadFile string

+ type UploadPartInfo struct

+ Etag string

+ IsCompleted bool

+ Offset int64

+ PartNumber int

+ PartSize int64

+ XMLName xml.Name

+ type UploadPartInput struct

+ Body io.Reader

+ Bucket string

+ ContentMD5 string

+ Key string

+ Offset int64

+ PartNumber int

+ PartSize int64

+ SourceFile string

+ SseHeader ISseHeader

+ UploadId string

+ type UploadPartOutput struct

+ ETag string

+ PartNumber int

+ SseHeader ISseHeader

+ type Version struct

+ ETag string

+ Size int64

+ XMLName xml.Name

+ type VersioningStatusType string

+ const VersioningStatusEnabled

+ const VersioningStatusSuspended