types

Aug 20, 2020

Changes in this version

type Freezer

+ func (o *Freezer) GetCreateWithoutMigrateSql() (string, []interface{})

type Part

+ func (p *Part) GetCreateFreezerSql(bucketname, objectname, version string) (string, []interface{})

May 8, 2018

Changes in this version

+ const BUCKET_ACL_COLUMN_FAMILY

+ const BUCKET_COLUMN_FAMILY

+ const BUCKET_CORS_COLUMN_FAMILY

+ const BUCKET_TABLE

+ const CLUSTER_COLUMN_FAMILY

+ const CLUSTER_TABLE

+ const GARBAGE_COLLECTION_COLUMN_FAMILY

+ const GARBAGE_COLLECTION_PART_COLUMN_FAMILY

+ const GARBAGE_COLLECTION_TABLE

+ const LIFE_CYCLE_COLUMN_FAMILY

+ const LIFE_CYCLE_TABLE

+ const MULTIPART_COLUMN_FAMILY

+ const MULTIPART_TABLE

+ const OBJECT_COLUMN_FAMILY

+ const OBJECT_PART_COLUMN_FAMILY

+ const OBJECT_TABLE

+ const OBJMAP_COLUMN_FAMILY

+ const OBJMAP_TABLE

+ const USER_COLUMN_FAMILY

+ const USER_TABLE

type Bucket

+ LC datatype.Lc

+ func (b *Bucket) GetValues() (values map[string]map[string][]byte, err error)

type Cluster

+ func (c Cluster) GetValues() (values map[string]map[string][]byte, err error)

type GarbageCollection

+ func (gc GarbageCollection) GetRowkey() (string, error)

+ func (gc GarbageCollection) GetValues() (values map[string]map[string][]byte, err error)

+ func (gc GarbageCollection) GetValuesForDelete() map[string]map[string][]byte

type LifeCycle

+ func (lc LifeCycle) GetRowkey() (string, error)

+ func (lc LifeCycle) GetValues() (values map[string]map[string][]byte, err error)

+ func (lc LifeCycle) GetValuesForDelete() map[string]map[string][]byte

type Multipart

+ func (m *Multipart) GetRowkey() (string, error)

+ func (m *Multipart) GetValues() (values map[string]map[string][]byte, err error)

+ func (m *Multipart) GetValuesForDelete() map[string]map[string][]byte

type ObjMap

+ func (om *ObjMap) GetRowKey() (string, error)

+ func (om *ObjMap) GetValues() (values map[string]map[string][]byte, err error)

+ func (om *ObjMap) GetValuesForDelete() (values map[string]map[string][]byte)

type Object

+ func (o *Object) GetRowkey() (string, error)

+ func (o *Object) GetValues() (values map[string]map[string][]byte, err error)

+ func (o *Object) GetValuesForDelete() (values map[string]map[string][]byte)

type Part

+ func (p *Part) GetValues() (values map[string]map[string][]byte, err error)

Apr 21, 2020

Changes in this version

+ const VersionDisabled

+ const VersionEnabled

+ const VersionSuspended

+ var StatusIndexMap = map[Status]string

+ var StatusStringMap = map[string]Status

+ var StorageClassIndexMap = map[StorageClass]string

+ var StorageClassStringMap = map[string]StorageClass

+ var XXTEA_KEY = []byte("hehehehe")

+ func GetMultipartUploadIdForTidb(uploadtime uint64) string

+ type DB interface

+ Exec func(string, ...interface{}) (sql.Result, error)

+ Query func(string, ...interface{}) (*sql.Rows, error)

+ QueryRow func(string, ...interface{}) *sql.Row

type Freezer

+ Etag string

+ OwnerId string

+ Rowkey []byte

type Multipart

+ func (m *Multipart) GetUploadId() (string, error)

+ type ObjMap struct

+ BucketName string

+ Name string

+ NullVerId string

+ NullVerNum uint64

+ Rowkey []byte

type Object

+ func (o *Object) GetAddUsageSql() (string, []interface{})

+ func (o *Object) GetAppendSql() (string, []interface{})

