tidbclient

Documentation

Index

• func GarbageCollectionFromObject(o *Object) (gc GarbageCollection)
• type TidbClient
  • func NewTidbClient() *TidbClient
  • func (t *TidbClient) AbortTrans(tx *sql.Tx) (err error)
  • func (t *TidbClient) AddBucketForUser(bucketName, userId string) (err error)
  • func (t *TidbClient) CheckAndPutBucket(bucket Bucket) (bool, error)
  • func (t *TidbClient) CommitTrans(tx *sql.Tx) (err error)
  • func (t *TidbClient) CreateMultipart(multipart Multipart) (err error)
  • func (t *TidbClient) DeleteBucket(bucket Bucket) error
  • func (t *TidbClient) DeleteMultipart(multipart *Multipart, tx DB) (err error)
  • func (t *TidbClient) DeleteObject(object *Object, tx DB) (err error)
  • func (t *TidbClient) DeleteObjectMap(objMap *ObjMap, tx DB) (err error)
  • func (t *TidbClient) DeleteOldObjects(latestObject *Object, tx DB) (err error)
  • func (t *TidbClient) GetAllObject(bucketName, objectName, version string) (object []*Object, err error)
  • func (t *TidbClient) GetAllOldObjects(bucketName, objectName, latestVersion string) (object []*Object, err error)
  • func (t *TidbClient) GetBucket(bucketName string) (bucket *Bucket, err error)
  • func (t *TidbClient) GetBuckets() (buckets []Bucket, err error)
  • func (t *TidbClient) GetClusters() (cluster []Cluster, err error)
  • func (t *TidbClient) GetGarbageCollection(bucketName, objectName, version string) (gc GarbageCollection, err error)
  • func (t *TidbClient) GetMultipart(bucketName, objectName, uploadId string) (multipart Multipart, err error)
  • func (t *TidbClient) GetObject(bucketName, objectName, version string) (object *Object, err error)
  • func (t *TidbClient) GetObjectMap(bucketName, objectName string) (objMap *ObjMap, err error)
  • func (t *TidbClient) GetUserBuckets(userId string) (buckets []string, err error)
  • func (t *TidbClient) ListMultipartUploads(bucketName, keyMarker, uploadIdMarker, prefix, delimiter, encodingType string, ...) (uploads []datatype.Upload, prefixs []string, isTruncated bool, ...)
  • func (t *TidbClient) ListObjects(bucketName, marker, verIdMarker, prefix, delimiter string, versioned bool, ...) (retObjects []*Object, prefixes []string, truncated bool, ...)
  • func (t *TidbClient) NewTrans() (tx *sql.Tx, err error)
  • func (t *TidbClient) PutBucket(bucket Bucket) error
  • func (t *TidbClient) PutBucketToLifeCycle(lifeCycle LifeCycle) error
  • func (t *TidbClient) PutObject(object *Object, tx DB) (err error)
  • func (t *TidbClient) PutObjectMap(objMap *ObjMap, tx DB) (err error)
  • func (t *TidbClient) PutObjectPart(multipart *Multipart, part *Part, tx DB) (err error)
  • func (t *TidbClient) PutObjectToGarbageCollection(object *Object, tx DB) (err error)
  • func (t *TidbClient) PutObjectWithoutMultiPart(object *Object) 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) RenameObject(object *Object, sourceObject string, tx DB) (err error)
  • func (t *TidbClient) RenameObjectPart(object *Object, sourceObject string, tx DB) (err error)
  • func (t *TidbClient) ReplaceObjectMetas(object *Object, tx DB) (err error)
  • func (t *TidbClient) ScanGarbageCollection(limit int, startRowKey string) (gcs []GarbageCollection, err error)
  • func (t *TidbClient) ScanLifeCycle(limit int, marker string) (result ScanLifeCycleResult, err error)
  • func (t *TidbClient) UpdateAppendObject(object *Object, tx DB) (err error)
  • func (t *TidbClient) UpdateObject(object *Object, tx DB) (err error)
  • func (t *TidbClient) UpdateObjectAcl(object *Object) error
  • func (t *TidbClient) UpdateObjectAttrs(object *Object) error
  • func (t *TidbClient) UpdateObjectWithoutMultiPart(object *Object) error
  • func (t *TidbClient) UpdateUsage(bucketName string, size int64, tx DB) (err error)

