tidbclient

Documentation

Index

• Constants
• type TidbClient
  • func NewTidbClient() *TidbClient
  • func (t *TidbClient) AbortTrans(tx Tx) (err error)
  • func (t *TidbClient) AppendObject(object *Object, updateUsage bool) (err error)
  • func (t *TidbClient) CheckAndPutBucket(bucket Bucket) (bool, error)
  • func (t *TidbClient) CommitTrans(tx Tx) (err error)
  • func (t *TidbClient) CreateFreezer(freezer *Freezer) (err error)
  • func (t *TidbClient) CreateMultipart(multipart Multipart) (err error)
  • func (t *TidbClient) DeleteBucket(bucket Bucket) error
  • func (t *TidbClient) DeleteFreezer(bucketName, objectName, versionId string, objectType ObjectType, ...) (err error)
  • func (t *TidbClient) DeleteFreezerPart(bucketName, objectName string, createTime uint64, tx Tx) (err error)
  • func (t *TidbClient) DeleteMultipart(multipart *Multipart, tx Tx) (err error)
  • func (t *TidbClient) DeleteObject(object *Object, tx Tx) (err error)
  • func (t *TidbClient) DeleteObjectPart(object *Object, tx Tx) (err error)
  • func (t *TidbClient) GetAllUserBuckets() (bucketUser map[string]string, err error)
  • func (t *TidbClient) GetAllUserQos() (userQos map[string]UserQos, err error)
  • func (t *TidbClient) GetBucket(bucketName string) (bucket *Bucket, err error)
  • func (t *TidbClient) GetBucketLifeCycle(bucket Bucket) (*LifeCycle, error)
  • func (t *TidbClient) GetBuckets() (buckets []Bucket, err error)
  • func (t *TidbClient) GetClusters() (cluster []Cluster, err error)
  • func (t *TidbClient) GetFreezer(bucketName, objectName, version string) (freezer *Freezer, err error)
  • func (t *TidbClient) GetFreezerStatus(bucketName, objectName, version string) (freezer *Freezer, err error)
  • func (t *TidbClient) GetLatestObjectVersion(bucketName, objectName string) (*Object, error)
  • func (t *TidbClient) GetMultipart(bucketName, objectName, uploadId string) (multipart Multipart, err error)
  • func (t *TidbClient) GetObject(bucketName, objectName, version string, tx Tx) (*Object, error)
  • func (t *TidbClient) GetUserBuckets(userId string) (buckets []string, err error)
  • func (t *TidbClient) IsEmptyBucket(bucket *Bucket) (bool, error)
  • func (t *TidbClient) ListFreezersWithStatus(maxKeys int, status common.RestoreStatus) (retFreezers []Freezer, err error)
  • func (t *TidbClient) ListHotObjects(marker string, maxKeys int) (listInfo ListHotObjectsInfo, err error)
  • func (t *TidbClient) ListLatestObjects(bucketName, marker, prefix, delimiter string, maxKeys int) (listInfo ListObjectsInfo, err error)
  • func (t *TidbClient) ListMultipartUploads(bucketName, keyMarker, uploadIdMarker, prefix, delimiter, encodingType string, ...) (result datatype.ListMultipartUploadsResponse, err error)
  • func (t *TidbClient) ListObjects(bucketName, marker, prefix, delimiter string, maxKeys int) (listInfo ListObjectsInfo, err error)
  • func (t *TidbClient) ListVersionedObjects(bucketName, marker, verIdMarker, prefix, delimiter string, maxKeys int) (listInfo VersionedListObjectsInfo, err error)
  • func (t *TidbClient) MigrateObject(object *Object) (err error)
  • func (t *TidbClient) NewTrans() (tx Tx, err error)
  • func (t *TidbClient) PutBucket(bucket Bucket) error
  • func (t *TidbClient) PutBucketToLifeCycle(bucket Bucket, lifeCycle LifeCycle) error
  • func (t *TidbClient) PutFreezer(freezer *Freezer, status common.RestoreStatus, tx Tx) (err error)
  • func (t *TidbClient) PutNewBucket(bucket Bucket) error
  • func (t *TidbClient) PutObject(object *Object, multipart *Multipart, updateUsage bool) (err error)
  • func (t *TidbClient) PutObjectPart(multipart *Multipart, part *Part) (deltaSize int64, err error)
  • func (t *TidbClient) RemoveBucketForUser(bucketName string, userId string) (err error)
  • func (t *TidbClient) RemoveBucketFromLifeCycle(bucket Bucket) error
  • func (t *TidbClient) RemoveHotObject(object *Object, tx Tx) (err error)
  • func (t *TidbClient) RenameObject(object *Object, sourceObject string) (err error)
  • func (t *TidbClient) ReplaceObjectMetas(object *Object, tx Tx) (err error)
  • func (t *TidbClient) ScanLifeCycle(limit int, marker string) (result ScanLifeCycleResult, err error)
  • func (t *TidbClient) UpdateAppendObject(object *Object) (err error)
  • func (t *TidbClient) UpdateFreezerDate(bucketName, objectName, version string, lifetime int) (err error)
  • func (t *TidbClient) UpdateFreezerStatus(bucketName, objectName, version string, ...) (err error)
  • func (t *TidbClient) UpdateObject(object *Object, multipart *Multipart, updateUsage bool, tx Tx) (err error)
  • func (t *TidbClient) UpdateObjectAcl(object *Object) error
  • func (t *TidbClient) UpdateObjectAttrs(object *Object) error
  • func (t *TidbClient) UpdateUsage(bucketName string, size int64, tx Tx) (err error)

