objectnode

package

Versions in this module

v1

v1.34.0

Oct 9, 2024 GO-2024-2430 +4 more

GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

Changes in this version

+ const ABORT_MULTIPART_UPLOAD

+ const ACTION_ABORT_MULTIPART_UPLOAD

+ const ACTION_ANY

+ const ACTION_DELETE_BUCKET

+ const ACTION_DELETE_OBJECT

+ const ACTION_GET_BUCKET_LOCATION

+ const ACTION_GET_OBJECT

+ const ACTION_GET_OBJECT_LOCK_CFG

+ const ACTION_GET_OBJECT_RETENTION

+ const ACTION_LIST_BUCKET

+ const ACTION_LIST_BUCKET_MULTIPART_UPLOADS

+ const ACTION_LIST_MULTIPART_UPLOAD_PARTS

+ const ACTION_PUT_OBJECT

+ const ACTION_PUT_OBJECT_LOCK_CFG

+ const AWSAccessKeyID

+ const AcceptRanges

+ const AccessControlAllowCredentials

+ const AccessControlAllowHeaders

+ const AccessControlAllowMethods

+ const AccessControlAllowOrigin

+ const AccessControlExposeHeaders

+ const AccessControlMaxAge

+ const AccessControlRequestHeaders

+ const AccessControlRequestMethod

+ const AnonymousUser

+ const Authorization

+ const BATCH_DELETE

+ const BackGroundEvictDurFactor

+ const BackGroundEvictMaxNumFactor

+ const BodyLimit

+ const COMPLETE_MULTIPART_UPLOAD

+ const COPY_OBJECT

+ const CacheControl

+ const CannedAuthenticatedRead

+ const CannedPrivate

+ const CannedPublicRead

+ const CannedPublicReadWrite

+ const ComplianceMode

+ const Connection

+ const ContentDisposition

+ const ContentEncoding

+ const ContentLength

+ const ContentMD5

+ const ContentRange

+ const ContentType

+ const ContextKeyAccessKey

+ const ContextKeyBucket

+ const ContextKeyErrorMessage

+ const ContextKeyObject

+ const ContextKeyOwner

+ const ContextKeyRequestAction

+ const ContextKeyRequestID

+ const ContextKeyRequester

+ const ContextKeyStatusCode

+ const ContextKeyUid

+ const DELETE_BUCKET

+ const DELETE_BUCKET_CORS

+ const DELETE_BUCKET_ENCRYPTION

+ const DELETE_BUCKET_LIFECYCLE

+ const DELETE_BUCKET_METRICS

+ const DELETE_BUCKET_POLICY

+ const DELETE_BUCKET_REPLICATION

+ const DELETE_BUCKET_TAGGING

+ const DELETE_BUCKET_WEBSITE

+ const DELETE_OBJECT

+ const DELETE_OBJECT_TAGGING

+ const Date

+ const DateLayout

+ const DefaultDirMode

+ const DefaultFileMode

+ const DefaultFlowLimitSize

+ const DefaultMaxBucketLength

+ const DefaultMinBucketLength

+ const ETag

+ const EmptyStringSHA256

+ const Enabled

+ const Expect

+ const ExpirationStatusDisabled

+ const ExpirationStatusEnabled

+ const Expires

+ const GET_BUCKET_ACCELERATE

+ const GET_BUCKET_ACL

+ const GET_BUCKET_CORS

+ const GET_BUCKET_ENCRYPTION

+ const GET_BUCKET_LIFECYCLE

+ const GET_BUCKET_LOCATION

+ const GET_BUCKET_LOGGING

+ const GET_BUCKET_METRICS

+ const GET_BUCKET_NOTIFICATION

+ const GET_BUCKET_OBJECT_VERSIONS

+ const GET_BUCKET_POLICY

+ const GET_BUCKET_POLICY_STATUS

+ const GET_BUCKET_REPLICATION

+ const GET_BUCKET_TAGGING

+ const GET_BUCKET_VERSIONING

+ const GET_BUCKET_WEBSITE

+ const GET_FEDERATION_TOKEN

+ const GET_OBJECT

+ const GET_OBJECT_ACL

+ const GET_OBJECT_LOCK_CFG

+ const GET_OBJECT_RETENTION

+ const GET_OBJECT_TAGGING

+ const GET_PUBLIC_ACCESS_BLOCK

+ const GroupAllUser

+ const GroupAuthenticated

+ const HEAD_BUCKET

+ const HEAD_OBJECT

+ const HOST

+ const HeaderNameXAmzDecodedContentLength

+ const Host

+ const INITIALE_MULTIPART_UPLOAD

+ const ISO8601Format

+ const ISO8601Layout

+ const ISO8601LayoutCompatible

+ const IfMatch

+ const IfModifiedSince

+ const IfNoneMatch

+ const IfUnmodifiedSince

+ const KEYNAME

+ const LIST_MULTIPART_UPLOADS

+ const LIST_OBJECTS

+ const LIST_OBJECTS_V2

+ const LIST_PARTS

+ const LastModified

+ const List

+ const List_BUCKETS

+ const Location

+ const MaxCORSSize

+ const MaxCopyObjectSize

+ const MaxIdLength

+ const MaxObjectLockSize

+ const MaxRequestSkewedSeconds

+ const MaxRetry

+ const MaxSignatureExpires

+ const MaxSizePutOnce

+ const MetadataDirectiveCopy

+ const MetadataDirectiveReplace

+ const MinParallelDownloadFileSize

+ const MinSignatureExpires

+ const OPTIONS_OBJECT

+ const Origin

+ const POST_OBJECT

+ const PUT

+ const PUT_BUCKET

+ const PUT_BUCKET_ACCELERATE

+ const PUT_BUCKET_ACL

+ const PUT_BUCKET_CORS

+ const PUT_BUCKET_ENCRYPTION

+ const PUT_BUCKET_LIFECYCLE

+ const PUT_BUCKET_LOGGING

+ const PUT_BUCKET_METRICS

+ const PUT_BUCKET_NOTIFICATION

+ const PUT_BUCKET_POLICY

+ const PUT_BUCKET_REPLICATION

+ const PUT_BUCKET_REQUEST_PAYMENT

+ const PUT_BUCKET_TAGGING

+ const PUT_BUCKET_VERSIONING

+ const PUT_BUCKET_WEBSITE

+ const PUT_OBJECT

+ const PUT_OBJECT_ACL

+ const PUT_OBJECT_LOCK_CFG

+ const PUT_OBJECT_TAGGING

+ const PUT_PUBLIC_ACCESS_BLOCK

+ const ParallelDownloadPartSize

+ const ParamEncodingType

+ const ParamKey

+ const ParamResponseCacheControl

+ const ParamResponseContentDisposition

+ const ParamResponseContentType

+ const ParamResponseExpires

+ const PermissionFullControl

+ const PermissionRead

+ const PermissionReadAcp

+ const PermissionWrite

+ const PermissionWriteAcp

+ const Principal_Any

+ const REFERER

+ const RFC1123Format

+ const Range

+ const RuleMaxCounts

+ const S3Namespace

+ const S3_ACTION_PREFIX

+ const S3_PRINCIPAL_PREFIX

+ const S3_RESOURCE_PREFIX

+ const SOURCEIP

+ const Server

+ const Signature

+ const SinglePutLimit

+ const SplitFileRangeBlockSize

+ const StatusServerPanic

+ const TaggingCounts

+ const TaggingKeyMaxLength

+ const TaggingValueMaxLength

+ const TypeCanonicalUser

+ const TypeGroup

+ const UNSUPPORT_API

+ const UPLOAD_PART

+ const UPLOAD_PART_COPY

+ const UserAgent

+ const ValueAcceptRanges

+ const ValueContentTypeDirectory

+ const ValueContentTypeJSON

+ const ValueContentTypeStream

+ const ValueContentTypeXML

+ const ValueMultipartFormData

+ const ValueServer

+ const XAmzAcl

+ const XAmzBucketRegion

+ const XAmzCopySource

+ const XAmzCopySourceIfMatch

+ const XAmzCopySourceIfModifiedSince

+ const XAmzCopySourceIfNoneMatch

+ const XAmzCopySourceIfUnmodifiedSince

+ const XAmzCopySourceRange

+ const XAmzDecodedContentLength

+ const XAmzGrantFullControl

+ const XAmzGrantRead

+ const XAmzGrantReadAcp

+ const XAmzGrantWrite

+ const XAmzGrantWriteAcp

+ const XAmzMetaPrefix

+ const XAmzMetadataDirective

+ const XAmzMpPartsCount

+ const XAmzObjectLockMode

+ const XAmzObjectLockRetainUntilDate

