Versions in this module Expand all Collapse all v1 v1.0.3 Dec 29, 2023 v1.0.2 Dec 29, 2023 v1.0.1 Dec 29, 2023 v1.0.0 Dec 29, 2023 Changes in this version + 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 EMPTY_CONTENT_SHA256 + 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_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 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 GetCurrentTimestamp() int64 + 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 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 WithPathStyle(pathStyle 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 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 + 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 + 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 + 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 string + 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 + 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 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 LifecycleRule struct + Expiration Expiration + ID string + NoncurrentVersionExpiration NoncurrentVersionExpiration + NoncurrentVersionTransitions []NoncurrentVersionTransition + Prefix string + Status RuleStatusType + Transitions []Transition + type ListBucketsInput struct + BucketType BucketType + QueryLocation bool + type ListBucketsOutput struct + Buckets []Bucket + 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 (cli *ObsClient) GetClient() *http.Client + 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) 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) 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 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 + CacheControl string + ContentDisposition string + ContentEncoding string + ContentLanguage string + ContentType 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
Go to main page