Constants

const MaxKeySuffix = string(0xFF)

Types

type TidbClient

type TidbClient struct {
	Client *sql.DB
}

func NewTidbClient

func NewTidbClient() *TidbClient

func (*TidbClient) AbortTrans

func (t *TidbClient) AbortTrans(tx Tx) (err error)

func (*TidbClient) AppendObject

func (t *TidbClient) AppendObject(object *Object, updateUsage bool) (err error)

func (*TidbClient) CheckAndPutBucket

func (t *TidbClient) CheckAndPutBucket(bucket Bucket) (bool, error)

func (*TidbClient) CommitTrans

func (t *TidbClient) CommitTrans(tx Tx) (err error)

func (*TidbClient) CreateFreezer

func (t *TidbClient) CreateFreezer(freezer *Freezer) (err error)

func (*TidbClient) CreateMultipart

func (t *TidbClient) CreateMultipart(multipart Multipart) (err error)

func (*TidbClient) DeleteBucket

func (t *TidbClient) DeleteBucket(bucket Bucket) error

func (*TidbClient) DeleteFreezer

func (t *TidbClient) DeleteFreezer(bucketName, objectName, versionId string, objectType ObjectType, createTime uint64, tx Tx) (err error)

func (*TidbClient) DeleteFreezerPart

func (t *TidbClient) DeleteFreezerPart(bucketName, objectName string, createTime uint64, tx Tx) (err error)

func (*TidbClient) DeleteMultipart

func (t *TidbClient) DeleteMultipart(multipart *Multipart, tx Tx) (err error)

func (*TidbClient) DeleteObject

func (t *TidbClient) DeleteObject(object *Object, tx Tx) (err error)

func (*TidbClient) DeleteObjectPart

func (t *TidbClient) DeleteObjectPart(object *Object, tx Tx) (err error)

func (*TidbClient) GetAllUserBuckets

func (t *TidbClient) GetAllUserBuckets() (bucketUser map[string]string, err error)

func (*TidbClient) GetAllUserQos

func (t *TidbClient) GetAllUserQos() (userQos map[string]UserQos, err error)

func (*TidbClient) GetBucket

func (t *TidbClient) GetBucket(bucketName string) (bucket *Bucket, err error)

func (*TidbClient) GetBucketLifeCycle

func (t *TidbClient) GetBucketLifeCycle(bucket Bucket) (*LifeCycle, error)

func (*TidbClient) GetBuckets

func (t *TidbClient) GetBuckets() (buckets []Bucket, err error)

func (*TidbClient) GetClusters

func (t *TidbClient) GetClusters() (cluster []Cluster, err error)

func (*TidbClient) GetFreezer

func (t *TidbClient) GetFreezer(bucketName, objectName, version string) (freezer *Freezer, err error)

func (*TidbClient) GetFreezerStatus

func (t *TidbClient) GetFreezerStatus(bucketName, objectName, version string) (freezer *Freezer, err error)

func (*TidbClient) GetLatestObjectVersion

func (t *TidbClient) GetLatestObjectVersion(bucketName, objectName string) (*Object, error)

func (*TidbClient) GetMultipart

func (t *TidbClient) GetMultipart(bucketName, objectName, uploadId string) (multipart Multipart, err error)

func (*TidbClient) GetObject

func (t *TidbClient) GetObject(bucketName, objectName, version string, tx Tx) (*Object, error)

func (*TidbClient) GetUserBuckets