+ func (o *Object) GetSubUsageSql() (string, []interface{})

+ func (o *Object) GetVersionId() string

+ func (o *Object) GetVersionNumber() (uint64, error)

+ type Status uint8

+ const ObjectHasRestored

+ const ObjectNeedRestore

+ const ObjectRestoring

+ func MatchStatusIndex(status string) (Status, error)

+ func (s Status) ToString() string

+ type StorageClass uint8

+ const ObjectStorageClassDeepArchive

+ const ObjectStorageClassGlacier

+ const ObjectStorageClassIntelligentTiering

+ const ObjectStorageClassOnezoneIa

+ const ObjectStorageClassReducedRedundancy

+ const ObjectStorageClassStandard

+ const ObjectStorageClassStandardIa

+ func MatchStorageClassIndex(storageClass string) (StorageClass, error)

+ func (s StorageClass) ToString() string

Sep 16, 2020

Changes in this version

+ const CREATE_TIME_LAYOUT

+ const DeadLineForGlacier

+ const DeadLineForStandardIa

+ const INITIALIZATION_VECTOR_LENGTH

+ const LcEnding

+ const LcPending

+ const NullVersion

+ const ObjectNameEnding

+ const ObjectNameSeparator

+ const ObjectNameSmallestStr

+ const ResponseNumberOfRows

+ const TIME_LAYOUT_TIDB

+ var SSE_S3_MASTER_KEY = []byte("hehehehehehehehehehehehehehehehe")

+ func DecodeUint64(bin []byte) uint64

+ func EncodeUint64(i uint64) []byte

+ func GetInitialTimeFromUploadId(uploadId string) (uint64, error)

+ func GetMultipartUploadIdByDbTime(uploadtime uint64) string

+ type BackendType uint8

+ const BackendCeph

+ type Bucket struct

+ ACL datatype.Acl

+ BucketLogging datatype.BucketLoggingStatus

+ CORS datatype.Cors

+ CreateTime time.Time

+ Encryption datatype.EncryptionConfiguration

+ Lifecycle lifecycle.Lifecycle

+ Name string

+ OwnerId string

+ Policy []byte

+ Usage int64

+ Versioning datatype.BucketVersioningType

+ Website datatype.WebsiteConfiguration

+ func (b *Bucket) String() (s string)

+ func (b Bucket) GetCreateSql() (string, []interface{})

+ func (b Bucket) GetUpdateSql() (string, []interface{})

+ type Cluster struct

+ Backend BackendType

+ Fsid string

+ Pool string

+ Weight int

+ type CompleteMultipartUpload struct

+ Parts []CompletePart

+ type CompletePart struct

+ ETag string

+ PartNumber int

+ type CompletedParts []CompletePart

+ func (a CompletedParts) Len() int

+ func (a CompletedParts) Less(i, j int) bool

+ func (a CompletedParts) Swap(i, j int)

+ type Freezer struct

+ BucketName string

+ CreateTime uint64

+ LastModifiedTime time.Time

+ LifeTime int

+ Location string

+ Name string

+ ObjectId string

+ Parts map[int]*Part

+ PartsIndex *SimpleIndex

+ Pool string

+ Size int64

+ Status RestoreStatus

+ Type ObjectType

+ VersionId string

+ func (f *Freezer) ToObject() (o Object)

+ func (o *Freezer) GetCreateSql() (string, []interface{})

+ func (o *Freezer) GetUpdateSql(status RestoreStatus) (string, []interface{})

+ type GarbageCollection struct

+ BucketName string

+ Location string

+ MTime time.Time

+ ObjectId string

+ ObjectName string

+ Parts map[int]*Part

+ Pool string

+ Rowkey string

+ Status string

+ TriedTimes int

+ VersionId string

+ func GetGcInfoFromObject(o *Object) (gc GarbageCollection)

+ type LifeCycle struct

+ BucketName string

+ EndTime uint64

+ StartTime uint64

+ Status string

+ func (l LifeCycle) GetCreateSql() (string, []interface{})

+ func (l LifeCycle) GetUpdateSql() (string, []interface{})