+ const XAmzRequestId

+ const XAmzSecurityToken

+ const XAmzStorageClass

+ const XAmzTagging

+ const XAmzTaggingCount

+ const XAttrKeyOSSACL

+ const XAttrKeyOSSCORS

+ const XAttrKeyOSSCacheControl

+ const XAttrKeyOSSDISPOSITION

+ const XAttrKeyOSSETagDeprecated

+ const XAttrKeyOSSExpires

+ const XAttrKeyOSSLock

+ const XAttrKeyOSSMIME

+ const XAttrKeyOSSPrefix

+ const XForwardedExpect

+ const XMLSI

+ var AccessDeniedBySTS = &ErrorCode

+ var AllSupportedKeys = []Key

+ var AuditWebhookUserAgent = "Golang cubefs/objectnode audit webhook"

+ var BothDaysAndYearsSpecifiedErr = errors.New(...)

+ var BucketAlreadyOwnedByYou = &ErrorCode

+ var CORSRuleNotMatch = &ErrorCode

+ var ConflictUploadRequest = &ErrorCode

+ var CopySourceSizeTooLarge = &ErrorCode

+ var DisableCreateBucketByS3 = &ErrorCode

+ var DiskQuotaExceeded = &ErrorCode

+ var DuplicateTagKey = &ErrorCode

+ var EitherDaysOrYearsSpecifiedErr = errors.New("Either Days or Years must be specified")

+ var ErrCORSNotEnabled = &ErrorCode

+ var ErrConflictAclHeader = &ErrorCode

+ var ErrFormMissingDateParam = &ErrorCode

+ var ErrInvalidActionInPolicy = &ErrorCode

+ var ErrInvalidActionResourceCombination = &ErrorCode

+ var ErrInvalidAuthHeader = &ErrorCode

+ var ErrInvalidAuthQueryParams = &ErrorCode

+ var ErrInvalidCannedACL = &ErrorCode

+ var ErrInvalidEffectValue = &ErrorCode

+ var ErrInvalidGroupUri = &ErrorCode

+ var ErrInvalidJsonPolicy = &ErrorCode

+ var ErrInvalidPermission = &ErrorCode

+ var ErrInvalidPolicyCondType = &ErrorCode

+ var ErrInvalidPolicyCondValue = &ErrorCode

+ var ErrInvalidPolicyEncoded = &ErrorCode

+ var ErrInvalidPolicyExpiration = &ErrorCode

+ var ErrInvalidPolicyValueType = &ErrorCode

+ var ErrInvalidPricipalInPolicy = &ErrorCode

+ var ErrInvalidRangeExpires = &ErrorCode

+ var ErrInvalidResourceInPolicy = &ErrorCode

+ var ErrMalformedACL = &ErrorCode

+ var ErrMalformedCredential = &ErrorCode

+ var ErrMalformedDate = &ErrorCode

+ var ErrMalformedPOSTRequest = &ErrorCode

+ var ErrMalformedPolicyCondValue = &ErrorCode

+ var ErrMalformedQueryExpires = &ErrorCode

+ var ErrMalformedXAmzDate = &ErrorCode

+ var ErrMissingActionInPolicy = &ErrorCode

+ var ErrMissingAuthQueryParams = &ErrorCode

+ var ErrMissingDateHeader = &ErrorCode

+ var ErrMissingEffectInPolicy = &ErrorCode

+ var ErrMissingFormFields = &ErrorCode

+ var ErrMissingGrants = &ErrorCode

+ var ErrMissingPolicyConditions = &ErrorCode

+ var ErrMissingPrincipalInPolicy = &ErrorCode

+ var ErrMissingResourceInPolicy = &ErrorCode

+ var ErrMissingSecurityHeader = &ErrorCode

+ var ErrMissingSignature = &ErrorCode

+ var ErrMissingSignedHeaders = &ErrorCode

+ var ErrMissingStatementInPolicy = &ErrorCode

+ var ErrMissingVersionInPolicy = &ErrorCode

+ var ErrPostPolicyExpired = &ErrorCode

+ var ErrTooManyGrants = &ErrorCode

+ var ErrTooManyStatementInPolicy = &ErrorCode

+ var ErrUnexpectedContent = &ErrorCode

+ var ExpiredToken = &ErrorCode

+ var FileDeleteLock = &ErrorCode

+ var InvalidAccessKeyId = &ErrorCode

+ var InvalidCacheArgument = &ErrorCode

+ var InvalidDigest = &ErrorCode

+ var InvalidLocationConstraint = &ErrorCode

+ var InvalidMaxPartNumber = &ErrorCode

+ var InvalidMinPartNumber = &ErrorCode

+ var InvalidModeErr = errors.New("Invalid Retention Mode")

+ var InvalidObjectLockEnabledErr = errors.New("Only Enabled value is allowd to ObjectLockEnabled element")

+ var InvalidPart = &ErrorCode

+ var InvalidPartNumber = &ErrorCode

+ var InvalidPartOrder = &ErrorCode

+ var InvalidTag = &ErrorCode

+ var InvalidToken = &ErrorCode

+ var KeyTooLong = &ErrorCode

+ var LifeCycleAtLeastOneAction = &ErrorCode

+ var LifeCycleErrDateType = &ErrorCode

+ var LifeCycleErrDaysType = &ErrorCode

+ var LifeCycleErrMalformedXML = &ErrorCode

+ var LifeCycleErrMissingActions = &ErrorCode

+ var LifeCycleErrMissingRuleID = &ErrorCode

+ var LifeCycleErrMissingRules = &ErrorCode

+ var LifeCycleErrSameRuleID = &ErrorCode

+ var LifeCycleErrTooLongRuleID = &ErrorCode

+ var LifeCycleErrTooManyRules = &ErrorCode

+ var LifeCycleRulesGreaterThen1K = &ErrorCode

+ var LifeCycleRulesInvalid = &ErrorCode

+ var LifeCycleRulesLessThenOne = &ErrorCode

+ var MalformedPOSTRequest = &ErrorCode

+ var MalformedXML = &ErrorCode

+ var MaxKeyLength = 750

+ var MaxPartCopySize int64 = 5 << 30

+ var MaxPartNumberValid = 10000

+ var MinPartNumberValid = 1

+ var MinPartSizeBytes uint64 = 1024 * 1024

+ var MissingContentMD5 = &ErrorCode

+ var MissingOriginHeader = &ErrorCode

+ var MissingSecurityElement = &ErrorCode

+ var MissingTagInBody = &ErrorCode

+ var NilDefaultRetentionErr = errors.New("Default retention cannot be nil")

+ var NilDefaultRuleErr = errors.New("Default rule cannot be nil")

+ var NoContentMd5HeaderErr = &ErrorCode

+ var NoSuchBucketPolicy = &ErrorCode

+ var NoSuchCORSConfiguration = &ErrorCode

+ var NoSuchLifecycleConfiguration = &ErrorCode

+ var NoSuchObjectLockConfiguration = &ErrorCode

+ var NoSuchTagSetError = &ErrorCode

+ var NoSuchUpload = &ErrorCode

+ var NonPositiveRetentionPeriodsErr = errors.New("Default retention period must be a positive integer value")

+ var NotModified = &ErrorCode

+ var ObjectLockConfigurationNotFound = &ErrorCode

+ var ObjectModeConflict = &ErrorCode

+ var OverMaxRecordSize = &ErrorCode

+ var RequestTimeTooSkewed = &ErrorCode

+ var RetentionPeriodsTooLargeErr = errors.New("Default retention period is too large")

+ var S3ActionToApis = map[string]SliceString

+ var SignatureDoesNotMatch = &ErrorCode

+ var TooManyCorsRules = &ErrorCode

+ var TooManyRequests = &ErrorCode

+ var TooManyTags = &ErrorCode

+ var UnexpectedContent = &ErrorCode

+ var XAmzGrantHeaders = []string

+ var XAmzGrantToPermission = map[string]string

+ func ActionFromRouteName(name string) proto.Action

+ func ActionToUniqueRouteName(action proto.Action) (name string)

+ func EncodeFedSessionToken(ownerAk, ownerSk, fedAk, fedSk, name, policy, expireUnix string) (token string, err error)

+ func GetActionFromContext(r *http.Request) (action proto.Action)

+ func GetContentLength(r *http.Request) int64

+ func GetMD5(b []byte) string

+ func GetRequestID(r *http.Request) (id string)

+ func GetRootCAs(file ...string) (*x509.CertPool, error)

+ func GetStatusCodeFromContext(r *http.Request) int

+ func HasAclInRequest(req *http.Request) bool

+ func IsAccountLevelApi(apiName string) bool

