tidbclient

Documentation

Index

• func GarbageCollectionFromFreeze(f *Freezer) (gc GarbageCollection)
• func GarbageCollectionFromObject(o *Object) (gc GarbageCollection)
• 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) 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) GetGarbageCollection(bucketName, objectName, version string) (gc GarbageCollection, 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) (*Object, error)
  • func (t *TidbClient) GetUserBuckets(userId string) (buckets []string, err error)
  • func (t *TidbClient) IsEmptyBucket(bucket *Bucket) (bool, 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) PutFreezerToGarbageCollection(object *Freezer, 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) (err error)
  • func (t *TidbClient) PutObjectToGarbageCollection(object *Object, tx Tx) (err error)
  • func (t *TidbClient) RemoveBucketForUser(bucketName string, userId string) (err error)
  • func (t *TidbClient) RemoveBucketFromLifeCycle(bucket Bucket) error
  • func (t *TidbClient) RemoveGarbageCollection(garbage GarbageCollection) (err 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) ScanGarbageCollection(limit int) (gcs []GarbageCollection, 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) UpdateFreezerObject(object *Object, tx Tx) (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)
  • func (t *TidbClient) UploadFreezerDate(bucketName, objectName, version string, lifetime int) (err error)

Functions

func GarbageCollectionFromFreeze

func GarbageCollectionFromFreeze(f *Freezer) (gc GarbageCollection)

func GarbageCollectionFromObject

func GarbageCollectionFromObject(o *Object) (gc GarbageCollection)

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) 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) GetGarbageCollection

func (t *TidbClient) GetGarbageCollection(bucketName, objectName, version string) (gc GarbageCollection, err error)

common func

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) (*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) 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) PutFreezerToGarbageCollection

func (t *TidbClient) PutFreezerToGarbageCollection(object *Freezer, 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) (err error)

func (*TidbClient) PutObjectToGarbageCollection

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

gc

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) RemoveGarbageCollection

func (t *TidbClient) RemoveGarbageCollection(garbage GarbageCollection) (err 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) ScanGarbageCollection

func (t *TidbClient) ScanGarbageCollection(limit int) (gcs []GarbageCollection, 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) UpdateFreezerObject

func (t *TidbClient) UpdateFreezerObject(object *Object, tx Tx) (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)

func (*TidbClient) UploadFreezerDate

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