Functions

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 *sql.Tx) (err error)

func (*TidbClient) AddBucketForUser

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

func (*TidbClient) CheckAndPutBucket

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

func (*TidbClient) CommitTrans

func (t *TidbClient) CommitTrans(tx *sql.Tx) (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) DeleteMultipart

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

func (*TidbClient) DeleteObject

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

func (*TidbClient) DeleteObjectMap

func (t *TidbClient) DeleteObjectMap(objMap *ObjMap, tx DB) (err error)

func (*TidbClient) DeleteOldObjects

func (t *TidbClient) DeleteOldObjects(latestObject *Object, tx DB) (err error)

func (*TidbClient) GetAllObject

func (t *TidbClient) GetAllObject(bucketName, objectName, version string) (object []*Object, err error)

func (*TidbClient) GetAllOldObjects

func (t *TidbClient) GetAllOldObjects(bucketName, objectName, latestVersion string) (object []*Object, err error)

func (*TidbClient) GetBucket

func (t *TidbClient) GetBucket(bucketName string) (bucket *Bucket, err 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) GetGarbageCollection

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

util func

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 *Object, err error)

func (*TidbClient) GetObjectMap

func (t *TidbClient) GetObjectMap(bucketName, objectName string) (objMap *ObjMap, err error)

objmap

func (*TidbClient) GetUserBuckets

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

func (*TidbClient) ListMultipartUploads

func (t *TidbClient) ListMultipartUploads(bucketName, keyMarker, uploadIdMarker, prefix, delimiter, encodingType string, maxUploads int) (uploads []datatype.Upload, prefixs []string, isTruncated bool, nextKeyMarker, nextUploadIdMarker string, err error)

func (*TidbClient) ListObjects

func (t *TidbClient) ListObjects(bucketName, marker, verIdMarker, prefix, delimiter string, versioned bool, maxKeys int) (retObjects []*Object, prefixes []string, truncated bool, nextMarker, nextVerIdMarker string, err error)

func (*TidbClient) NewTrans

func (t *TidbClient) NewTrans() (tx *sql.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(lifeCycle LifeCycle) error

func (*TidbClient) PutObject

func (t *TidbClient) PutObject(object *Object, tx DB) (err error)

func (*TidbClient) PutObjectMap

func (t *TidbClient) PutObjectMap(objMap *ObjMap, tx DB) (err error)

func (*TidbClient) PutObjectPart

func (t *TidbClient) PutObjectPart(multipart *Multipart, part *Part, tx DB) (err error)

func (*TidbClient) PutObjectToGarbageCollection

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

gc

func (*TidbClient) PutObjectWithoutMultiPart

func (t *TidbClient) PutObjectWithoutMultiPart(object *Object) 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) RemoveGarbageCollection

func (t *TidbClient) RemoveGarbageCollection(garbage GarbageCollection) (err error)

func (*TidbClient) RenameObject

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

func (*TidbClient) RenameObjectPart

func (t *TidbClient) RenameObjectPart(object *Object, sourceObject string, tx DB) (err error)

func (*TidbClient) ReplaceObjectMetas

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

func (*TidbClient) ScanGarbageCollection

func (t *TidbClient) ScanGarbageCollection(limit int, startRowKey string) (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, tx DB) (err error)

func (*TidbClient) UpdateObject

func (t *TidbClient) UpdateObject(object *Object, tx DB) (err error)

func (*TidbClient) UpdateObjectAcl

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

func (*TidbClient) UpdateObjectAttrs

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

func (*TidbClient) UpdateObjectWithoutMultiPart

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

func (*TidbClient) UpdateUsage

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