+ func IsApiSupportByACL(apiName proto.Action) bool

+ func IsApiSupportByObjectAcl(apiName proto.Action) bool

+ func IsBucketApi(apiName string) bool

+ func IsMonitoredStatusCode(code int) bool

+ func IsValidBucketName(bucketName string, minBucketLength, maxBucketLength int) bool

+ func MakeHmacSha1(key, data []byte) []byte

+ func MakeHmacSha256(key, data []byte) []byte

+ func MakeMD5(data []byte) []byte

+ func MakeSha256(data []byte) []byte

+ func Match(pattern, name string) (matched bool)

+ func NewClosableChunkedReader(source io.ReadCloser) io.ReadCloser

+ func NewTLSConfig(clientCert, clientKey string) (*tls.Config, error)

+ func ParseCompatibleTime(timeStr string) (t time.Time, err error)

+ func ParseJSONEntity(raw interface{}, entity interface{}) error

+ func ParseUserDefinedMetadata(header http.Header) map[string]string

+ func PolicyConditionMatch(policy string, forms map[string]string) error

+ func ReleaseUserInfoStore(store UserInfoStore)

+ func SetRequestAction(r *http.Request, action proto.Action)

+ func SetRequestID(r *http.Request, requestID string)

+ func SetResponseErrorMessage(r *http.Request, message string)

+ func SetResponseStatusCode(r *http.Request, code string)

+ func SplitFileRange(size, blockSize int64) (ranges [][2]int64)

+ func StringListContain(list []string, element string) bool

+ func ValidateCacheControl(cacheControl string) bool

+ func ValidateCacheExpires(expires string) bool

type AccessControlPolicy

+ func CreateDefaultACL(owner string) *AccessControlPolicy

+ func ParseAclFromRequestBody(body io.Reader, owner string) (acl *AccessControlPolicy, err error)

+ func ParseCannedAcl(cannedAcl, owner string) (*AccessControlPolicy, error)

+ func ParseGrantAclWithinHeader(reqHeader http.Header, owner string) (*AccessControlPolicy, error)

+ func (acp *AccessControlPolicy) AddGrant(idUri, granteeType, permission string)

+ func (acp *AccessControlPolicy) Encode() string

+ func (acp *AccessControlPolicy) GetOwner() string

+ func (acp *AccessControlPolicy) IsEmpty() bool

+ func (acp *AccessControlPolicy) IsValid() error

+ func (acp *AccessControlPolicy) SetAuthenticatedRead(ownerId string)

+ func (acp *AccessControlPolicy) SetOwner(owner string)

+ func (acp *AccessControlPolicy) SetPrivate(ownerId string)

+ func (acp *AccessControlPolicy) SetPublicRead(ownerId string)

+ func (acp *AccessControlPolicy) SetPublicReadWrite(ownerId string)

+ func (acp *AccessControlPolicy) XmlMarshal() ([]byte, error)

+ type AccessStat struct

+ type ActionElementType string

+ type ActionType []interface

+ type AsyncTaskErrorFunc func(err error)

+ func (f AsyncTaskErrorFunc) OnError(err error)

+ type AttrItem struct

+ func (attr *AttrItem) IsExpired() bool

+ type AuditEntry struct

+ AccessKey string

+ BytesRequest int64

+ BytesResponse int64

+ Duration string

+ DurationNS string

+ Owner string

+ Request struct{ ... }

+ RequestID string

+ Requester string

+ Response struct{ ... }

+ Time time.Time

+ Version string

+ type AuditLogConfig struct

+ Kafka map[string]KafkaAuditConfig

+ Local *auditlog.Config

+ Webhook map[string]WebhookAuditConfig

+ type AuditLogger interface

+ Close func() error

+ Name func() string

+ Send func(data []byte) error

+ type Auther interface

+ Algorithm func() string

+ CanonicalRequest func() string

+ Credential func() *Credential

+ IsExpired func() bool

+ IsPresigned func() bool

+ IsSkewed func() bool

+ Signature func() string

+ SignatureMatch func(string, Wildcards) bool

+ SignedHeaders func() []string

+ StringToSign func() string

+ Version func() string

+ func NewAuth(r *http.Request) (Auther, error)

+ func NewFormAuth(r *http.Request) (Auther, error)

+ func NewHeaderAuth(r *http.Request) (Auther, error)

+ func NewQueryAuth(r *http.Request) (Auther, error)

+ type CORSConfiguration struct

+ CORSRule []*CORSRule

+ XMLName xml.Name

+ type CORSRule struct

+ AllowedHeader []string

+ AllowedMethod []string

+ AllowedOrigin []string

+ ExposeHeader []string

+ MaxAgeSeconds uint16

+ type CacheUserInfoLoader struct

+ func NewUserInfoLoader(mc *master.MasterClient) *CacheUserInfoLoader

+ func (us *CacheUserInfoLoader) Close()

+ func (us *CacheUserInfoLoader) LoadUser(accessKey string) (*proto.UserInfo, error)

+ type CacheUserInfoStore struct

+ func (s *CacheUserInfoStore) Close()

+ func (s *CacheUserInfoStore) LoadUser(accessKey string) (*proto.UserInfo, error)

+ type CompleteMultipartUploadRequest struct

+ Parts []*PartRequest

+ XMLName xml.Name

+ type CondMatch struct

+ Key string

+ Operator string

+ Value string

type Condition

+ func (operations *Condition) UnmarshalJSON(data []byte) error

+ func (operations Condition) CheckValid() error

+ func (operations Condition) Evaluate(values map[string]string) bool

+ func (operations Condition) Keys() KeySet

+ func (operations Condition) MarshalJSON() ([]byte, error)

+ func (operations Condition) String() string

+ type ConditionEnum int

+ type ContentLengthRange struct

+ Max int64

+ Min int64

+ type CreateBucketRequest struct

+ LocationConstraint string

+ XMLName xml.Name

+ type Credential struct

+ AccessKey string

+ Date string

+ Expires int64

+ Region string

+ Request string

+ Service string

+ TimeStamp string

+ func (c *Credential) ParseDate() (time.Time, error)

+ func (c *Credential) ParseTimeStamp() (time.Time, error)

+ type DefaultRetention struct

+ Days *int64

+ Mode string

+ XMLName *xml.Name

+ Years *int64

+ type DentryItem struct

+ func (di *DentryItem) IsExpired() bool

+ func (di *DentryItem) Key() string

+ type ETagValue struct

+ PartNum int

+ TS time.Time

+ Value string

+ func DirectoryETagValue() ETagValue

+ func EmptyContentETagValue(ts time.Time) ETagValue

+ func NewRandomBytesETagValue(partNum int, ts time.Time) ETagValue

+ func NewRandomUUIDETagValue(partNum int, ts time.Time) ETagValue

+ func ParseETagValue(raw string) ETagValue

+ func (e ETagValue) ETag() string

+ func (e ETagValue) Encode() string

+ func (e ETagValue) String() string

+ func (e ETagValue) TSUnix() int64

+ func (e ETagValue) Valid() bool

type ErrorCode

+ func CheckConditionInHeader(r *http.Request, fileInfo *FSFileInfo) *ErrorCode

+ func HttpStatusErrorCode(code int) *ErrorCode

+ func InternalErrorCode(err error) *ErrorCode

+ func NewError(errCode, errMsg string, statusCode int) *ErrorCode

+ func VerifyContentLength(r *http.Request, bodyLimit int64) (int64, *ErrorCode)

+ func (ec *ErrorCode) Copy() *ErrorCode

+ func (ec *ErrorCode) Error() string

+ type ErrorResponse struct

+ Code string

+ Message string

+ RequestId string

+ Resource string

+ XMLName xml.Name

+ type Expiration struct

+ Date *time.Time

+ Days *int

+ XMLName xml.Name

+ type ExternalAudit struct

+ func NewExternalAudit() *ExternalAudit

+ func (a *ExternalAudit) AddLoggers(al ...AuditLogger)

+ func (a *ExternalAudit) Close()

+ func (a *ExternalAudit) Logger(w http.ResponseWriter, r *http.Request)

type FSFileInfo

+ CacheControl string

+ CreateTime time.Time

+ Disposition string

+ Expires string

+ MIMEType string

+ Metadata map[string]string

+ RetainUntilDate string

+ type FedDecodeResult struct

+ FedSK string

+ Policy *PolicyV2

+ UserInfo *proto.UserInfo

+ func DecodeFedSessionToken(fedAk, session string, getUserInfo func(ak string) (*proto.UserInfo, error)) (*FedDecodeResult, error)

+ type FederatedCredentials struct

+ AccessKeyId string

+ Expiration string

+ SecretAccessKey string

+ SessionToken string

