Documentation ¶
Index ¶
- Variables
- type Bucket
- type BucketQuota
- type BucketStatistic
- type BucketStatisticUsage
- type BucketUsage
- type BucketUsage1
- type Buckets
- type Caps
- type Key
- type ListAllMyBucketsResult
- type Owner
- type Quota
- type RgwClient
- func (rgw_client *RgwClient) Abort(rgwUid, bucketName, objkey, uploadid string)
- func (rgwClient *RgwClient) ActivityUser(uid, suspended string) (*UserInfo, error)
- func (rgwClient *RgwClient) AddUserCaps(uid, caps string) ([]Caps, error)
- func (rgw_client *RgwClient) CompleteUpload(rgwUid, bucketName, objkey, uploadid string, parts []s3.Part)
- func (rgwClient *RgwClient) CreateBucket(bucket, acl string) error
- func (rgwClient *RgwClient) CreateKey(uid string) ([]Key, error)
- func (rgwClient *RgwClient) CreateUser(uid, display_name, caps string, max_bucket int) (*UserInfo, error)
- func (rgwClient *RgwClient) GetBucket() ([]Bucket, error)
- func (rgwClient *RgwClient) GetBucketQuota(uid string) (bucketQuota Quota, err error)
- func (rgwClient *RgwClient) GetBucketStatistic(bucket string) (*BucketStatistic, error)
- func (rgwClient *RgwClient) GetBucketStatisticUsage(uid, start, end string) (*BucketStatisticUsage, error)
- func (rgw_client *RgwClient) GetHead(rgwUid, bucketName, objKey string) map[string][]string
- func (rgwClient *RgwClient) GetObject(bucket, object string) ([]byte, error)
- func (rgwClient *RgwClient) GetUserInfo(uid string) (*UserInfo, error)
- func (rgwClient *RgwClient) GetUserQuota(uid string) (userQuota Quota, err error)
- func (rgwClient *RgwClient) GetUserUsage(uid string) (userUage UserUsage, err error)
- func (rgw_client *RgwClient) InitMultiUpload(rgwUid, bucketName, objkey string, metadata map[string][]string) string
- func (rgw_client *RgwClient) ListParts(rgwUid, bucketName, objkey, uploadid string) []s3.Part
- func (rgwClient *RgwClient) ModifyUser(uid, display_name, caps string, max_bucket int) (*UserInfo, error)
- func (rgwClient *RgwClient) PutObject(bucket, object string, content *string, useMd5 bool) error
- func (rgwClient *RgwClient) RemoveBucket(bucket string) error
- func (rgwClient *RgwClient) RemoveKey(uid, access_key string) error
- func (rgwClient *RgwClient) RemoveObject(bucket, object string) error
- func (rgwClient *RgwClient) RemoveUser(uid string, purge_data bool) error
- func (rgwClient *RgwClient) RemoveUserCaps(uid, caps string) ([]Caps, error)
- func (rgwClient *RgwClient) RevokeObjectPublicRead(owner, bucket, object string) error
- func (rgwClient *RgwClient) SetBucketAcl(bucket, acl string) error
- func (rgwClient *RgwClient) SetBucketQuota(uid string, bucketQuota Quota) error
- func (rgwClient *RgwClient) SetObjectPublicRead(owner, bucket, object string) error
- func (rgwClient *RgwClient) SetUserQuota(uid string, userQuota Quota) error
- func (rgw_client *RgwClient) UploadParts(rgwUid, bucketName, objkey, uploadid, path string)
- type UserInfo
- type UserUsage
Constants ¶
This section is empty.
Variables ¶
View Source
var ERR_BUCKET_ALREADY_EXISTS = errors.New("BucketAlreadyExists")
View Source
var ERR_NOT_FOUND = errors.New("not found")
Functions ¶
This section is empty.
Types ¶
type BucketQuota ¶
type BucketStatistic ¶
type BucketStatistic struct { Bucket string `json:"bucket, omitempty"` Pool string `json:"pool, omitempty"` Index_pool string `json:"index_pool, omitempty"` Id string `json:"id, omitempty"` Marker string `json:"marker, omitempty"` Owner string `json:"owner, omitempty"` Ver string `json:"ver, omitempty"` Master_ver string `json:"master_ver, omitempty"` Mtime string `json:"mtime, omitempty"` Max_marker string `json:"max_marker, omitempty"` Usage BucketUsage `json:"usage, omitempty"` Bucket_quota BucketQuota `json:"bucket_quota, omitempty"` }
type BucketStatisticUsage ¶
type BucketStatisticUsage struct { Entries []struct { Owner string `json:"owner, omitempty"` Buckets []struct { Bucket string `json:"bucket, omitempty"` Time string `json:"time,omitempty"` Epoch int `json:"epoch, omitempty"` Categories []struct { Category string `json:"category, omitempty"` Bytes_sent int `json:"bytes_sent, omitempty"` Bytes_received int `json:"bytes_received, omitempty"` Ops int `json:"ops, omitempty"` Successful_ops int `json:"successful_ops,omitempty"` } `json:"categories, omitempty"` } `json:"buckets, omitempty"` } `json:"entries, omitempty"` }
type BucketUsage ¶
type BucketUsage struct { Rgw_main struct { Size_kb int `json:"size_kb, omitempty"` Size_kb_actual int `json:"size_kb_actual, omitempty"` Num_objects int `json:"num_objects, omitempty"` } `json:"rgw.main, omitempty"` Rgw_multimeta struct { Size_kb int `json:"size_kb, omitempty"` Size_kb_actual int `json:"size_kb_actual, omitempty"` Num_objects int `json:"num_objects, omitempty"` } `json:"rgw.multimeta, omitempty"` }
type BucketUsage1 ¶
type ListAllMyBucketsResult ¶
type RgwClient ¶
func (*RgwClient) ActivityUser ¶
func (*RgwClient) AddUserCaps ¶
func (*RgwClient) CompleteUpload ¶
func (*RgwClient) CreateBucket ¶
func (*RgwClient) CreateUser ¶
func (*RgwClient) GetBucketQuota ¶
func (*RgwClient) GetBucketStatistic ¶
func (rgwClient *RgwClient) GetBucketStatistic(bucket string) (*BucketStatistic, error)
获取bucket使用统计
func (*RgwClient) GetBucketStatisticUsage ¶
func (rgwClient *RgwClient) GetBucketStatisticUsage(uid, start, end string) (*BucketStatisticUsage, error)
func (*RgwClient) GetUserInfo ¶
func (*RgwClient) GetUserQuota ¶
func (*RgwClient) GetUserUsage ¶
func (*RgwClient) InitMultiUpload ¶
func (*RgwClient) ModifyUser ¶
func (*RgwClient) RemoveBucket ¶
func (*RgwClient) RemoveObject ¶
func (*RgwClient) RemoveUser ¶
func (*RgwClient) RemoveUserCaps ¶
func (*RgwClient) RevokeObjectPublicRead ¶
func (*RgwClient) SetBucketAcl ¶
func (*RgwClient) SetBucketQuota ¶
func (*RgwClient) SetObjectPublicRead ¶
func (*RgwClient) SetUserQuota ¶
func (*RgwClient) UploadParts ¶
Click to show internal directories.
Click to hide internal directories.