hbaseclient

Documentation

Index

• Variables
• func GarbageCollectionFromObject(o *Object) (gc GarbageCollection)
• func GarbageCollectionFromResponse(response *hrpc.Result) (garbage GarbageCollection, err error)
• func LifeCycleFromResponse(response *hrpc.Result) (lc LifeCycle, err error)
• func MultipartFromResponse(response *hrpc.Result, bucketName string) (multipart Multipart, err error)
• func ObjMapFromResponse(response *hrpc.Result) (objMap *ObjMap, err error)
• func ObjectFromResponse(response *hrpc.Result) (object *Object, err error)
• type HbaseClient
  • func NewHbaseClient() *HbaseClient
  • func (h *HbaseClient) AddBucketForUser(bucketName, userId string) (err error)
  • func (h *HbaseClient) CheckAndPutBucket(bucket Bucket) (bool, error)
  • func (h *HbaseClient) CreateMultipart(multipart Multipart) (err error)
  • func (h *HbaseClient) DeleteBucket(bucket Bucket) error
  • func (h *HbaseClient) DeleteMultipart(multipart Multipart) (err error)
  • func (h *HbaseClient) DeleteObject(object *Object) error
  • func (h *HbaseClient) DeleteObjectMap(objMap *ObjMap) error
  • func (h *HbaseClient) GetAllObject(bucketName, objectName, version string) (object []*Object, err error)
  • func (h *HbaseClient) GetBucket(bucketName string) (bucket Bucket, err error)
  • func (h *HbaseClient) GetBuckets() (buckets []Bucket, err error)
  • func (h *HbaseClient) GetCluster(fsid, pool string) (cluster Cluster, err error)
  • func (h *HbaseClient) GetMultipart(bucketName, objectName, uploadId string) (multipart Multipart, err error)
  • func (h *HbaseClient) GetObject(bucketName, objectName, version string) (object *Object, err error)
  • func (h *HbaseClient) GetObjectMap(bucketName, objectName string) (objMap *ObjMap, err error)
  • func (h *HbaseClient) GetUserBuckets(userId string) (buckets []string, err error)
  • func (h *HbaseClient) ListMultipartUploads(bucketName, keyMarker, uploadIdMarker, prefix, delimiter, encodingType string, ...) (uploads []datatype.Upload, prefixs []string, isTruncated bool, ...)
  • func (h *HbaseClient) ListObjects(bucketName, marker, verIdMarker, prefix, delimiter string, versioned bool, ...) (retObjects []*Object, prefixes []string, truncated bool, ...)
  • func (h *HbaseClient) PutBucket(bucket Bucket) error
  • func (h *HbaseClient) PutBucketPolicy(bucketName, policy string) error
  • func (h *HbaseClient) PutBucketToLifeCycle(lifeCycle LifeCycle) error
  • func (h *HbaseClient) PutObject(object *Object) error
  • func (h *HbaseClient) PutObjectMap(objMap *ObjMap) error
  • func (h *HbaseClient) PutObjectPart(multipart Multipart, part Part) (err error)
  • func (h *HbaseClient) PutObjectToGarbageCollection(object *Object) error
  • func (h *HbaseClient) RemoveBucketForUser(bucketName string, userId string) (err error)
  • func (h *HbaseClient) RemoveBucketFromLifeCycle(bucket Bucket) error
  • func (h *HbaseClient) RemoveBucketPolicy(bucketName string) error
  • func (h *HbaseClient) RemoveGarbageCollection(garbage GarbageCollection) error
  • func (h *HbaseClient) ScanGarbageCollection(limit int, startRowKey string) ([]GarbageCollection, error)
  • func (h *HbaseClient) ScanLifeCycle(limit int, marker string) (result ScanLifeCycleResult, err error)
  • func (h *HbaseClient) UpdateObjectAcl(object *Object) error
  • func (h *HbaseClient) UpdateUsage(bucketName string, size int64)

Variables

var RootContext = context.Background()

Functions

func GarbageCollectionFromObject

func GarbageCollectionFromObject(o *Object) (gc GarbageCollection)

func GarbageCollectionFromResponse

func GarbageCollectionFromResponse(response *hrpc.Result) (garbage GarbageCollection, err error)

util function

func LifeCycleFromResponse

func LifeCycleFromResponse(response *hrpc.Result) (lc LifeCycle, err error)

util function

func MultipartFromResponse

func MultipartFromResponse(response *hrpc.Result, bucketName string) (multipart Multipart,
	err error)