+ type FederatedUser struct

+ Arn string

+ FederatedUserId string

+ type FederationTokenResponse struct

+ GetFederationTokenResult *FederationTokenResult

+ ResponseMetadata struct{ ... }

+ XMLName *xml.Name

+ type FederationTokenResult struct

+ Credentials *FederatedCredentials

+ FederatedUser *FederatedUser

+ PackedPolicySize int

+ type Filter struct

+ Prefix string

+ XMLName xml.Name

+ type FormAuth struct

+ func (auth *FormAuth) Algorithm() string

+ func (auth *FormAuth) CanonicalRequest() string

+ func (auth *FormAuth) Credential() *Credential

+ func (auth *FormAuth) FromMultipartForm(key string) string

+ func (auth *FormAuth) IsExpired() bool

+ func (auth *FormAuth) IsPresigned() bool

+ func (auth *FormAuth) IsSkewed() bool

+ func (auth *FormAuth) Signature() string

+ func (auth *FormAuth) SignatureMatch(secretKey string, wildcards Wildcards) bool

+ func (auth *FormAuth) SignedHeaders() []string

+ func (auth *FormAuth) StringToSign() string

+ func (auth *FormAuth) Version() string

+ type FormRequest struct

+ func NewFormRequest(r *http.Request) *FormRequest

+ func (r *FormRequest) FileName() string

+ func (r *FormRequest) FormFile(maxMemory int64) (f multipart.File, size int64, err error)

+ func (r *FormRequest) MultipartFormValue(key string) string

+ func (r *FormRequest) ParseMultipartForm() error

+ type GetXAttrOutput struct

+ XAttr *XAttr

+ XMLName xml.Name

type Grantee

+ Xmlxsi string

+ XsiType string

+ type HeaderAuth struct

+ func (auth *HeaderAuth) Algorithm() string

+ func (auth *HeaderAuth) CanonicalRequest() string

+ func (auth *HeaderAuth) Credential() *Credential

+ func (auth *HeaderAuth) IsExpired() bool

+ func (auth *HeaderAuth) IsPresigned() bool

+ func (auth *HeaderAuth) IsSkewed() bool

+ func (auth *HeaderAuth) Signature() string

+ func (auth *HeaderAuth) SignatureMatch(secretKey string, wildcards Wildcards) bool

+ func (auth *HeaderAuth) SignedHeaders() []string

+ func (auth *HeaderAuth) StringToSign() string

+ func (auth *HeaderAuth) Version() string

+ type IPInfo struct

+ IP net.IP

+ Net *net.IPNet

+ type Initiator struct

+ DisplayName string

+ ID string

+ XMLName xml.Name

+ func NewInitiator(volume *Volume) *Initiator

+ type KafkaAudit struct

+ func NewKafkaAudit(id string, conf KafkaAuditConfig) (*KafkaAudit, error)

+ func (k *KafkaAudit) Close() error

+ func (k *KafkaAudit) Name() string

+ func (k *KafkaAudit) Send(data []byte) error

+ type KafkaAuditConfig struct

+ Enable bool

+ IsTest bool

+ type KafkaConfig struct

+ Brokers string

+ Password string

+ TLS struct{ ... }

+ TimeoutMs int64

+ Topic string

+ Username string

+ Version string

+ func (c *KafkaConfig) BuildSyncProducer() (sarama.SyncProducer, error)

+ func (c *KafkaConfig) FixConfig() error

+ type Key string

+ const AWSHost

+ const AWSReferer

+ const AWSSourceIP

+ func (key *Key) UnmarshalJSON(data []byte) error

+ func (key *Key) UnmarshalText(data []byte) error

+ func (key Key) IsValid() bool

+ func (key Key) MarshalJSON() ([]byte, error)

+ func (key Key) Name() string

+ type KeySet map[Key]struct

+ func NewKeySet(keys ...Key) KeySet

+ func (set KeySet) Add(key Key)

+ func (set KeySet) AddAll(keys KeySet)

+ func (set KeySet) Difference(sset KeySet) KeySet

+ func (set KeySet) IsEmpty() bool

+ func (set KeySet) String() string

+ func (set KeySet) ToSlice() []Key

+ type LifeCycle struct

+ Rules []*Rule

+ XMLName xml.Name

+ Xmlns string

+ func NewLifeCycle() *LifeCycle

+ func (l *LifeCycle) Validate() (bool, *ErrorCode)

+ type ListFilesV1Option struct

+ Delimiter string

+ Marker string

+ MaxKeys uint64

+ OnlyObject bool

+ Prefix string

+ type ListFilesV1Result struct

+ CommonPrefixes []string

+ Files []*FSFileInfo

+ NextMarker string

+ Truncated bool

+ type ListFilesV2Option struct

+ ContToken string

+ Delimiter string

+ FetchOwner bool

+ MaxKeys uint64

+ Prefix string

+ StartAfter string

+ type ListFilesV2Result struct

+ CommonPrefixes []string

+ Files []*FSFileInfo

+ KeyCount uint64

+ NextToken string

+ Truncated bool

type ListPartsResult

+ Initiator *Initiator

+ type ListXAttrsOutput struct

+ Keys []string

+ XMLName xml.Name

+ type LocationResponse struct

+ Location string

+ XMLName xml.Name

+ type NullRateLimit struct

+ func (n *NullRateLimit) AcquireLimitResource(uid string, api string) error

+ func (n *NullRateLimit) GetReader(uid string, api string, r io.Reader) io.Reader

+ func (n *NullRateLimit) GetResponseWriter(uid string, api string, w io.Writer) io.Writer

+ func (n *NullRateLimit) ReleaseLimitResource(uid string, api string)

+ type ObjMetaCache struct

+ func NewObjMetaCache(maxDentryNum, maxInodeAttrNum int64, refreshInterval uint64) *ObjMetaCache

+ func (omc *ObjMetaCache) DeleteAttr(volume string, inode uint64)

+ func (omc *ObjMetaCache) DeleteAttrWithKey(volume string, inode uint64, key string)

+ func (omc *ObjMetaCache) DeleteDentry(volume string, key string)

+ func (omc *ObjMetaCache) GetAttr(volume string, inode uint64) (attr *AttrItem, needRefresh bool)

+ func (omc *ObjMetaCache) GetDentry(volume string, key string) (dentry *DentryItem, needRefresh bool)

+ func (omc *ObjMetaCache) MergeAttr(volume string, item *AttrItem)

+ func (omc *ObjMetaCache) PutAttr(volume string, item *AttrItem)

+ func (omc *ObjMetaCache) PutDentry(volume string, item *DentryItem)

+ func (omc *ObjMetaCache) TotalAttrNum() int

+ func (omc *ObjMetaCache) TotalDentryNum() int

+ type ObjectLockConfig struct

+ ObjectLockEnabled string

+ Rule *ObjectLockRule

+ XMLNS string

+ XMLName *xml.Name

+ func ParseObjectLockConfigFromXML(data []byte) (*ObjectLockConfig, error)

+ func (c *ObjectLockConfig) CheckValid() error

+ func (c ObjectLockConfig) IsEmpty() bool

+ func (c ObjectLockConfig) ToRetention() (r *Retention)

+ type ObjectLockRule struct

+ DefaultRetention *DefaultRetention

type ObjectNode

+ func (o *ObjectNode) AcquireRateLimiter() RateLimiter

+ func (o *ObjectNode) Reload(data []byte) error

+ type ObjectRetention struct

+ Mode string

+ RetainUntilDate RetentionDate

+ XMLNS string

+ XMLName xml.Name

+ type Operation interface

+ func NewIPAddressOp(m map[Key][]*IPInfo) (Operation, error)

+ func NewNotIPAddressOp(m map[Key][]*IPInfo) (Operation, error)

+ func NewStringLikeOp(m map[Key]StringSet) (Operation, error)

+ func NewStringNotLikeOp(m map[Key]StringSet) (Operation, error)

type Owner

+ DisplayName string

+ type PartRequest struct

+ ETag string

+ PartNumber int

+ XMLName xml.Name

+ type PathItem struct

+ IsDirectory bool

+ Name string

+ type PathIterator struct

+ func NewPathIterator(path string) PathIterator

+ func (p *PathIterator) HasNext() bool

+ func (p *PathIterator) Next() PathItem

+ func (p *PathIterator) Reset()

+ func (p PathIterator) ToSlice() []PathItem

type Policy

+ func (p *Policy) IsEmpty() bool

+ type PolicyCheckResult int

+ const POLICY_ALLOW

+ const POLICY_DENY

+ const POLICY_UNKNOW

+ func (p PolicyCheckResult) String() string

+ type PolicyV2 struct