func (t *TidbClient) GetUserBuckets(userId string) (buckets []string, err error)

func (*TidbClient) IsEmptyBucket

func (t *TidbClient) IsEmptyBucket(bucket *Bucket) (bool, error)

TODO: Only find one object

func (*TidbClient) ListFreezersWithStatus

func (t *TidbClient) ListFreezersWithStatus(maxKeys int, status common.RestoreStatus) (retFreezers []Freezer, err error)

func (*TidbClient) ListHotObjects

func (t *TidbClient) ListHotObjects(marker string, maxKeys int) (listInfo ListHotObjectsInfo, err error)

func (*TidbClient) ListLatestObjects

func (t *TidbClient) ListLatestObjects(bucketName, marker, prefix, delimiter string, maxKeys int) (listInfo ListObjectsInfo, err error)

func (*TidbClient) ListMultipartUploads

func (t *TidbClient) ListMultipartUploads(bucketName, keyMarker, uploadIdMarker, prefix, delimiter, encodingType string, maxUploads int) (result datatype.ListMultipartUploadsResponse, err error)

func (*TidbClient) ListObjects

func (t *TidbClient) ListObjects(bucketName, marker, prefix, delimiter string, maxKeys int) (listInfo ListObjectsInfo, err error)

func (*TidbClient) ListVersionedObjects

func (t *TidbClient) ListVersionedObjects(bucketName, marker, verIdMarker, prefix, delimiter string, maxKeys int) (listInfo VersionedListObjectsInfo, err error)

func (*TidbClient) MigrateObject

func (t *TidbClient) MigrateObject(object *Object) (err error)

func (*TidbClient) NewTrans

func (t *TidbClient) NewTrans() (tx Tx, err error)

func (*TidbClient) PutBucket

func (t *TidbClient) PutBucket(bucket Bucket) error

Actually this method is used to update bucket

func (*TidbClient) PutBucketToLifeCycle

func (t *TidbClient) PutBucketToLifeCycle(bucket Bucket, lifeCycle LifeCycle) error

func (*TidbClient) PutFreezer

func (t *TidbClient) PutFreezer(freezer *Freezer, status common.RestoreStatus, tx Tx) (err error)

func (*TidbClient) PutNewBucket

func (t *TidbClient) PutNewBucket(bucket Bucket) error

func (*TidbClient) PutObject

func (t *TidbClient) PutObject(object *Object, multipart *Multipart, updateUsage bool) (err error)

func (*TidbClient) PutObjectPart

func (t *TidbClient) PutObjectPart(multipart *Multipart, part *Part) (deltaSize int64, err error)

func (*TidbClient) RemoveBucketForUser

func (t *TidbClient) RemoveBucketForUser(bucketName string, userId string) (err error)

func (*TidbClient) RemoveBucketFromLifeCycle

func (t *TidbClient) RemoveBucketFromLifeCycle(bucket Bucket) error

func (*TidbClient) RemoveHotObject

func (t *TidbClient) RemoveHotObject(object *Object, tx Tx) (err error)

func (*TidbClient) RenameObject

func (t *TidbClient) RenameObject(object *Object, sourceObject string) (err error)

func (*TidbClient) ReplaceObjectMetas

func (t *TidbClient) ReplaceObjectMetas(object *Object, tx Tx) (err error)

func (*TidbClient) ScanLifeCycle

func (t *TidbClient) ScanLifeCycle(limit int, marker string) (result ScanLifeCycleResult, err error)

func (*TidbClient) UpdateAppendObject

func (t *TidbClient) UpdateAppendObject(object *Object) (err error)

func (*TidbClient) UpdateFreezerDate

func (t *TidbClient) UpdateFreezerDate(bucketName, objectName, version string, lifetime int) (err error)

func (*TidbClient) UpdateFreezerStatus

func (t *TidbClient) UpdateFreezerStatus(bucketName, objectName, version string, status, statusSetting common.RestoreStatus) (err error)

func (*TidbClient) UpdateObject

func (t *TidbClient) UpdateObject(object *Object, multipart *Multipart, updateUsage bool, tx Tx) (err error)

func (*TidbClient) UpdateObjectAcl

func (t *TidbClient) UpdateObjectAcl(object *Object) error

func (*TidbClient) UpdateObjectAttrs

func (t *TidbClient) UpdateObjectAttrs(object *Object) error

func (*TidbClient) UpdateUsage

func (t *TidbClient) UpdateUsage(bucketName string, size int64, tx Tx) (err error)