func ObjMapFromResponse

func ObjMapFromResponse(response *hrpc.Result) (objMap *ObjMap, err error)

util func

func ObjectFromResponse

func ObjectFromResponse(response *hrpc.Result) (object *Object, err error)

Decode response from HBase and return an Object object

Types

type HbaseClient

type HbaseClient struct {
	Client gohbase.Client
}

func NewHbaseClient

func NewHbaseClient() *HbaseClient

func (*HbaseClient) AddBucketForUser

func (h *HbaseClient) AddBucketForUser(bucketName, userId string) (err error)

func (*HbaseClient) CheckAndPutBucket

func (h *HbaseClient) CheckAndPutBucket(bucket Bucket) (bool, error)

func (*HbaseClient) CreateMultipart

func (h *HbaseClient) CreateMultipart(multipart Multipart) (err error)

func (*HbaseClient) DeleteBucket

func (h *HbaseClient) DeleteBucket(bucket Bucket) error

func (*HbaseClient) DeleteMultipart

func (h *HbaseClient) DeleteMultipart(multipart Multipart) (err error)

func (*HbaseClient) DeleteObject

func (h *HbaseClient) DeleteObject(object *Object) error

func (*HbaseClient) DeleteObjectMap

func (h *HbaseClient) DeleteObjectMap(objMap *ObjMap) error

func (*HbaseClient) GetAllObject

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

func (*HbaseClient) GetBucket

func (h *HbaseClient) GetBucket(bucketName string) (bucket Bucket, err error)

func (*HbaseClient) GetBuckets

func (h *HbaseClient) GetBuckets() (buckets []Bucket, err error)

func (*HbaseClient) GetCluster

func (h *HbaseClient) GetCluster(fsid, pool string) (cluster Cluster, err error)

func (*HbaseClient) GetMultipart

func (h *HbaseClient) GetMultipart(bucketName, objectName, uploadId string) (multipart Multipart, err error)

func (*HbaseClient) GetObject

func (h *HbaseClient) GetObject(bucketName, objectName, version string) (object *Object, err error)

func (*HbaseClient) GetObjectMap

func (h *HbaseClient) GetObjectMap(bucketName, objectName string) (objMap *ObjMap, err error)

func (*HbaseClient) GetUserBuckets

func (h *HbaseClient) GetUserBuckets(userId string) (buckets []string, err error)

func (*HbaseClient) ListMultipartUploads

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

func (*HbaseClient) ListObjects

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

func (*HbaseClient) PutBucket

func (h *HbaseClient) PutBucket(bucket Bucket) error

func (*HbaseClient) PutBucketPolicy

func (h *HbaseClient) PutBucketPolicy(bucketName, policy string) error

func (*HbaseClient) PutBucketToLifeCycle

func (h *HbaseClient) PutBucketToLifeCycle(lifeCycle LifeCycle) error

func (*HbaseClient) PutObject

func (h *HbaseClient) PutObject(object *Object) error

func (*HbaseClient) PutObjectMap

func (h *HbaseClient) PutObjectMap(objMap *ObjMap) error

func (*HbaseClient) PutObjectPart

func (h *HbaseClient) PutObjectPart(multipart Multipart, part Part) (err error)

func (*HbaseClient) PutObjectToGarbageCollection

func (h *HbaseClient) PutObjectToGarbageCollection(object *Object) error

func (*HbaseClient) RemoveBucketForUser

func (h *HbaseClient) RemoveBucketForUser(bucketName string, userId string) (err error)

func (*HbaseClient) RemoveBucketFromLifeCycle

func (h *HbaseClient) RemoveBucketFromLifeCycle(bucket Bucket) error

func (*HbaseClient) RemoveBucketPolicy

func (h *HbaseClient) RemoveBucketPolicy(bucketName string) error

func (*HbaseClient) RemoveGarbageCollection

func (h *HbaseClient) RemoveGarbageCollection(garbage GarbageCollection) error

func (*HbaseClient) ScanGarbageCollection

func (h *HbaseClient) ScanGarbageCollection(limit int, startRowKey string) ([]GarbageCollection, error)

func (*HbaseClient) ScanLifeCycle

func (h *HbaseClient) ScanLifeCycle(limit int, marker string) (result ScanLifeCycleResult, err error)

func (*HbaseClient) UpdateObjectAcl

func (h *HbaseClient) UpdateObjectAcl(object *Object) error

func (*HbaseClient) UpdateUsage

func (h *HbaseClient) UpdateUsage(bucketName string, size int64)