+ Statements []StatementV2

+ Version string

+ func ParsePolicyV2Config(data string) (*PolicyV2, error)

+ func (p *PolicyV2) IsAllow(action, bucket, key string) bool

+ func (p *PolicyV2) Validate() error

+ type PostPolicy struct

+ Conditions struct{ ... }

+ Expiration time.Time

+ func NewPostPolicy(data string) (*PostPolicy, error)

+ func (p *PostPolicy) Match(forms map[string]string) error

+ type PrincipalElementType string

+ type PrincipalType map[string]interface

+ type PutFileOption struct

+ ACL *AccessControlPolicy

+ CacheControl string

+ Disposition string

+ Expires string

+ MIMEType string

+ Metadata map[string]string

+ ObjectLock *ObjectLockConfig

+ Tagging *Tagging

+ type QueryAuth struct

+ func (auth *QueryAuth) Algorithm() string

+ func (auth *QueryAuth) CanonicalRequest() string

+ func (auth *QueryAuth) Credential() *Credential

+ func (auth *QueryAuth) IsExpired() bool

+ func (auth *QueryAuth) IsPresigned() bool

+ func (auth *QueryAuth) IsSkewed() bool

+ func (auth *QueryAuth) Signature() string

+ func (auth *QueryAuth) SignatureMatch(secretKey string, wildcards Wildcards) bool

+ func (auth *QueryAuth) SignedHeaders() []string

+ func (auth *QueryAuth) StringToSign() string

+ func (auth *QueryAuth) Version() string

+ type RateLimit struct

+ ApiLimitConf map[string]*proto.UserLimitConf

+ S3ApiRateLimitMgr map[string]UserRateManager

+ func (r *RateLimit) AcquireLimitResource(uid string, api string) error

+ func (r *RateLimit) GetReader(uid string, api string, reader io.Reader) io.Reader

+ func (r *RateLimit) GetResponseWriter(uid string, api string, w io.Writer) io.Writer

+ func (r *RateLimit) ReleaseLimitResource(uid string, api string)

+ type RateLimiter interface

+ AcquireLimitResource func(uid string, api string) error

+ GetReader func(uid string, api string, r io.Reader) io.Reader

+ GetResponseWriter func(uid string, api string, w io.Writer) io.Writer

+ ReleaseLimitResource func(uid string, api string)

+ func NewRateLimit(apiLimitConf map[string]*proto.UserLimitConf) RateLimiter

type RequestParam

+ func ParseRequestParam(r *http.Request) *RequestParam

+ func (p *RequestParam) API() string

+ func (p *RequestParam) AccessKey() string

+ func (p *RequestParam) Action() proto.Action

+ func (p *RequestParam) Bucket() string

+ func (p *RequestParam) GetVar(name string) string

+ func (p *RequestParam) Object() string

+ func (p *RequestParam) Owner() string

+ func (p *RequestParam) RequestID() string

+ func (p *RequestParam) Requester() string

+ type ResourceElementType string

+ func ResourceElement(r string) ResourceElementType

+ type ResponseStater struct

+ StartTime time.Time

+ StatusCode int

+ Written int64

+ func NewResponseStater(w http.ResponseWriter) *ResponseStater

+ func (w *ResponseStater) ExtraHeader() http.Header

+ func (w *ResponseStater) Header() http.Header

+ func (w *ResponseStater) Write(b []byte) (int, error)

+ func (w *ResponseStater) WriteHeader(code int)

+ type Retention struct

+ Duration time.Duration

+ Mode string

+ type RetentionDate struct

+ func (r RetentionDate) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error

+ type Rule struct

+ Expire *Expiration

+ Filter *Filter

+ ID string

+ Status string

+ XMLName xml.Name

+ type S3CopyPartResult struct

+ ETag string

+ LastModified string

+ XMLName xml.Name

+ func NewS3CopyPartResult(etag, lastModified string) *S3CopyPartResult

+ func (s *S3CopyPartResult) String() string

+ type S3UploadObject struct

+ Bucket string

+ ETag string

+ Key string

+ Location string

+ XMLName xml.Name

+ func NewS3UploadObject() *S3UploadObject

+ func (s3 *S3UploadObject) SetBucket(bucket string)

+ func (s3 *S3UploadObject) SetETag(etag string)

+ func (s3 *S3UploadObject) SetKey(key string)

+ func (s3 *S3UploadObject) SetLocation(location string)

+ func (s3 *S3UploadObject) String() string

+ type SignChunkedReader struct

+ func NewSignChunkedReader(r io.Reader, key []byte, scope, datetime, seed string) *SignChunkedReader

+ func (cr *SignChunkedReader) Close() error

+ func (cr *SignChunkedReader) Read(p []byte) (n int, err error)

+ type SignatureInfo struct

+ type SliceString []string

+ func (list SliceString) Contain(v string) bool

type Statement

+ Action interface{}

+ Resource interface{}

+ func (s *Statement) CheckPolicy(apiName string, uid string, conditionCheck map[string]string) PolicyCheckResult

+ type StatementV2 struct

+ Action interface{}

+ Condition Condition

+ Effect string

+ Resource interface{}

+ Sid string

+ func (s *StatementV2) IsAllow() bool

+ func (s *StatementV2) IsValid() error

+ func (s *StatementV2) MatchAction(action string) bool

+ func (s *StatementV2) MatchResource(bucket, key string) bool

+ type StrictUserInfoStore struct

+ func (s *StrictUserInfoStore) LoadUser(accessKey string) (*proto.UserInfo, error)

type StringSet

+ func CopyStringSet(set StringSet) StringSet

+ func CreateStringSet(sl ...string) StringSet

+ func NewStringSet() StringSet

+ func (set StringSet) Add(s string)

+ func (set StringSet) Difference(sset StringSet) StringSet

+ func (set StringSet) Equals(sset StringSet) bool

+ func (set StringSet) IsEmpty() bool

+ func (set StringSet) Remove(s string)

+ func (set StringSet) ToSlice() []string

+ func (set StringSet) Union(sset StringSet) StringSet

+ type StsEncoding struct

+ func NewStsEncoding(block, key string) (*StsEncoding, error)

+ func (ec *StsEncoding) Decrypt(s string) ([]byte, error)

+ func (ec *StsEncoding) Encrypt(data []byte) string

type Tagging

+ func NewTagging() *Tagging

+ func ParseTagging(src string) (*Tagging, error)

+ func (t Tagging) Encode() string

+ func (t Tagging) Validate() error

+ type TransportConfig struct

+ DialTimeoutMs int64

+ DisableCompression bool

+ IdleConnTimeoutMs int64

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ ResponseHeaderTimeoutMs int64

+ RootRAFile string

+ func (c *TransportConfig) BuildTransport() (*http.Transport, error)

+ func (c *TransportConfig) FixConfig() error

+ type UserInfoStore interface

+ LoadUser func(accessKey string) (*proto.UserInfo, error)

+ func NewUserInfoStore(masters []string, strict bool) UserInfoStore

+ type UserRateManager interface

+ ConcurrentLimitAcquire func(uid string) error

+ ConcurrentLimitRelease func(uid string)

+ GetReader func(uid string, r io.Reader) io.Reader

+ GetResponseWriter func(uid string, w io.Writer) io.Writer

+ QPSLimitAllowed func(uid string) (bool, time.Duration)

+ func NewUserRateMgr(conf *proto.UserLimitConf) UserRateManager

+ type UserRateMgr struct

+ BandWidthLimit *flowctrl.KeyFlowCtrl

+ ConcurrentLimit *concurrent.KeyConcurrentLimit

+ QPSLimit *ratelimit.KeyRateLimit

+ UserLimitConf *proto.UserLimitConf

+ func (r *UserRateMgr) ConcurrentLimitAcquire(uid string) error

+ func (r *UserRateMgr) ConcurrentLimitRelease(uid string)

+ func (r *UserRateMgr) GetReader(uid string, reader io.Reader) io.Reader

+ func (r *UserRateMgr) GetResponseWriter(uid string, w io.Writer) io.Writer

+ func (r *UserRateMgr) QPSLimitAllowed(uid string) (bool, time.Duration)

+ type Value struct

+ func NewBoolValue(b bool) Value

+ func NewIntValue(i int) Value

+ func NewStringValue(s string) Value

+ func (v *Value) StoreBool(b bool)

+ func (v *Value) StoreInt(i int)

+ func (v *Value) StoreString(s string)

+ func (v *Value) UnmarshalJSON(data []byte) error

+ func (v Value) GetBool() (bool, error)

+ func (v Value) GetInt() (int, error)

+ func (v Value) GetString() (string, error)

+ func (v Value) GetType() reflect.Kind

