支持调用获取cibuckets接口

Author: wanjiewu

ci.go

@@ -2788,3 +2788,42 @@ func (s *CIService) DeleteImageSlim(ctx context.Context) (*Response, error) {
 	resp, err := s.client.send(ctx, sendOpt)
 	return resp, err
 }
+
+// CIBucketsOptions is the option of CIBuckets
+type DescribeCIBucketsOptions struct {
+	BucketName string `url:"bucketName,omitempty"`
+	TagKey     string `url:"tagKey,omitempty"`
+	PageNumber int    `url:"pageNumber,omitempty"`
+	PageSize   int    `url:"pageSize,omitempty"`
+}
+
+type CIBucketList struct {
+	BucketId   string `xml:"BucketId,omitempty"`
+	BucketName string `xml:"BucketName,omitempty"`
+	AppId      string `xml:"AppId,omitempty"`
+	CreateTime string `xml:"CreateTime,omitempty"`
+	Region     string `xml:"Region,omitempty"`
+	Status     string `xml:"Status,omitempty"`
+}
+
+type CIBucketsResult struct {
+	XMLName      xml.Name       `xml:"Response"`
+	RequestId    string         `xml:"RequestId,omitempty"`
+	TotalCount   string         `xml:"TotalCount,omitempty"`
+	PageNumber   string         `xml:"PageNumber,omitempty"`
+	PageSize     string         `xml:"PageSize,omitempty"`
+	CIBucketList []CIBucketList `xml:"CIBucketList,omitempty"`
+}
+
+func (s *CIService) DescribeCIBuckets(ctx context.Context, opt *DescribeCIBucketsOptions) (*CIBucketsResult, *Response, error) {
+	var res CIBucketsResult
+	sendOpt := &sendOptions{
+		baseURL:  s.client.BaseURL.CIURL,
+		uri:      "/cibuckets",
+		method:   http.MethodGet,
+		optQuery: opt,
+		result:   &res,
+	}
+	resp, err := s.client.send(ctx, sendOpt)
+	return &res, resp, err
+}

ci_test.go

@@ -3088,3 +3088,19 @@ func TestBucketService_DeleteImageSlim(t *testing.T) {
 		t.Fatalf("CI.DeleteImageSlim returned error: %v", err)
 	}
 }
+
+func TestBucketService_DescribeCIBuckets(t *testing.T) {
+	setup()
+	defer teardown()
+
+	mux.HandleFunc("/cibuckets", func(w http.ResponseWriter, r *http.Request) {
+		testMethod(t, r, "GET")
+	})
+
+	opt := &DescribeCIBucketsOptions{}
+
+	_, _, err := client.CI.DescribeCIBuckets(context.Background(), opt)
+	if err != nil {
+		t.Fatalf("CI.DescribeCIBuckets returned error: %v", err)
+	}
+}

example/CI/media_process/media_process.go

@@ -153,5 +153,16 @@ func CreateMediaProcessBucket() {
 	fmt.Printf("%+v\n", res)
 }
 
+func DescribeCIBuckets() {
+	c := getClient()
+	opt := &cos.DescribeCIBucketsOptions{
+		PageSize:   100,
+		PageNumber: 6,
+	}
+	res, _, err := c.CI.DescribeCIBuckets(context.Background(), opt)
+	log_status(err)
+	fmt.Printf("%+v\n", len(res.CIBucketList))
+}
+
 func main() {
 }