+ type ListHotObjectsInfo struct

+ IsTruncated bool

+ NextMarker string

+ Objects []*Object

+ type ListObjectsInfo struct

+ IsTruncated bool

+ NextMarker string

+ Objects []datatype.Object

+ Prefixes []string

+ type Multipart struct

+ BucketName string

+ InitialTime uint64

+ Metadata MultipartMetadata

+ ObjectName string

+ Parts map[int]*Part

+ UploadId string

+ func (m *Multipart) GenUploadId() error

+ type MultipartMetadata struct

+ Acl datatype.Acl

+ Attrs map[string]string

+ CipherKey []byte

+ ContentType string

+ EncryptionKey []byte

+ InitiatorId string

+ Location string

+ OwnerId string

+ Pool string

+ SseRequest datatype.SseRequest

+ StorageClass StorageClass

+ type Object struct

+ ACL datatype.Acl

+ BucketName string

+ ContentType string

+ CreateTime uint64

+ CustomAttributes map[string]string

+ DeleteMarker bool

+ DeltaSize int64

+ EncryptionKey []byte

+ Etag string

+ InitializationVector []byte

+ LastModifiedTime time.Time

+ Location string

+ Name string

+ NullVersion bool

+ ObjectId string

+ OwnerId string

+ Parts map[int]*Part

+ PartsIndex *SimpleIndex

+ Pool string

+ Rowkey []byte

+ Size int64

+ SseType string

+ StorageClass StorageClass

+ Type ObjectType

+ VersionId string

+ func (o *Object) GenVersionId(bucketVersionType datatype.BucketVersioningType) string

+ func (o *Object) GetCreateHotSql() (string, []interface{})

+ func (o *Object) GetCreateSql() (string, []interface{})

+ func (o *Object) GetGlacierUpdateSql() (string, []interface{})

+ func (o *Object) GetRemoveHotSql() (string, []interface{})

+ func (o *Object) GetReplaceObjectMetasSql() (string, []interface{})

+ func (o *Object) GetUpdateAclSql() (string, []interface{})

+ func (o *Object) GetUpdateAttrsSql() (string, []interface{})

+ func (o *Object) GetUpdateHotSql() (string, []interface{})

+ func (o *Object) GetUpdateNameSql(sourceObject string) (string, []interface{})

+ func (o *Object) GetUpdateObjectPartNameSql(sourceObject string) (string, []interface{})

+ func (o *Object) GetUpdateSql() (string, []interface{})

+ func (o *Object) IsUnexpired() (bool, int64)

+ func (o *Object) ObjectTypeToString() string

+ func (o *Object) String() (s string)

+ type ObjectType int

+ const ObjectTypeAppendable

+ const ObjectTypeMultipart

+ const ObjectTypeNormal

+ type Part struct

+ BucketName string

+ Etag string

+ InitializationVector []byte

+ LastModified string

+ ObjectId string

+ ObjectName string

+ Offset int64

+ PartNumber int

+ Size int64

+ Version uint64

+ func (p *Part) GetCreateGcSql(bucketname, objectname string, version uint64) (string, []interface{})

+ func (p *Part) GetCreateSql(bucketname, objectname, version string) (string, []interface{})

+ type PartTooSmall struct

+ PartETag string

+ PartNumber int

+ PartSize int64

+ func (e PartTooSmall) Error() string

+ type ScanLifeCycleResult struct

+ Lcs []LifeCycle

+ NextMarker string

+ Truncated bool

+ type SimpleIndex struct

+ Index []int64

+ func (array *SimpleIndex) SearchLowerBound(key int64) int

+ func (array *SimpleIndex) SearchUpperBound(key int64) int

+ type UserQos struct

+ Bandwidth int

+ ReadQps int

+ UserID string

+ WriteQps int

+ type Users struct

+ BucketName string

+ Glacier uint64

+ OwnerId string

+ Standard uint64

+ StandardIa uint64

+ type VersionedListObjectsInfo struct

+ IsTruncated bool

+ NextKeyMarker string

+ NextVersionIdMarker string

+ Objects []datatype.VersionedObject

+ Prefixes []string