+ func (v Value) MarshalJSON() ([]byte, error)

+ func (v Value) String() string

+ type ValueSet map[Value]struct

+ func NewValueSet(values ...Value) ValueSet

+ func (set *ValueSet) UnmarshalJSON(data []byte) error

+ func (set ValueSet) Add(value Value)

+ func (set ValueSet) MarshalJSON() ([]byte, error)

type Volume

+ func NewVolume(config *VolumeConfig) (*Volume, error)

+ func (v *Volume) CreateTime() time.Time

+ func (v *Volume) DeletePath(path string) (err error)

+ func (v *Volume) GetOwner() string

+ func (v *Volume) IsEmpty() bool

+ func (v *Volume) ListXAttrs(path string) (keys []string, err error)

+ func (v *Volume) Name() string

+ func (v *Volume) ObjectMeta(path string) (info *FSFileInfo, xattr *proto.XAttrInfo, err error)

+ func (v *Volume) Owner() string

+ func (v *Volume) PutObject(path string, reader io.Reader, opt *PutFileOption) (fsInfo *FSFileInfo, err error)

+ type VolumeConfig struct

+ Masters []string

+ MetaStrict bool

+ OnAsyncTaskError AsyncTaskErrorFunc

+ Store Store

+ Volume string

+ type VolumeDentryCache struct

+ func NewVolumeDentryCache(maxElements int64) *VolumeDentryCache

+ func (vdc *VolumeDentryCache) GetAccessStat() (accssNum, validHit, miss uint64)

+ func (vdc *VolumeDentryCache) TotalNum() int

+ type VolumeInodeAttrsCache struct

+ func NewVolumeInodeAttrsCache(maxElements int64) *VolumeInodeAttrsCache

+ func (vac *VolumeInodeAttrsCache) GetAccessStat() (accssNum, validHit, miss uint64)

+ func (vac *VolumeInodeAttrsCache) SetMaxElements(maxElements int64)

+ func (vac *VolumeInodeAttrsCache) TotalNum() int

+ type VolumeLoader struct

+ func NewVolumeLoader(masters []string, store Store, strict bool) *VolumeLoader

+ func (loader *VolumeLoader) Close()

+ func (loader *VolumeLoader) Release(volName string)

+ func (loader *VolumeLoader) Volume(volName string) (*Volume, error)

+ func (loader *VolumeLoader) VolumeWithoutBlacklist(volName string) (*Volume, error)

type VolumeManager

+ func (m *VolumeManager) VolumeWithoutBlacklist(volName string) (*Volume, error)

+ type WebhookAudit struct

+ func NewWebhookAudit(id string, conf WebhookAuditConfig) (*WebhookAudit, error)

+ func (w *WebhookAudit) Close() error

+ func (w *WebhookAudit) Name() string

+ func (w *WebhookAudit) Send(data []byte) error

+ type WebhookAuditConfig struct

+ Enable bool

+ type WebhookConfig struct

+ Authorization string

+ Endpoint string

+ Proxy string

+ Transport TransportConfig

+ func (c *WebhookConfig) BuildClient() (*http.Client, error)

+ func (c *WebhookConfig) FixConfig() error

v1.5.1

Jan 20, 2020 GO-2024-2430 +4 more

GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

Changes in this version

+ type Wildcard struct

+ func NewWildcard(domain string) (*Wildcard, error)

+ func (w *Wildcard) Parse(host string) (bucket string, is bool)

+ type Wildcards []*Wildcard

+ func NewWildcards(domains []string) (Wildcards, error)

+ func (ws Wildcards) Parse(host string) (bucket string, is bool)

v1.5.0

Jan 8, 2020 GO-2024-2430 +4 more

GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

Changes in this version

+ const AMZTimeFormat

+ const AbortMultipartUploadAction

+ const ArnEquals

+ const ArnLike

+ const ArnNotEquals

+ const ArnNotLike

+ const ArnSplitToken

+ const AuthenticatedReadACL

+ const AwsCurrentTime

+ const AwsEpochTime

+ const AwsExecReadACL

+ const AwsMultiFactorAuthPresent

+ const AwsPrincipalAccount

+ const AwsPrincipalArn

+ const AwsPrincipalOrgID

+ const AwsPrincipalTag

+ const AwsPrincipalType

+ const AwsReferer

+ const AwsRequestRegion

+ const AwsRequestTagKey

+ const AwsResourceTagKey

+ const AwsSecureTransport

+ const AwsSourceAccout

+ const AwsSourceArn

+ const AwsSourceIp

+ const AwsSourceVpc

+ const AwsSourceVpce

+ const AwsTagKeys

+ const AwsTokenIssueTime

+ const AwsUserAgent

+ const AwsUserId

+ const AwsUserName

+ const AwsVpcSourceIp

+ const Bool

+ const BucketOwnerFullControlACL

+ const BucketOwnerReadACL

+ const BucketPolicyLimitSize

+ const CreateBucketAction

+ const DEF_GRANTEE_TYPE

+ const DateEquals

+ const DateFormatISO8601

+ const DateGreaterThan

+ const DateGreaterThanEquals

+ const DateLessThan

+ const DateLessThanEquals

+ const DateNotEquals

+ const DeleteBucketPolicyAction

+ const DeleteObjectAction

+ const EmptyContentMD5String

+ const FullControlPermission

+ const GetBucketAclAction

+ const GetBucketLocationAction

+ const GetBucketPolicyAction

+ const GetObjectAclAction

+ const GetObjectAction

+ const GetObjectTorrentAction

+ const GetObjectVersionAclAction

+ const GetObjectVersionAction

+ const HeadObjectAction

+ const HeaderNameAcceptRange

+ const HeaderNameAuthorization

+ const HeaderNameContentEnc

+ const HeaderNameContentHash

+ const HeaderNameContentLength

+ const HeaderNameContentMD5

+ const HeaderNameContentRange

+ const HeaderNameContentType

+ const HeaderNameCopyMatch

+ const HeaderNameCopyModified

+ const HeaderNameCopyNoneMatch

+ const HeaderNameCopySource

+ const HeaderNameCopyUnModified

+ const HeaderNameDate

+ const HeaderNameDecodeContentLength

+ const HeaderNameETag

+ const HeaderNameHost

+ const HeaderNameLastModified

+ const HeaderNameRange

+ const HeaderNameRequestId

+ const HeaderNameServer

+ const HeaderNameStartDate

+ const HeaderValueAcceptRange

+ const HeaderValueContentTypeXML

+ const HeaderValueServer

+ const HeaderValueTypeStream

+ const IpAddress

+ const ListBucketAction

+ const ListBucketMultipartUploadsAction

+ const ListBucketVersionsAction

+ const ListMultipartUploadPartsAction

+ const LogDeliveryRole

+ const LogDeliveryWriteACL

+ const META_OSS_VOLUME

+ const MaxKeys

+ const MaxParts

+ const MaxPresignedExpires

+ const MaxSkewTime

+ const MaxUploads

+ const NotIpAddress

+ const NumericEquals

+ const NumericGreaterThan

+ const NumericGreaterThanEquals

+ const NumericLessThan

+ const NumericLessThanEquals

+ const NumericNotEquals

+ const OSSMetaUpdateDuration

+ const OSS_ACL_KEY

+ const ParamContToken

+ const ParamFetchOwner

+ const ParamKeyMarker

+ const ParamMarker

+ const ParamMaxKeys

+ const ParamMaxParts

+ const ParamPartDelimiter

+ const ParamPartMaxUploads

+ const ParamPartNoMarker

+ const ParamPartNumber

+ const ParamPrefix

+ const ParamStartAfter

+ const ParamUploadId

+ const ParamUploadIdMarker

+ const PolicyDefaultVersion

+ const PresignedV2

+ const PresignedV4

+ const PresignedV4QueryAuth

+ const PrivateACL

+ const PublicReadACL

+ const PubliceReadWriteACL

+ const PutBucketAclAction

+ const PutBucketPolicyAction

+ const PutObjectAclAction

+ const PutObjectAction

+ const PutObjectTorrentAction

+ const PutObjectVersionAclAction

+ const PutObjectVersionAction

+ const ReadACPPermission

+ const ReadPermission

+ const RequestHeaderV2Authorization

+ const RequestHeaderV2AuthorizationScheme

+ const RequestHeaderV2XAmzDate

+ const Running

+ const Shutdown

+ const SignatrueV2

+ const SignatrueV4

+ const SignatureV4Algorithm

+ const SignatureV4Request

+ const SignedHeaderHost

+ const Standby

+ const Start

+ const Stopped

+ const StorageClassStandard

+ const StringEquals

+ const StringLike

+ const StringNotEquals

+ const StringNotLike

+ const SubMultipartUpload

+ const SubObjectDelete

+ const UnsignedPayload

+ const WriteACPPermission

+ const WritePermission

+ const XAmzAlgorithm

+ const XAmzContentSha256

+ const XAmzCredential

+ const XAmzDate

+ const XAmzExpires

+ const XAmzSignature

+ const XAmzSignedHeaders

+ const XAttrKeyOSSETag

+ const XAttrKeyOSSPolicy

+ const XAttrKeyOSSTagging

+ const XMLNS

+ const XMLXSI

+ var ALGORITHM = "HMAC-SHA256"

+ var AccessDenied = ErrorCode

+ var ArnFuncs = []ConditionFunc

+ var ArnType = ConditionTypeSet

+ var AuthSignatureV4Headers = []string

+ var BadDigest = ErrorCode

+ var BoolFuncs = []ConditionFunc

+ var BoolType = ConditionTypeSet

+ var BucketNotEmpty = ErrorCode

+ var BucketNotExisted = ErrorCode

+ var BucketNotExistedForHead = ErrorCode

+ var BucketNotOwnedByYou = ErrorCode

+ var ConditionFuncMap = map[ConditionType]ConditionFunc

+ var ConditionKeyType = map[ConditionKey]ConditionTypeSet

+ var DateFuncs = []ConditionFunc

+ var DateType = ConditionTypeSet

+ var EntityTooLarge = ErrorCode

+ var EntityTooSmall = ErrorCode

+ var ErrUnexpectedChunkEnd = errors.New("unexpected chunk end")

+ var ErrUnexpectedChunkSize = errors.New("unexpected chunk size")

+ var IncorrectNumberOfFilesInPostRequest = ErrorCode

+ var InternalError = ErrorCode

+ var InvalidArgument = ErrorCode

+ var InvalidBucketName = ErrorCode

+ var InvalidKey = ErrorCode

+ var InvalidParamError = errors.New("invalid param")

+ var InvalidRange = ErrorCode

+ var IpAddressFuncs = []ConditionFunc

+ var IpAddressType = ConditionTypeSet

+ var KeyTooLongError = ErrorCode

+ var MaxContentLength = ErrorCode

+ var MaxExpiresError = errors.New("max expires value")

+ var MissingContentLength = ErrorCode

+ var NoSuchBucket = ErrorCode

+ var NoSuchKey = ErrorCode

+ var NumericFuncs = []ConditionFunc

+ var NumericType = ConditionTypeSet

+ var PreconditionFailed = ErrorCode

+ var PresignedSignatureV2Queries = []string

+ var PresignedSignatureV4Queries = []string

+ var SCHEME = "AWS4"

+ var SERVICE = "s3"

+ var SignatureV2WhiteQueries = map[string]struct

+ var StringFuncs = []ConditionFunc

+ var StringType = ConditionTypeSet

+ var TERMINATOR = "aws4_request"

+ var UnsupportedOperation = ErrorCode

+ func ArnEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func ArnLikeFunc(p *RequestParam, value ConditionValues) bool

+ func ArnNotEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func ArnNotLikeFunc(p *RequestParam, value ConditionValues) bool

+ func BoolFunc(p *RequestParam, policyCondtion ConditionValues) bool

+ func DateEqualsFunc(p *RequestParam, policyVals ConditionValues) bool

+ func DateGreaterThanEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func DateGreaterThanFunc(p *RequestParam, value ConditionValues) bool

+ func DateLessThanEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func DateLessThanFunc(p *RequestParam, value ConditionValues) bool

+ func DateNotEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func IpAddressFunc(p *RequestParam, value ConditionValues) bool

+ func IsIntersectionActions(actions1, actions2 []Action) bool

+ func MarshalXMLEntity(entity interface{}) ([]byte, error)

+ func NewChunkedReader(reader io.ReadCloser) io.ReadCloser

+ func NotIpAddressFunc(p *RequestParam, values ConditionValues) bool

+ func NumericEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func NumericGreaterThanEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func NumericGreaterThanFunc(p *RequestParam, value ConditionValues) bool

+ func NumericLessThanEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func NumericLessThanFunc(p *RequestParam, value ConditionValues) bool

+ func NumericNotEqualsFunc(p *RequestParam, value ConditionValues) bool

+ func RequestIDFromRequest(r *http.Request) (id string)

+ func ServeInternalStaticErrorResponse(w http.ResponseWriter, r *http.Request)

+ func StringEqualsFunc(reqParam *RequestParam, storeCondVals ConditionValues) bool

+ func StringLikeFunc(reqParam *RequestParam, storeCondVals ConditionValues) bool

+ func StringNotEqualsFunc(p *RequestParam, values ConditionValues) bool

+ func StringNotLikeFunc(p *RequestParam, values ConditionValues) bool

+ func TrimAwsPrefixKey(key string) string

+ func UnmarshalXMLEntity(bytes []byte, data interface{}) error

+ type AccessControlList struct

+ Grants []Grant

+ type AccessControlPolicy struct

+ Acl AccessControlList

+ Owner Owner

+ Xmlns string

+ func ParseACL(bytes []byte, bucket string) (*AccessControlPolicy, error)

+ func (acl *AccessControlPolicy) Marshal() ([]byte, error)

+ func (acp *AccessControlPolicy) IsAllowed(param *RequestParam) bool

+ func (acp *AccessControlPolicy) SetBucketGrantACL(param *RequestParam, permission Permission)

+ func (acp *AccessControlPolicy) SetBucketStandardACL(param *RequestParam, acl string)

+ func (acp *AccessControlPolicy) Validate(bucket string) (bool, error)

+ type AclRole = string

+ type Action string

+ type Arn struct

+ type AuthType string

+ type BucketOwner struct

+ DisplayName string

+ ID string

+ XMLName xml.Name

+ func NewBucketOwner(accessKey string) *BucketOwner

+ type CheckFuncs func(p *RequestParam) bool

+ type CommonPrefix struct

+ Prefix string

+ XMLName xml.Name

+ type CompleteMultipartResult struct

+ Bucket string

+ ETag string

+ Key string

+ Location string

+ XMLName xml.Name

+ type Condition map[ConditionType]ConditionValues

+ type ConditionFunc func(p *RequestParam, values ConditionValues) bool

+ type ConditionKey string

+ type ConditionType string

+ type ConditionTypeSet map[ConditionType]null

+ type ConditionValues map[string]StringSet

+ type Content struct

+ ETag string

+ Key string

+ LastModified string

+ Owner *BucketOwner

+ Size int

+ StorageClass string

+ type CopyObjectResult struct

+ ETag string

+ LastModified string

+ XMLName xml.Name

+ type CopyResult struct

+ ETag string

+ LastModified string

+ XMLName xml.Name

+ type DeleteRequest struct

+ Objects []Object

+ XMLName xml.Name

+ type DeleteResult struct

+ Deleted []Deleted

+ Error []Error

+ XMLName xml.Name

+ type Deleted struct

+ DeleteMarker string

+ DeleteMarkerVersionId string

+ Key string

+ VersionId string

+ XMLName xml.Name

+ type DeletesResult struct

+ DeletedErrors []Error

+ DeletedObjects []Deleted

+ XMLName xml.Name

+ type Effect string

+ const Allow

+ const Deny

+ type Error struct

+ Code string

+ Key string

+ Message string

+ VersionId string

+ XMLName xml.Name

+ type ErrorCode struct

+ ErrorCode string

+ ErrorMessage string

+ StatusCode int

+ func (code ErrorCode) ServeResponse(w http.ResponseWriter, r *http.Request) error

+ type FSFileInfo struct

+ ETag string

+ Inode uint64

+ Mode os.FileMode

+ ModifyTime time.Time

+ Path string

+ Size int64

+ type FSPart struct

+ ETag string

+ LastModified string

+ PartNumber int

+ Size int

+ type FSUpload struct

+ Initiated string

+ Key string

+ StorageClass string

+ UploadId string

+ type GetBucketLocationOutput struct

+ LocationConstraint string

+ XMLName xml.Name

+ type Grant struct

+ Grantee Grantee

+ Permission Permission

+ func (g *Grant) IsAllowed(param *RequestParam) bool

+ func (g Grant) Validate() bool

+ type Grantee struct

+ DisplayName string

+ EmailAddress string

+ Id string

+ Type string

+ URI string

+ Xmlns string

+ Xmlsi string

+ type InitMultipartResult struct

+ Bucket string

+ Key string

+ UploadId string

+ XMLName xml.Name

+ type ListBucketRequestV1 struct

+ type ListBucketRequestV2 struct

+ type ListBucketResult struct

+ Bucket string

+ CommonPrefixes []*CommonPrefix

+ Contents []*Content

+ Delimiter string

+ IsTruncated bool

+ Marker string

+ MaxKeys int

+ NextMarker string

+ Prefix string

+ XMLName xml.Name

+ type ListBucketResultV2 struct

+ CommonPrefixes []*CommonPrefix

+ Contents []*Content

+ Delimiter string

+ IsTruncated bool

+ KeyCount uint64

+ MaxKeys uint64

+ Name string

+ NextToken string

+ Prefix string

+ Token string

+ XMLName xml.Name

+ type ListPartsResult struct

+ Bucket string

+ IsTruncated bool

+ Key string

+ MaxParts int

+ NextMarker int

+ Owner *BucketOwner

+ PartNumberMarker int

+ Parts []*Part

+ StorageClass string

+ UploadId string

+ XMLName xml.Name

+ type ListUploadsResult struct

+ Bucket string

+ CommonPrefixes []*CommonPrefix

+ Delimiter string

+ IsTruncated bool

+ KeyMarker string

+ MaxUploads int

+ NextKeyMarker string

+ NextUploadIdMarker string

+ Prefix string

+ UploadIdMarker string

+ Uploads []*Upload

+ XMLName xml.Name

+ type ListXAttrsResult struct

+ XAttrs []*XAttr

+ XMLName xml.Name

+ type MetaStore interface

+ type OSSMeta struct

+ type OSSOperation string

+ type Object struct

+ Key string

+ VersionId string

+ type ObjectNode struct

+ func NewServer() *ObjectNode

+ func (o *ObjectNode) Shutdown()

+ func (o *ObjectNode) Start(cfg *config.Config) (err error)

+ func (o *ObjectNode) Sync()

+ type Owner struct

+ DispalyName string

+ Id string

+ type Part struct

+ ETag string

+ LastModified string

+ PartNumber int

+ Size int

+ XMLName xml.Name

+ func NewParts(fsParts []*FSPart) []*Part

+ type Permission string

+ type Policy struct

+ Id string

+ Statements []Statement

+ Version string

+ func ParsePolicy(r io.Reader, bucket string) (*Policy, error)

+ func (p *Policy) IsAllowed(params *RequestParam) bool

+ func (p Policy) Validate(bucket string) (bool, error)

+ type PrefixMap map[string]struct

+ func (m PrefixMap) AddPrefix(prefix string)

+ func (m PrefixMap) Prefixes() Prefixes

+ type Prefixes []string

+ type Principal map[string]StringSet

+ type PutXAttrRequest struct

+ XAttr *XAttr

+ XMLName xml.Name

+ type RequestAuthInfo struct

+ type RequestParam struct

+ type Resource string

+ type ResourceType string

+ type StandardACL string

+ type Statement struct

+ Actions StringSet

+ Condition Condition

+ Effect Effect

+ NotActions StringSet

+ NotResources StringSet

+ Principal Principal

+ Resources StringSet

+ Sid string

+ func (s *Statement) Validate(bucket string) (bool, error)

+ func (s Statement) IsAllowed(p *RequestParam) bool

+ type Store interface

+ Delete func(ns, obj, key string) error

+ Get func(ns, obj, key string) (data []byte, err error)

+ Init func(vm *volumeManager)

+ List func(ns, obj string) (data [][]byte, err error)

+ Put func(ns, obj, key string, data []byte) error

+ type StringSet struct

+ func (ss *StringSet) Contains(val string) bool

+ func (ss *StringSet) ContainsRegex(val string) bool

+ func (ss *StringSet) ContainsWild(val string) bool

+ func (ss *StringSet) ContainsWithAny(val string) bool

+ func (ss *StringSet) Empty() bool

+ func (ss *StringSet) Intersection(set *StringSet) bool

+ func (ss *StringSet) UnmarshalJSON(b []byte) error

+ func (ss StringSet) MarshalJSON() ([]byte, error)

+ func (ss StringSet) String() string

+ type Tag struct

+ Key string

+ Value string

+ type Tagging struct

+ TagSet []*Tag

+ XMLName xml.Name

+ type Upload struct

+ Initiated string

+ Key string

+ Owner *BucketOwner

+ StorageClass string

+ UploadId string

+ XMLName xml.Name

+ func NewUploads(fsUploads []*FSUpload, accessKey string) []*Upload

+ type Volume interface

+ AbortMultipart func(path, multipartID string) error

+ Close func() error

+ CompleteMultipart func(path, multipartID string) (*FSFileInfo, error)

+ CopyFile func(path, sourcePath string) (*FSFileInfo, error)

+ DeleteFile func(path string) error

+ DeleteXAttr func(path string, key string) error

+ FileInfo func(path string) (*FSFileInfo, error)

+ GetXAttr func(path string, key string) (*proto.XAttrInfo, error)

+ InitMultipart func(path string) (multipartID string, err error)

+ ListFilesV1 func(request *ListBucketRequestV1) ([]*FSFileInfo, string, bool, []string, error)

+ ListFilesV2 func(request *ListBucketRequestV2) ([]*FSFileInfo, uint64, string, bool, []string, error)

+ ListMultipartUploads func(prefix, delimiter, keyMarker, uploadIdMarker string, maxUploads uint64) ([]*FSUpload, string, string, bool, []string, error)

+ ListParts func(path, multipartID string, maxParts, partNumberMarker uint64) ([]*FSPart, uint64, bool, error)

+ OSSMeta func() *OSSMeta

+ OSSSecure func() (accessKey, secretKey string)

+ ReadFile func(path string, writer io.Writer, offset, size uint64) error

+ SetXAttr func(path string, key string, data []byte) error

+ WriteFile func(path string, reader io.Reader) (*FSFileInfo, error)

+ WritePart func(path, multipartID string, partId uint16, reader io.Reader) (*FSFileInfo, error)

+ type VolumeManager interface

+ Close func()

+ GetStore func() (Store, error)

+ InitStore func(s Store)

+ Release func(volName string)

+ Volume func(volName string) (Volume, error)

+ func NewVolumeManager(masters []string) VolumeManager

+ type XAttr struct

+ Key string

+ Value string

Incompatible versions in this module

v3.0.0-beta-rc.1+incompatible

Jan 27, 2022

GO-2024-2430

+4 more

v3.0.0-beta-rc.0+incompatible

Oct 19, 2021

GO-2024-2430

+4 more

v3.0.0-beta+incompatible

Jan 27, 2022

GO-2024-2430

+4 more

v2.5.2+incompatible

Jun 27, 2022

GO-2024-2430

+4 more

v2.5.1+incompatible

Jan 26, 2022

GO-2024-2430

+4 more

v2.5.1-rc.0+incompatible

Jan 26, 2022

GO-2024-2430

+4 more

v2.5.0+incompatible

Dec 15, 2021

GO-2024-2430

+4 more

v2.5.0-rc.1+incompatible

Dec 15, 2021

GO-2024-2430

+4 more

v2.5.0-rc.0+incompatible

Sep 24, 2021

GO-2024-2430

+4 more

v2.4.3+incompatible

Mar 18, 2022

GO-2024-2430

+4 more

v2.4.1+incompatible

Dec 31, 2021

GO-2024-2430

+4 more

v2.4.1-rc.1+incompatible

Oct 19, 2021

GO-2024-2430

+4 more

v2.4.1-rc.0+incompatible

Sep 2, 2021

GO-2024-2430

+4 more

v2.4.0+incompatible

May 14, 2021

GO-2024-2430

+4 more

v2.4.0-rc.1+incompatible

Apr 23, 2021

GO-2024-2430

+4 more

v2.4.0-rc.0+incompatible

Apr 14, 2021

GO-2024-2430

+4 more

v2.3.0+incompatible

Feb 28, 2021

GO-2024-2430

+4 more

v2.3.0-rc.2+incompatible

Feb 9, 2021

GO-2024-2430

+4 more

v2.3.0-rc.1+incompatible

Jan 28, 2021

GO-2024-2430

+4 more

v2.2.2+incompatible

Sep 23, 2020

GO-2024-2430

+4 more

v2.2.1+incompatible

Sep 7, 2020

GO-2024-2430

+4 more

v2.2.0+incompatible

Sep 4, 2020

GO-2024-2430

+4 more

v2.1.0+incompatible

Jul 10, 2020

GO-2024-2430

+4 more

v2.1.0-rc.1+incompatible

Jun 13, 2020

GO-2024-2430

+4 more

v2.0.0+incompatible

Apr 10, 2020

GO-2024-2430

+4 more

v2.0.0-rc.1+incompatible

Apr 9, 2020

GO-2024-2430

+4 more

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